Python+Tornado開(kāi)發(fā)微信公眾號(hào)

時(shí)間：2023-05-30 21:00:01 | 來(lái)源：網(wǎng)站運(yùn)營(yíng)

時(shí)間：2023-05-30 21:00:01 來(lái)源：網(wǎng)站運(yùn)營(yíng)

Python+Tornado開(kāi)發(fā)微信公眾號(hào)：本教程針對(duì)的是已掌握Python語(yǔ)言基本用法并且掌握其任一Web框架的用戶。

本教程使用的Python版本為3.5.0, Web框架為Tornado， IDE開(kāi)發(fā)工具為PyCharm，整個(gè)開(kāi)發(fā)過(guò)程是在Windows環(huán)境下測(cè)試開(kāi)發(fā),最終上線部署至centos服務(wù)器。

備注：(1) 如果您是python小白,建議參考 Python入門(mén)教程

(2) 對(duì)tornado框架還不熟悉的同學(xué),建議參考 Tornado中文文檔

本教程整體框架如下:

1. Python開(kāi)發(fā)環(huán)境和項(xiàng)目的初始化搭建；

2. 微信公眾號(hào)注冊(cè)及開(kāi)發(fā)模式校驗(yàn)配置；

3. 接收關(guān)注/取關(guān)事件推送和自動(dòng)回復(fù)；

4. IOLoop定時(shí)獲取access_token和jsapi_ticket；

5. 自定義菜單及點(diǎn)擊菜單時(shí)獲取openid；

6. 菜單中網(wǎng)頁(yè)的開(kāi)發(fā), JS-SDK的使用；

7. 完成測(cè)試,發(fā)布上線,部署至centos服務(wù)器。

思維導(dǎo)圖如下:


整體項(xiàng)目結(jié)構(gòu)如下:




下面我們正式進(jìn)入詳細(xì)的開(kāi)發(fā)流程

一. Python開(kāi)發(fā)環(huán)境和項(xiàng)目的初始化搭建

1. 安裝python及pip,并配置環(huán)境變量,安裝tornado框架
Python及pip安裝參考教程windows下面安裝Python和pip終極教程
(1) 下載Python包并安裝 點(diǎn)此下載
(2) 將python配置到系統(tǒng)環(huán)境變量
(3) 下載pip包并安裝 點(diǎn)此下載
(4) 將pip配置到系統(tǒng)環(huán)境變量
(5) 使用pip安裝tornado框架 指令為:




pip install tornado2. 選擇一款開(kāi)發(fā)Python的IDE
本教程使用的是PyCharm點(diǎn)擊下載
附帶: PyCharm 2016.2.3專(zhuān)業(yè)版注冊(cè)碼

3. 選擇一個(gè)代碼托管平臺(tái)
本教程使用的是開(kāi)源中國(guó)Git@osc代碼托管平臺(tái) 碼云 - 開(kāi)源中國(guó)代碼托管平臺(tái),請(qǐng)自行注冊(cè),并配置賬戶下的SSH密鑰,關(guān)于Git的使用,請(qǐng)參考教程 Git教程 - 廖雪峰的官方網(wǎng)站
4. 創(chuàng)建Web項(xiàng)目
使用Tornado搭建項(xiàng)目入口,端口號(hào)為8000,項(xiàng)目搭建至完成微信校驗(yàn)所需的基本代碼如下:
項(xiàng)目整體目錄

• 為了方便調(diào)試,編寫(xiě)了日志管理文件 logger_helper.py
  

備注: 為防止日志輸出報(bào)錯(cuò), 請(qǐng)各位同學(xué)注意修改日志輸出目錄為自己定義的文件目錄





import loggingfrom logging import Loggerfrom logging.handlers import TimedRotatingFileHandler'''日志管理類(lèi)'''def init_logger(logger_name): if logger_name not in Logger.manager.loggerDict: logger1 = logging.getLogger(logger_name) logger1.setLevel(logging.INFO) # 設(shè)置最低級(jí)別 # logger1.setLevel(logging.DEBUG) # 設(shè)置最低級(jí)別 df = '%Y-%m-%d %H:%M:%S' format_str = '[%(asctime)s]: %(name)s %(levelname)s %(lineno)s %(message)s' formatter = logging.Formatter(format_str, df) # handler all try: handler1 = TimedRotatingFileHandler('/usr/web_wx/log/all.log', when='D', interval=1, backupCount=7) except Exception: handler1 = TimedRotatingFileHandler('F:/program/web_wx/core/log//all.log', when='D', interval=1, backupCount=7) handler1.setFormatter(formatter) handler1.setLevel(logging.DEBUG) logger1.addHandler(handler1) # handler error try: handler2 = TimedRotatingFileHandler('/usr/web_wx/log/error.log', when='D', interval=1, backupCount=7) except Exception: handler2 = TimedRotatingFileHandler('F:/program/web_wx/core/log/error.log', when='D', interval=1, backupCount=7) handler2.setFormatter(formatter) handler2.setLevel(logging.ERROR) logger1.addHandler(handler2) # console console = logging.StreamHandler() console.setLevel(logging.DEBUG) # 設(shè)置日志打印格式 console.setFormatter(formatter) # 將定義好的console日志handler添加到root logger logger1.addHandler(console) logger1 = logging.getLogger(logger_name) return logger1logger = init_logger('runtime-log')if __name__ == '__main__': logger.debug('test-debug') logger.info('test-info') logger.warn('test-warn') logger.error('test-error')

• 微信服務(wù)端校驗(yàn)的接口文件 wxauthorize.py
  

