Openwrt路由器上开发微信公众号应用

利用nohup命令创建启动服务

nohup, /dev/null 2>&1,输出重定向

http://www.cnblogs.com/taosim/articles/2610170.html

Linux 技巧：让进程在后台可靠运行的几种方法

https://www.ibm.com/developerworks/cn/linux/l-cn-nohup/

[root@PandoraBox:/mnt/sda1/projects/openwrtpytest/utils]#opkg -d usb install /mn

t/sda1/ipk/coreutils_8.16-1_ramips_24kec.ipk

Installing coreutils (8.16-1) to usb...

Configuring coreutils.

[root@PandoraBox:/mnt/sda1/projects/openwrtpytest/utils]#opkg -d usb install /mn

t/sda1/ipk/coreutils-nohup_8.16-1_ramips_24kec.ipk

Installing coreutils-nohup (8.16-1) to usb...

Configuring coreutils-nohup.

后面的&是后台运行

Linux shell中有三种输入输出，分别为标准输入，标准输出，错误输出，分别对应0，1，2

ps命令无法看到nohup的job,用jobs -l

 

用nohup执行python程序时，print无法输出

nohup python test.py > nohup.out 2>&1 &

发现nohup.out中显示不出来python程序中print的东西。

这是因为python的输出有缓冲，导致nohup.out并不能够马上看到输出。

python 有个-u参数，使得python不启用缓冲。

nohup python -u test.py > nohup.out 2>&1 &

 

创建启动服务

/etc/init.d/wechat

#!/bin/sh /etc/rc.common

# Example script

# Copyright (C) 2007 OpenWrt.org

START=10

STOP=15

start() {

        echo "wechat start" >> /mnt/sda1/temp/log

		date -R >> /mnt/sda1/temp/log

        nohup python -u /mnt/sda1/projects/openwrtpytest/utils/webhelper.py 2>>/mnt/sda1/temp/log 1>>/mnt/sda1/temp/log &

        # commands to launch application

}