from core.logger_helper import loggerimport hashlibimport tornado.webclass WxSignatureHandler(tornado.web.RequestHandler): """ 微信服務(wù)器簽名驗(yàn)證, 消息回復(fù) check_signature: 校驗(yàn)signature是否正確 """ def data_received(self, chunk): pass def get(self): try: signature = self.get_argument('signature') timestamp = self.get_argument('timestamp') nonce = self.get_argument('nonce') echostr = self.get_argument('echostr') logger.debug('微信sign校驗(yàn),signature='+signature+',&timestamp='+timestamp+'&nonce='+nonce+'&echostr='+echostr) result = self.check_signature(signature, timestamp, nonce) if result: logger.debug('微信sign校驗(yàn),返回echostr='+echostr) self.write(echostr) else: logger.error('微信sign校驗(yàn),---校驗(yàn)失敗') except Exception as e: logger.error('微信sign校驗(yàn),---Exception' + str(e)) def check_signature(self, signature, timestamp, nonce): """校驗(yàn)token是否正確""" token = 'test12345' L = [timestamp, nonce, token] L.sort() s = L[0] + L[1] + L[2] sha1 = hashlib.sha1(s.encode('utf-8')).hexdigest() logger.debug('sha1=' + sha1 + '&signature=' + signature) return sha1 == signature

• 配置Tornado的url路由規(guī)則 url.py
  

from core.server.wxauthorize import WxSignatureHandlerimport tornado.web'''web解析規(guī)則'''urlpatterns = [ (r'/wxsignature', WxSignatureHandler), # 微信簽名 ]

• 基本配置文件 run.py
  

import osimport tornado.httpserverimport tornado.ioloopimport tornado.webfrom tornado.options import define, optionsfrom core.url import urlpatternsdefine('port', default=8000, help='run on the given port', type=int)class Application(tornado.web.Application): def __init__(self): settings = dict( template_path=os.path.join(os.path.dirname(__file__), "core/template"), static_path=os.path.join(os.path.dirname(__file__), "core/static"), debug=True, login_url='/login', cookie_secret='MuG7xxacQdGPR7Svny1OfY6AymHPb0H/t02+I8rIHHE=', ) super(Application, self).__init__(urlpatterns, **settings)def main(): tornado.options.parse_command_line() http_server = tornado.httpserver.HTTPServer(Application()) http_server.listen(options.port) tornado.ioloop.IOLoop.current().start()if __name__ == '__main__': main()
(5) 同步項(xiàng)目文件至Git托管平臺(tái)
項(xiàng)目入口文件及微信校驗(yàn)文件已編寫(xiě)好,使用Git同步代碼至托管平臺(tái),接下來(lái)需要配置端口映射,使外網(wǎng)能訪問(wèn)到我們的本地項(xiàng)目,便于完成微信服務(wù)端校驗(yàn).

5. 使用花生殼,配置本地測(cè)試所需端口映射
微信公眾號(hào)開(kāi)發(fā)需要配置服務(wù)端URL, 驗(yàn)證URL的有效性,這個(gè)URL必須以http://或https://開(kāi)頭，分別支持80端口和443端口,我們目前測(cè)試階段都是在自己電腦上測(cè)試(本地測(cè)試),為了滿足不斷修改代碼能夠即時(shí)生效, 因此需要一個(gè)外網(wǎng)ip端口映射到本地(內(nèi)網(wǎng)穿透),我本人使用的是花生殼內(nèi)網(wǎng)穿透服務(wù),下面是花生殼的使用流程:
(1) 花生殼的賬戶注冊(cè) 花生殼軟件-內(nèi)網(wǎng)也能用！內(nèi)網(wǎng)動(dòng)態(tài)域名,注冊(cè)成功后,會(huì)贈(zèng)送一個(gè)免費(fèi)域名,這個(gè)域名同時(shí)也配備了一個(gè)公網(wǎng)ip
(2) 進(jìn)入到花生殼管理界面, 選擇內(nèi)網(wǎng)穿透菜單,進(jìn)入到配置界面



(3) 選擇 右邊的"編輯"操作,彈出編輯映射面板,在"內(nèi)網(wǎng)主機(jī)"一項(xiàng),填上自己本地電腦的ip地址,端口填寫(xiě)自己將要?jiǎng)?chuàng)建的web應(yīng)用端口,我本地項(xiàng)目用的端口號(hào)為8000,此處填寫(xiě)8000即可

二. 微信公眾號(hào)注冊(cè)及開(kāi)發(fā)模式校驗(yàn)配置

1. 微信公眾號(hào)注冊(cè)
官網(wǎng)鏈接https://mp.weixin.qq.com/,依次填寫(xiě)信息進(jìn)行注冊(cè)
2.微信公眾開(kāi)發(fā)模式校驗(yàn)配置
(1)登錄微信公眾號(hào)后, 進(jìn)入基本配置,如下:


URL 填寫(xiě)為: 花生殼的域名+我們項(xiàng)目中微信校驗(yàn)的接口名:
http://XXXXXXX.imwork.net/wxsignature
token 填寫(xiě)為我們項(xiàng)目中自定義的token: test12345
EncodingAESKey 點(diǎn)擊"隨機(jī)生成"按鈕即可,消息加密方式使用明文模式

填寫(xiě)完畢后,先啟動(dòng)我們的項(xiàng)目,運(yùn)行python run.py指令后, 保證我們的服務(wù)器是運(yùn)行著的, 然后點(diǎn)擊"提交",如果你是按照以上流程操作的話,會(huì)提示提交成功,否則校驗(yàn)失敗,需要我們通過(guò)日志檢查是哪一塊出了問(wèn)題.
(2) 接下來(lái),校驗(yàn)成功后,點(diǎn)擊啟用,即可激活開(kāi)發(fā)者模式

三.接收關(guān)注/取關(guān)事件推送和自動(dòng)回復(fù)

1. 接收關(guān)注/取關(guān)事件推送
在開(kāi)發(fā)模式中,有新用戶關(guān)注我們的公眾號(hào)時(shí),微信公眾平臺(tái)會(huì)使用http協(xié)議的Post方式推送數(shù)據(jù)至我們的后臺(tái)微信校驗(yàn)的接口,在接收到消息后,我們后臺(tái)發(fā)送一條歡迎語(yǔ)給該用戶,關(guān)于微信公眾平臺(tái)推送消息的具體內(nèi)容和數(shù)據(jù)格式,詳見(jiàn)微信開(kāi)發(fā)文檔