stop() {

        echo "wechat stop" >> /mnt/sda1/temp/log

		date -R >> /mnt/sda1/temp/log

        # commands to kill application

　　

chmod 777 /etc/init.d/wechat

启动

/etc/init.d/wechat start

注意wechat里面的\r\n要换成linux下的\n，不然会出错

如果重复启动后报错端口被占用，要先把原先的进程杀掉

error: [Errno 125] Address already in use

[root@PandoraBox:/mnt/sda1/projects/openwrtpytest/utils]#netstat -atpn | grep 8001

Active Internet connections (servers and established)

Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name

tcp 0 0 0.0.0.0:8001 0.0.0.0:* LISTEN 2626/python

kill 2626

 

webhelper.py

from wsgiref.simple_server import make_server

from wechat import app

PORT = 8001

httpd = make_server('', PORT, app)

httpd.allow_reuse_address = True

httpd.serve_forever()

 wechat.py

#!/mnt/sda1/opkg/usr/bin/python

#coding:utf-8

import sys

reload(sys)

sys.setdefaultencoding('utf8')

import time

from flask import Flask, request,make_response,render_template

import hashlib

import xml.etree.ElementTree as ET

import loghelper

import traceback

import requests

import os

import pprint

import uniout

import apihelper

import yaml

import pickledb

app = Flask(__name__)

app.debug=True

logger = loghelper.create_logger(r'/mnt/sda1/temp/log')

app_root = os.path.dirname(__file__)

templates_root = os.path.join(app_root, 'templates/reply_text.xml')

api = apihelper.ApiHelper()

cachefpath='../data/cache.db'

cachedb = pickledb.load(cachefpath,True)

@app.route('/',methods=['GET','POST'])

def wechat_auth():

    msg = "funcname : %s , request.args : %s" % (__name__ ,request.args)

    logger.info(msg)

    response = make_response("")

    try:

        if request.method == 'GET':

            token='weixintest'

            data = request.args

            pprint.pprint( "Request get data:",data)

            signature = data.get('signature','')

            timestamp = data.get('timestamp','')

            nonce = data.get('nonce','')

            echostr = data.get('echostr','')

            s = [timestamp,nonce,token]

            s.sort()

            s = ''.join(s)

            if (hashlib.sha1(s).hexdigest() == signature):

                response  = make_response(echostr)

            else:

                response  = make_response("Not Valid!")

        else:

            rec = request.stream.read()

            print "Request post data:",rec

            xml_rec = ET.fromstring(rec)

            datadict = get_replydata(xml_rec)

            pprint.pprint(datadict)

            render = render_template("reply_text.xml",dict=datadict)

            response = make_response(render)

            #xml_rep = get_response(xml_rec)

            #response = make_response(xml_rep)

            response.content_type='application/xml;charset=utf-8'

    except Exception,e:

            type =xml_rec.find("MsgType").text

            tou = xml_rec.find('ToUserName').text

            fromu = xml_rec.find('FromUserName').text

            datadict = {"to":fromu,"from":tou,"time":str(int(time.time())),"type":type,"msg":e.message}

            render = render_template("reply_text.xml",dict=datadict)

            response = make_response(render)

            # log the exception

            err = "exception : %s , %s" % (e.message ,traceback.format_exc())

            logger.exception(err)

    finally:

        #pprint.pprint( request.__dict__)

        pprint.pprint( response.__dict__)

        return response

def get_replydata(xml_rec):

    '''

    import xml2dict

    xml = xml2dict.XML2Dict()

    r = xml.fromstring(textdata)

    r.get('xml').get('FromUserName').get('value')

    '''

    type =xml_rec.find("MsgType").text

    tou = xml_rec.find('ToUserName').text

    fromu = xml_rec.find('FromUserName').text

    datadict = {"to":fromu,"from":tou,"time":str(int(time.time())),"type":type,"msg":""}

    if type == 'image' or type == 'voice':

        dmedia_id = xml_rec.find('MediaId').text

        purl = xml_rec.find('PicUrl').text

        fname = xml_rec.find('CreateTime').text

        import urllib

        urllib.urlretrieve(purl,'/mnt/sda1/data/image/%s.jpg' % fname)

        print purl

    elif type == 'location':

        locx = xml_rec.find('Location_X').text

        locy = xml_rec.find('Location_Y').text

        scale = xml_rec.find('Scale').text

        location = xml_rec.find('Label').text

        wjdu="%s,%s" % (locx,locy)

        data = api.location(wjdu)

        datadict["msg"]=data

    else:

        content = xml_rec.find("Content").text

        data = get_replytext(content)

        datadict["msg"]=data

    print datadict.get("msg")

    return datadict

def get_replytext(content):

    content = content.strip()

    print 'enter content :',content

    cvalue = cachedb.get(content)

    cvalue =None

    if cvalue<>None:

        print 'get it from cache'

        data=cvalue

    else:

        if content.lower().startswith("ip"):

            content=content.replace("ip","").strip()

            data = api.ip(content)

        elif content.startswith(u"航班"):

            data=api.airline(content)

        elif content.startswith(u"火车"):

            data=api.train(content)

        elif content.startswith(u"翻译"):

            data=api.translator(content)

        elif content.startswith(u"手机"):

            data=api.mobile(content)

        elif content.startswith(u"简体") or content.startswith(u"繁体"):

            data=api.tradition(content)

        elif content.startswith(u"汇率"):

            data=api.huilv(content)

        else:

            data = api.weather(content)

        cachedb.set(content,data)

    return data

if __name__ == '__main__':

    path='../conf/test.yaml'

    with open(path) as f:

        x=yaml.load(f)

    textdata = x.get('textdata')

    wxlink = x.get('wxlink')

    r=requests.get(wxlink)

    print r.text

    r=requests.post(wxlink,textdata)

    print r.text

这里实现了查询航班，火车，汇率，中英文翻译，简繁体转换，查询当前IP，手机所在地的功能

代码放在github上
https://github.com/sui84/openwrtpytest

另外pandorbox上的python安装文件为了可以运行有些改动，放在这里

https://github.com/sui84/PandorboxPython27