• wxauthorize.py
  

以下是在該文件中增加的post方法,用來(lái)接收事件推送





def post(self): body = self.request.body logger.debug('微信消息回復(fù)中心】收到用戶消息' + str(body.decode('utf-8'))) data = ET.fromstring(body) ToUserName = data.find('ToUserName').text FromUserName = data.find('FromUserName').text MsgType = data.find('MsgType').text if MsgType == 'event': '''接收事件推送''' try: Event = data.find('Event').text if Event == 'subscribe': # 關(guān)注事件 CreateTime = int(time.time()) reply_content = '歡迎關(guān)注我的公眾號(hào)~' out = self.reply_text(FromUserName, ToUserName, CreateTime, reply_content) self.write(out) except: passdef reply_text(self, FromUserName, ToUserName, CreateTime, Content): """回復(fù)文本消息模板""" textTpl = """<xml> <ToUserName><![CDATA[%s]]></ToUserName> <FromUserName><![CDATA[%s]]></FromUserName> <CreateTime>%s</CreateTime> <MsgType><![CDATA[%s]]></MsgType> <Content><![CDATA[%s]]></Content></xml>""" out = textTpl % (FromUserName, ToUserName, CreateTime, 'text', Content) return out2. 自動(dòng)回復(fù)

(1) 同接收關(guān)注/取關(guān)事件推送消息一樣,用戶給我們公眾號(hào)發(fā)送消息時(shí),微信公眾平臺(tái)也會(huì)推送數(shù)據(jù)至我們的后臺(tái)微信校驗(yàn)的接口,在接收到消息后,我們?nèi)〕鲎远x的關(guān)鍵字進(jìn)行匹配,匹配到了就執(zhí)行自動(dòng)回復(fù)
(2) 微信公眾平臺(tái)也提供了語(yǔ)音識(shí)別功能, 將用戶發(fā)送的語(yǔ)音內(nèi)容識(shí)別轉(zhuǎn)化為文字,發(fā)送給我們后臺(tái),在使用該功能時(shí)需要在接口權(quán)限中打開(kāi)語(yǔ)音識(shí)別功能.

• wxauthorize.py
  

以下是在該文件中post方法中增加的一個(gè)判斷,用來(lái)匹配用戶文本消息和語(yǔ)音消息中的關(guān)鍵字





def post(self): body = self.request.body logger.debug('微信消息回復(fù)中心】收到用戶消息' + str(body.decode('utf-8'))) data = ET.fromstring(body) ToUserName = data.find('ToUserName').text FromUserName = data.find('FromUserName').text MsgType = data.find('MsgType').text if MsgType == 'text' or MsgType == 'voice': '''文本消息 or 語(yǔ)音消息''' try: MsgId = data.find("MsgId").text if MsgType == 'text': Content = data.find('Content').text # 文本消息內(nèi)容 elif MsgType == 'voice': Content = data.find('Recognition').text # 語(yǔ)音識(shí)別結(jié)果，UTF8編碼 if Content == u'你好': reply_content = '您好,請(qǐng)問(wèn)有什么可以幫助您的嗎?' else: # 查找不到關(guān)鍵字,默認(rèn)回復(fù) reply_content = "客服小兒智商不夠用啦~" if reply_content: CreateTime = int(time.time()) out = self.reply_text(FromUserName, ToUserName, CreateTime, reply_content) self.write(out) except: pass elif MsgType == 'event': '''接收事件推送''' try: Event = data.find('Event').text if Event == 'subscribe': # 關(guān)注事件 CreateTime = int(time.time()) reply_content = self.sys_order_reply out = self.reply_text(FromUserName, ToUserName, CreateTime, reply_content) self.write(out) except: pass def reply_text(self, FromUserName, ToUserName, CreateTime, Content): """回復(fù)文本消息模板""" textTpl = """<xml> <ToUserName><![CDATA[%s]]></ToUserName> <FromUserName><![CDATA[%s]]></FromUserName> <CreateTime>%s</CreateTime> <MsgType><![CDATA[%s]]></MsgType> <Content><![CDATA[%s]]></Content></xml>""" out = textTpl % (FromUserName, ToUserName, CreateTime, 'text', Content) return out

四. IOLoop定時(shí)獲取access_token和jsapi_ticket

1. access_token
access_token是公眾號(hào)的全局唯一票據(jù)，公眾號(hào)調(diào)用各接口時(shí)都需使用access_token。開(kāi)發(fā)者需要進(jìn)行妥善保存。access_token的存儲(chǔ)至少要保留512個(gè)字符空間。access_token的有效期目前為2個(gè)小時(shí)，需定時(shí)刷新，重復(fù)獲取將導(dǎo)致上次獲取的access_token失效。以下是文檔中的說(shuō)明 詳見(jiàn)微信開(kāi)發(fā)文檔




2. jsapi_ticket
jsapi_ticket是公眾號(hào)用于調(diào)用微信JS接口的臨時(shí)票據(jù)。正常情況下，jsapi_ticket的有效期為7200秒，通過(guò)access_token來(lái)獲取。由于獲取jsapi_ticket的api調(diào)用次數(shù)非常有限，頻繁刷新jsapi_ticket會(huì)導(dǎo)致api調(diào)用受限，影響自身業(yè)務(wù)，開(kāi)發(fā)者必須在自己的服務(wù)全局緩存jsapi_ticket 。參考文檔JS-SDK使用權(quán)限簽名算法


3. Redis數(shù)據(jù)庫(kù)
如果有對(duì)Redis不了解的同學(xué),可參考Redis快速入門(mén)

• basecache.py

import redis"""緩存服務(wù)器"""CACHE_SERVER = { 'host': '127.0.0.1', 'port': 6379, 'database': 0, 'password': '',}class BaseCache(object): """ 緩存類(lèi)父類(lèi) redis_ctl: redis控制句柄 """ _host = CACHE_SERVER.get('host', '') _port = CACHE_SERVER.get('port', '') _database = CACHE_SERVER.get('database', '') _password = CACHE_SERVER.get('password', '') @property def redis_ctl(self): """redis控制句柄""" redis_ctl = redis.Redis(host=self._host, port=self._port, db=self._database, password=self._password) return redis_ctl

• tokencache.py

from core.cache.basecache import BaseCachefrom core.logger_helper import loggerclass TokenCache(BaseCache): """ 微信token緩存 set_cache 添加redis get_cache 獲取redis """ _expire_access_token = 7200 # 微信access_token過(guò)期時(shí)間, 2小時(shí) _expire_js_token = 30 * 24 * 3600 # 微信js網(wǎng)頁(yè)授權(quán)過(guò)期時(shí)間, 30天 KEY_ACCESS_TOKEN = 'access_token' # 微信全局唯一票據(jù)access_token KEY_JSAPI_TICKET = 'jsapi_ticket' # JS_SDK權(quán)限簽名的jsapi_ticket def set_access_cache(self, key, value): """添加微信access_token驗(yàn)證相關(guān)redis""" res = self.redis_ctl.set(key, value) self.redis_ctl.expire(key, self._expire_access_token) logger.debug('【微信token緩存】setCache>>>key[' + key + '],value[' + value + ']') return res def set_js_cache(self, key, value): """添加網(wǎng)頁(yè)授權(quán)相關(guān)redis""" res = self.redis_ctl.set(key, value) self.redis_ctl.expire(key, self._expire_js_token) logger.debug('【微信token緩存】setCache>>>key[' + key + '],value[' + value + ']') return res def get_cache(self, key): """獲取redis""" try: v = (self.redis_ctl.get(key)).decode('utf-8') logger.debug(v) logger.debug('【微信token緩存】getCache>>>key[' + key + '],value[' + v + ']') return v except Exception: return None4. 使用tornado的 Ioloop 實(shí)現(xiàn)定時(shí)獲取access_token和 jsapi_ticket,并將獲取到的access_token和 jsapi_ticket保存在Redis數(shù)據(jù)庫(kù)中

• wxconfig.py
  

class WxConfig(object): """ 微信開(kāi)發(fā)--基礎(chǔ)配置 """ AppID = 'wxxxxxxxxxxxxxxxx' # AppID(應(yīng)用ID) AppSecret = '024a7fcxxxxxxxxxxxxxxxxxxxx' # AppSecret(應(yīng)用密鑰) '''獲取access_token''' config_get_access_token_url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s' % (AppID, AppSecret)

• wxshedule.py
  

from core.logger_helper import loggerimport tornado.ioloopimport requestsimport jsonfrom core.server.wxconfig import WxConfigfrom core.cache.tokencache import TokenCacheclass WxShedule(object): """ 定時(shí)任務(wù)調(diào)度器 excute 執(zhí)行定時(shí)器任務(wù) get_access_token 獲取微信全局唯一票據(jù)access_token get_jsapi_ticket 獲取JS_SDK權(quán)限簽名的jsapi_ticket """ _token_cache = TokenCache() # 微信token緩存實(shí)例 _expire_time_access_token = 7000 * 1000 # token過(guò)期時(shí)間 def excute(self): """執(zhí)行定時(shí)器任務(wù)""" logger.info('【獲取微信全局唯一票據(jù)access_token】>>>執(zhí)行定時(shí)器任務(wù)') tornado.ioloop.IOLoop.instance().call_later(0, self.get_access_token) tornado.ioloop.PeriodicCallback(self.get_access_token, self._expire_time_access_token).start() # tornado.ioloop.IOLoop.current().start() def get_access_token(self): """獲取微信全局唯一票據(jù)access_token""" url = WxConfig.config_get_access_token_url r = requests.get(url) logger.info('【獲取微信全局唯一票據(jù)access_token】Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.info('【獲取微信全局唯一票據(jù)access_token】>>>' + res) d = json.loads(res) if 'access_token' in d.keys(): access_token = d['access_token'] # 添加至redis中 self._token_cache.set_access_cache(self._token_cache.KEY_ACCESS_TOKEN, access_token) # 獲取JS_SDK權(quán)限簽名的jsapi_ticket self.get_jsapi_ticket() return access_token elif 'errcode' in d.keys(): errcode = d['errcode'] logger.info( '【獲取微信全局唯一票據(jù)access_token-SDK】errcode[' + errcode + '] , will retry get_access_token() method after 10s') tornado.ioloop.IOLoop.instance().call_later(10, self.get_access_token) else: logger.error('【獲取微信全局唯一票據(jù)access_token】request access_token error, will retry get_access_token() method after 10s') tornado.ioloop.IOLoop.instance().call_later(10, self.get_access_token) def get_jsapi_ticket(self): """獲取JS_SDK權(quán)限簽名的jsapi_ticket""" access_token = self._token_cache.get_cache(self._token_cache.KEY_ACCESS_TOKEN) if access_token: url = 'https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=%s&type=jsapi' % access_token r = requests.get(url) logger.info('【微信JS-SDK】獲取JS_SDK權(quán)限簽名的jsapi_ticket的Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.info('【微信JS-SDK】獲取JS_SDK權(quán)限簽名的jsapi_ticket>>>>' + res) d = json.loads(res) errcode = d['errcode'] if errcode == 0: jsapi_ticket = d['ticket'] # 添加至redis中 self._token_cache.set_access_cache(self._token_cache.KEY_JSAPI_TICKET, jsapi_ticket) else: logger.info('【微信JS-SDK】獲取JS_SDK權(quán)限簽名的jsapi_ticket>>>>errcode[' + errcode + ']') logger.info('【微信JS-SDK】request jsapi_ticket error, will retry get_jsapi_ticket() method after 10s') tornado.ioloop.IOLoop.instance().call_later(10, self.get_jsapi_ticket) else: logger.info('【微信JS-SDK】request jsapi_ticket error, will retry get_jsapi_ticket() method after 10s') tornado.ioloop.IOLoop.instance().call_later(10, self.get_jsapi_ticket) else: logger.error('【微信JS-SDK】獲取JS_SDK權(quán)限簽名的jsapi_ticket時(shí),access_token獲取失敗, will retry get_access_token() method after 10s') tornado.ioloop.IOLoop.instance().call_later(10, self.get_access_token)if __name__ == '__main__': wx_shedule = WxShedule() """執(zhí)行定時(shí)器""" wx_shedule.excute()

• run.py 將定時(shí)器的啟動(dòng)放在主程序入口處,保證每次啟動(dòng)服務(wù)器時(shí),重新啟動(dòng)定時(shí)器
  

import osimport tornado.httpserverimport tornado.ioloopimport tornado.webfrom tornado.options import define, optionsfrom core.url import urlpatternsfrom core.server.wxshedule import WxSheduledefine('port', default=8000, help='run on the given port', type=int)class Application(tornado.web.Application): def __init__(self): settings = dict( template_path=os.path.join(os.path.dirname(__file__), "core/template"), static_path=os.path.join(os.path.dirname(__file__), "core/static"), debug=True, login_url='/login', cookie_secret='MuG7xxacQdGPR7Svny1OfY6AymHPb0H/t02+I8rIHHE=', ) super(Application, self).__init__(urlpatterns, **settings)def main(): tornado.options.parse_command_line() http_server = tornado.httpserver.HTTPServer(Application()) http_server.listen(options.port) # 執(zhí)行定時(shí)任務(wù) wx_shedule = WxShedule() wx_shedule.excute() tornado.ioloop.IOLoop.current().start()if __name__ == '__main__': main()

五. 自定義菜單及點(diǎn)擊菜單時(shí)獲取openid

1. 編寫(xiě)菜單對(duì)應(yīng)的html頁(yè)面

• 先在template模板文件夾下制作一個(gè)html頁(yè)面,用于點(diǎn)擊自定義菜單時(shí)跳轉(zhuǎn)到的網(wǎng)頁(yè).
  

• 編寫(xiě)一個(gè)頁(yè)面處理類(lèi),用于接收tornado.web.RequestHandler請(qǐng)求
  

• 給PageHandler添加url規(guī)則
  

2.創(chuàng)建一個(gè)菜單,并給菜單添加獲取授權(quán)code的URL

以下是微信公眾平臺(tái)官方文檔給出的具體流程,詳見(jiàn) 網(wǎng)頁(yè)授權(quán)獲取用戶基本信息

我們希望在用戶點(diǎn)擊自定義菜單時(shí),需要先獲取用戶的openid,以便從我們自己的后臺(tái)中通過(guò)該openid獲取這個(gè)用戶更多的信息,比如它對(duì)應(yīng)的我們后臺(tái)中的uid等, 如果我們后臺(tái)中沒(méi)有這個(gè)用戶,則需要執(zhí)行綁定等操作.

因此我們需要給這個(gè)自定義菜單按鈕添加一個(gè)對(duì)應(yīng)的URL,點(diǎn)擊這個(gè)菜單,跳轉(zhuǎn)到這個(gè)URL,這個(gè)URL會(huì)觸發(fā)獲取code操作,獲取到code后,通過(guò)獲取授權(quán)的access_token接口,獲取openid及access_token

(1) 給菜單添加url,及state映射關(guān)系

• state為自定義字符串,可以用來(lái)標(biāo)識(shí)是用戶點(diǎn)擊了哪一個(gè)菜單,放在一個(gè)dict字典中,當(dāng)前我們制作的第一個(gè)菜單就對(duì)應(yīng) /page/index 映射
  

(2) 點(diǎn)擊菜單時(shí),觸發(fā)獲取code接口,微信公眾平臺(tái)攜帶code和state請(qǐng)求訪問(wèn)我們后臺(tái)的 /wx/wxauthor 接口,根據(jù)state字段獲取 /page/index 映射,用來(lái)做重定向用.通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token及openid,拿到openid后我們就可以重定向跳轉(zhuǎn)到 /page/index映射對(duì)應(yīng)的頁(yè)面 index.html


附:涉及到的主要程序代碼如下:

• wxconfig.py
  

class WxConfig(object): """ 微信開(kāi)發(fā)--基礎(chǔ)配置 """ AppID = 'wxxxxxxxxxxxxxxxx' # AppID(應(yīng)用ID) AppSecret = '024a7fcxxxxxxxxxxxxxxxxxxxx' # AppSecret(應(yīng)用密鑰) """微信網(wǎng)頁(yè)開(kāi)發(fā)域名""" AppHost = 'http://xxxxxx.com' '''獲取access_token''' config_get_access_token_url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s' % (AppID, AppSecret) '''自定義菜單創(chuàng)建接口''' menu_create_url = 'https://api.weixin.qq.com/cgi-bin/menu/create?access_token=' '''自定義菜單查詢接口''' menu_get_url = 'https://api.weixin.qq.com/cgi-bin/menu/get?access_token=' '''自定義菜單刪除接口''' menu_delete_url = 'https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=' '''微信公眾號(hào)菜單映射數(shù)據(jù)''' """重定向后會(huì)帶上state參數(shù)，開(kāi)發(fā)者可以填寫(xiě)a-zA-Z0-9的參數(shù)值，最多128字節(jié)""" wx_menu_state_map = { 'menuIndex0': '%s/page/index' % AppHost, # 測(cè)試菜單1 }

• wxauthorize.py 中的 WxAuthorServer類(lèi)

class WxAuthorServer(object): """ 微信網(wǎng)頁(yè)授權(quán)server get_code_url 獲取code的url get_auth_access_token 通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token refresh_token 刷新access_token check_auth 檢驗(yàn)授權(quán)憑證（access_token）是否有效 get_userinfo 拉取用戶信息 """ """授權(quán)后重定向的回調(diào)鏈接地址，請(qǐng)使用urlencode對(duì)鏈接進(jìn)行處理""" REDIRECT_URI = '%s/wx/wxauthor' % WxConfig.AppHost """ 應(yīng)用授權(quán)作用域 snsapi_base （不彈出授權(quán)頁(yè)面，直接跳轉(zhuǎn)，只能獲取用戶openid） snsapi_userinfo （彈出授權(quán)頁(yè)面，可通過(guò)openid拿到昵稱(chēng)、性別、所在地。并且，即使在未關(guān)注的情況下，只要用戶授權(quán)，也能獲取其信息） """ SCOPE = 'snsapi_base' # SCOPE = 'snsapi_userinfo' """通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token""" get_access_token_url = 'https://api.weixin.qq.com/sns/oauth2/access_token?' """拉取用戶信息""" get_userinfo_url = 'https://api.weixin.qq.com/sns/userinfo?' def get_code_url(self, state): """獲取code的url""" dict = {'redirect_uri': self.REDIRECT_URI} redirect_uri = urllib.parse.urlencode(dict) author_get_code_url = 'https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&%s&response_type=code&scope=%s&state=%s#wechat_redirect' % (WxConfig.AppID, redirect_uri, self.SCOPE, state) logger.debug('【微信網(wǎng)頁(yè)授權(quán)】獲取網(wǎng)頁(yè)授權(quán)的code的url>>>>' + author_get_code_url) return author_get_code_url def get_auth_access_token(self, code): """通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token""" url = self.get_access_token_url + 'appid=%s&secret=%s&code=%s&grant_type=authorization_code' % (WxConfig.AppID, WxConfig.AppSecret, code) r = requests.get(url) logger.debug('【微信網(wǎng)頁(yè)授權(quán)】通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token的Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.debug('【微信網(wǎng)頁(yè)授權(quán)】通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token>>>>' + res) json_res = json.loads(res) if 'access_token' in json_res.keys(): return json_res elif 'errcode' in json_res.keys(): errcode = json_res['errcode']

• wxmenu.py

import requestsimport jsonfrom core.server.wxconfig import WxConfigfrom core.cache.tokencache import TokenCachefrom core.logger_helper import loggerfrom core.server.wxauthorize import WxAuthorServerclass WxMenuServer(object): """ 微信自定義菜單 create_menu 自定義菜單創(chuàng)建接口 get_menu 自定義菜單查詢接口 delete_menu 自定義菜單刪除接口 create_menu_data 創(chuàng)建菜單數(shù)據(jù) """ _token_cache = TokenCache() # 微信token緩存 _wx_author_server = WxAuthorServer() # 微信網(wǎng)頁(yè)授權(quán)server def create_menu(self): """自定義菜單創(chuàng)建接口""" access_token = self._token_cache.get_cache(self._token_cache.KEY_ACCESS_TOKEN) if access_token: url = WxConfig.menu_create_url + access_token data = self.create_menu_data() r = requests.post(url, data.encode('utf-8')) logger.debug('【微信自定義菜單】自定義菜單創(chuàng)建接口Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.debug('【微信自定義菜單】自定義菜單創(chuàng)建接口' + res) json_res = json.loads(res) if 'errcode' in json_res.keys(): errcode = json_res['errcode'] return errcode else: logger.error('【微信自定義菜單】自定義菜單創(chuàng)建接口獲取不到access_token') def get_menu(self): """自定義菜單查詢接口""" access_token = self._token_cache.get_cache(self._token_cache.KEY_ACCESS_TOKEN) if access_token: url = WxConfig.menu_get_url + access_token r = requests.get(url) logger.debug('【微信自定義菜單】自定義菜單查詢接口Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.debug('【微信自定義菜單】自定義菜單查詢接口' + res) json_res = json.loads(res) if 'errcode' in json_res.keys(): errcode = json_res['errcode'] return errcode else: logger.error('【微信自定義菜單】自定義菜單查詢接口獲取不到access_token') def delete_menu(self): """自定義菜單刪除接口""" access_token = self._token_cache.get_cache(self._token_cache.KEY_ACCESS_TOKEN) if access_token: url = WxConfig.menu_delete_url + access_token r = requests.get(url) logger.debug('【微信自定義菜單】自定義菜單刪除接口Response[' + str(r.status_code) + ']') if r.status_code == 200: res = r.text logger.debug('【微信自定義菜單】自定義菜單刪除接口' + res) json_res = json.loads(res) if 'errcode' in json_res.keys(): errcode = json_res['errcode'] return errcode else: logger.error('【微信自定義菜單】自定義菜單刪除接口獲取不到access_token') def create_menu_data(self): """創(chuàng)建菜單數(shù)據(jù)""" menu_data = {'button': []} # 大菜單 menu_Index0 = { 'type': 'view', 'name': '測(cè)試菜單1', 'url': self._wx_author_server.get_code_url('menuIndex0') } menu_data['button'].append(menu_Index0) MENU_DATA = json.dumps(menu_data, ensure_ascii=False) logger.debug('【微信自定義菜單】創(chuàng)建菜單數(shù)據(jù)MENU_DATA[' + str(MENU_DATA) + ']') return MENU_DATAif __name__ == '__main__': wx_menu_server = WxMenuServer() '''創(chuàng)建菜單數(shù)據(jù)''' # wx_menu_server.create_menu_data() # '''自定義菜單創(chuàng)建接口''' wx_menu_server.create_menu() '''自定義菜單查詢接口''' # wx_menu_server.get_menu() '''自定義菜單刪除接口''' # wx_menu_server.delete_menu()wx_handler.py





import tornado.webfrom core.logger_helper import loggerfrom core.server.wxauthorize import WxConfigfrom core.server.wxauthorize import WxAuthorServerfrom core.cache.tokencache import TokenCacheclass WxHandler(tornado.web.RequestHandler): """ 微信handler處理類(lèi) """ '''微信配置文件''' wx_config = WxConfig() '''微信網(wǎng)頁(yè)授權(quán)server''' wx_author_server = WxAuthorServer() '''redis服務(wù)''' wx_token_cache = TokenCache() def post(self, flag): if flag == 'wxauthor': '''微信網(wǎng)頁(yè)授權(quán)''' code = self.get_argument('code') state = self.get_argument('state') # 獲取重定向的url redirect_url = self.wx_config.wx_menu_state_map[state] logger.debug('【微信網(wǎng)頁(yè)授權(quán)】將要重定向的地址為:redirct_url[' + redirect_url + ']') logger.debug('【微信網(wǎng)頁(yè)授權(quán)】用戶同意授權(quán)，獲取code>>>>code[' + code + ']state[' + state + ']') if code: # 通過(guò)code換取網(wǎng)頁(yè)授權(quán)access_token data = self.wx_author_server.get_auth_access_token(code) openid = data['openid'] logger.debug('【微信網(wǎng)頁(yè)授權(quán)】openid>>>>openid[' + openid + ']') if openid: # 跳到自己的業(yè)務(wù)界面 self.redirect(redirect_url) else: # 獲取不到openid logger.debug('獲取不到openid')六. 菜單中網(wǎng)頁(yè)的開(kāi)發(fā), JS-SDK的使用


在完成自定義菜單后,我們就可以開(kāi)發(fā)自己的網(wǎng)頁(yè)了,在網(wǎng)頁(yè)中涉及到獲取用戶地理位置,微信支付等,都需要使用微信公眾平臺(tái)提供的JS-SDK,詳見(jiàn) 微信JS-SDK說(shuō)明文檔

1. 獲取JS-SDK權(quán)限簽名

• wxsign.py
  

import timeimport randomimport stringimport hashlibfrom core.server.weixin.wxconfig import WxConfigfrom core.server.cache.tokencache import TokenCachefrom core.logger_helper import loggerclass WxSign: """/ 微信開(kāi)發(fā)--獲取JS-SDK權(quán)限簽名 __create_nonce_str 隨機(jī)字符串 __create_timestamp 時(shí)間戳 sign 生成JS-SDK使用權(quán)限簽名 """ def __init__(self, jsapi_ticket, url): self.ret = { 'nonceStr': self.__create_nonce_str(), 'jsapi_ticket': jsapi_ticket, 'timestamp': self.__create_timestamp(), 'url': url } def __create_nonce_str(self): return ''.join(random.choice(string.ascii_letters + string.digits) for _ in range(15)) def __create_timestamp(self): return int(time.time()) def sign(self): string = '&'.join(['%s=%s' % (key.lower(), self.ret[key]) for key in sorted(self.ret)]) self.ret['signature'] = hashlib.sha1(string.encode('utf-8')).hexdigest() logger.debug('【微信JS-SDK】獲取JS-SDK權(quán)限簽名>>>>dict[' + str(self.ret) + ']') return self.retif __name__ == '__main__': token_cache = TokenCache() jsapi_ticket = token_cache.get_cache(token_cache.KEY_JSAPI_TICKET) # 注意 URL 一定要?jiǎng)討B(tài)獲取，不能 hardcode url = '%s/order/index' % WxConfig.AppHost sign = WxSign(jsapi_ticket, url) print(sign.sign())

七. 完成測(cè)試,發(fā)布上線,部署至centos服務(wù)器

本測(cè)試項(xiàng)目發(fā)布上線時(shí)使用的服務(wù)器為阿里云的centos 6.5服務(wù)器,系統(tǒng)python版本為2.7,為保證多個(gè)Python版本共存,及當(dāng)前項(xiàng)目環(huán)境的純凈,需要使用pyenv及虛擬環(huán)境virtualenv

同時(shí)我們采用 nginx 做負(fù)載均衡和靜態(tài)文件伺服,supervisor做守護(hù)進(jìn)程管理

1. 安裝pyenv


(1) 下載





$ git clone git://github.com/yyuu/pyenv.git ~/.pyenv(2) 配置





$ echo 'export PYENV_ROOT="$HOME/.pyenv"' >> ~/.bashrc$ echo 'export PATH="$PYENV_ROOT/bin:$PATH"' >> ~/.bashrc$ echo 'eval "$(pyenv init -)"' >> ~/.bashrc(3) 重新加載shell





$ exec $SHELL -l2.通過(guò)pyenv安裝多個(gè)版本的python


(1) 安裝相關(guān)依賴




yum install readline readline-devel readline-static -yyum install openssl openssl-devel openssl-static -yyum install sqlite-devel -yyum install bzip2-devel bzip2-libs -y(2) 安裝需要的python版本





pyenv install 3.5.0然后刷新python版本pyenv rehash(3) 設(shè)置全局Python版本





$ pyenv global 3.5.03.使用虛擬環(huán)境virtualenv
(1) 安裝





$ pip install virtualenv(2) 使用方法
(a)進(jìn)入項(xiàng)目目錄





$ virtualenv --no-site-packages wx_env(b)用source進(jìn)入該環(huán)境





$ source wx_env/bin/activate注意到命令提示符變了，有個(gè)(venv)前綴，表示當(dāng)前環(huán)境是一個(gè)名為venv的Python環(huán)境

4.導(dǎo)出本地項(xiàng)目的關(guān)聯(lián)關(guān)系,并在centos上安裝





pip freeze > ./requirements.txtpip install -r requirements.txt 5.安裝redis服務(wù)

(1)下載redis Redis
(2) 上傳至 /usr/local文件夾
(3) 解壓 tar -xzvf redis-3.2.3.tar.gz
(4) 重命名redis-3.2.3文件名為redis
(4) 進(jìn)入目錄 cd /usr/local/redis
(5) 編譯安裝





make make install(6) 修改配置文件





vi /etc/redis/redis.conf僅修改： daemonize yes （no-->yes）
(7) 啟動(dòng)





/usr/local/bin/redis-server /usr/local/redis/redis.conf(8) 查看啟動(dòng)





ps -ef | grep redis6.安裝nginx
(1) 下載安裝包：





wget http://nginx.org/download/nginx-1.10.0.tar.gz(2) 解壓Nginx的tar包，并進(jìn)入解壓好的目錄





tar -zxvf nginx-1.10.0.tar.gzcd nginx-1.10.0/(3) 安裝zlib和pcre庫(kù)





yum -y install zlib zlib-develyum -y install pcre pcre-devel(4) 配置、編譯并安裝





./configure


makemake install(5) 啟動(dòng)nginx




/usr/local/nginx/sbin/nginx訪問(wèn)服務(wù)器后如下圖顯示說(shuō)明Nginx運(yùn)正常。



7.配置nginx




user nobody;worker_processes 1; #error_log logs/error.log; #error_log logs/error.log notice; #error_log logs/error.log info; #pid logs/nginx.pid; events { worker_connections 1024;}http { include mime.types; default_type application/octet-stream; upstream web_wx { server 127.0.0.1:8001; server 127.0.0.1:8002; server 127.0.0.1:8003; server 127.0.0.1:8004; } sendfile on; #tcp_nopush on; keepalive_timeout 65; proxy_read_timeout 200; tcp_nopush on; tcp_nodelay on; gzip on; gzip_min_length 1000; gzip_proxied any; server { listen 80; server_name localhost; # redirect server error pages to the static page /50x.html # error_page 500 502 503 504 /50x.html; location = /50x.html { root html; } location / { proxy_pass_header Server; proxy_set_header Host $http_host; # proxy_redirect false; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Scheme $scheme; proxy_pass http://web_wx; } }}8.配置Supervisord

(1) 安裝





yum install supervisor(2) 設(shè)置開(kāi)機(jī)自啟





wget -O /etc/rc.d/init.d/supervisord https://gist.githubusercontent.com/gracece/21e5719b234929799eeb/raw/supervisord(3)將守護(hù)進(jìn)程添加為服務(wù)





chmod +x /etc/rc.d/init.d/supervisordchkconfig --add supervisord #加為服務(wù)ntsysv #運(yùn)行ntsysv，選中supervisord啟動(dòng)系統(tǒng)時(shí)跟著啟動(dòng)。(4) 設(shè)置 /etc/supervisord.conf文件





[unix_http_server]file=/tmp/supervisor.sock ; (the path to the socket file);chmod=0700 ; socket file mode (default 0700);chown=nobody:nogroup ; socket file uid:gid owner;username=user ; (default is no username (open server));password=123 ; (default is no password (open server));[inet_http_server] ; inet (TCP) server disabled by default;port=127.0.0.1:9001 ; (ip_address:port specifier, *:port for all iface);username=user ; (default is no username (open server));password=123 ; (default is no password (open server))[supervisord]logfile=/tmp/supervisord.log ; (main log file;default $CWD/supervisord.log)logfile_maxbytes=50MB ; (max main logfile bytes b4 rotation;default 50MB)logfile_backups=10 ; (num of main logfile rotation backups;default 10)loglevel=info ; (log level;default info; others: debug,warn,trace)pidfile=/tmp/supervisord.pid ; (supervisord pidfile;default supervisord.pid)nodaemon=false ; (start in foreground if true;default false)minfds=1024 ; (min. avail startup file descriptors;default 1024)minprocs=200 ; (min. avail process descriptors;default 200);umask=022 ; (process file creation umask;default 022);user=chrism ; (default is current user, required if root);identifier=supervisor ; (supervisord identifier, default is 'supervisor');directory=/tmp ; (default is not to cd during start);nocleanup=true ; (don't clean up tempfiles at start;default false);childlogdir=/tmp ; ('AUTO' child log dir, default $TEMP);environment=KEY="value" ; (key value pairs to add to environment);strip_ansi=false ; (strip ansi escape codes in logs; def. false)[rpcinterface:supervisor]supervisor.rpcinterface_factory = supervisor.rpcinterface:make_main_rpcinterface[supervisorctl]serverurl=unix:///tmp/supervisor.sock ; use a unix:// URL for a unix socket;serverurl=http://127.0.0.1:9001 ; use an http:// url to specify an inet socket;username=grace ; should be same as http_username if set;password=grace ; should be same as http_password if set;prompt=mysupervisor ; cmd line prompt (default "supervisor");history_file=~/.sc_history ; use readline history if available[group:tornadoApp]programs=web_wx[program:web_wx]command=python /var/web_wx/run.py --port=80%(process_num)02ddirectory=/var/web_wx/process_name = %(program_name)s%(process_num)dautorestart=trueredirect_stderr=truestdout_logfile=/var/log/tornado.logstdout_logfile_maxbytes=500MBstdout_logfile_backups=50stderr_logfile=/var/log/tornado-error.logloglevel=infonumprocs = 4numprocs_start = 1(5) 開(kāi)啟守護(hù)進(jìn)程服務(wù)


supervisordsupervisorctl reload allsupervisorctl status★ 關(guān)于項(xiàng)目源碼

知識(shí)無(wú)價(jià)! 本項(xiàng)目涉及到的所有源代碼已整理完成,有需要源代碼的同學(xué)請(qǐng)點(diǎn)擊下方的打賞按鈕, 打賞金額不少于50元哦, 收到打賞后,我會(huì)私信源碼給你。對(duì)源碼有任何不懂的地方,可以私信我協(xié)助你進(jìn)行測(cè)試并部署上線。