一、步骤:
以下为我在搭建时的大体步骤,遵循两条主线,其中编写代码文件和注册文件最重要,需要仔细阅读新浪云和微信公众号的开发文档
1、注册新浪云(需要身份认证)··>创建云应用··>编写代码文件和注册文件··>git上传代码到sae仓库··>测试连通性
2、注册微信公众平台··>进行开发者基本配置··>验证token··>(使用测试工具测试接口)··>启用
二、理解
对于整个过程的理解,转用别人的一张图,其实可以按照我们平时上网冲浪来理解,浏览器输入网址发送请求-->服务器接收到请求-->返回显示的html网页或者json、xml数据-->浏览器处理后显示,只是输入网址这个动作由微信公众号来完成了,flask框架就负责在服务器端接收请求处理请求,处理请求可以是多种多样,例如你可根据关注者发送来的图片进行一番图像处理然后返回,又或者识别信息,根据需求再去请求第三方api获得数据再返回,总之就看各位看官的创意啦。
三、开始动手实践
i.----新浪云步骤-----
1、首先是去新浪云:http://t.cn/RC4mL5Y 官网注册账号,其实使用微博账号授权登录的,如果你有需要请点击我以上的链接进行注册登录哟,这样你和我两个都会有奖励的,还有一个要啰嗦的就是,新用户会有一定的云豆让你试用,但是如果你身份认证通过后,即使你不使用服务,云豆也会每天自动消耗的,这个要注意,尽早使用或者等要用再认证身份哟。
2、你可以点击云应用,然后进入控制台,创建新应用
3、选择python,只有Python2.7可以选择,如果你学习的是Python3,建议你先去看一下菜鸟教程这篇关于py2和3区别的文章哟,千万不要因为版本问题而被吓退:
Python2.x与3.x版本区别
4、代码管理上传我使用的是git(没为什么,就因为我只会使用git),然后二级域名随便填,遵循不重名可用原则, 应用名称也是随便填,你开心就好。
5、创建应用成功后,在你电脑本地新建一个文件夹,关联sae仓库,如果你不熟悉git操作,不用怕,我为你准备了一本入门github电子书 :
learn-github-from-zero :http://pan.baidu.com/s/1eSw61Tg 提取密码:ishd
6、这时假设你创建了一个文件夹,在这个文件夹里使用git命令将你创建的云应用仓库克隆下来,然后添加两个文件,并分别写上如下内容,config.yaml文件是声明你的应用名称和版本号,index.wsgi就是将你创建的flask app注册进云应用开始启动(按照我的理解哈)
vendor文件夹里面存放的是云应用上python环境没有的第三方库,安装第三方库你需要指定该文件夹安装,然后git上传代码
命令:pip install -t vendor PACKAGE ...
7、接下来就是编写代码测试连通性了,在你创建的文件夹里新建一个py文件(我的是weixin.py),先创建一个最简单的flask应用进行测试,git上传代码,这里要注意,你创建的文件名要跟index.wsgi里面的导入文件名一致(看上图),如下
# -*- coding: utf-8 -*-
# filename: weixin.py
from flask import Flask
app = Flask(__name__)
@app.route('/test/')
def test():
return '<h1 style ="color:red">喂喂,我已经收到你发来的请求啦</h1>'
8、在浏览器输入你的二级域名网址,注意,再加一个路径test,熟悉flask的童鞋不用说了吧。这里说明新浪云应用可以正常接收请求并返回信息了。
ii.----微信公众号步骤-----
1、前提就是你得要先有一个微信公众号,找到基本配置,填写你新浪云的二级域名网址,也就是请求网址,,Token按照要求随便填,是进行验证的,填完后进行提交这时token验证是没通过的,需要完善云应用上的代码。
2、然后来到weixin.py文件根据下面的流程图编写验证代码,我这里的token使用的就是在基本配置中填写的。
# -*- coding: utf-8 -*-
# filename: weixin.py
from flask import Flask, request, make_response
import time, hashlib
@app.route('/wechat/', methods=['GET', 'POST'])
def wechat():
# 微信验证token
if request.method == 'GET':
token = ' 你的token''
query = request.args
signature = query.get('signature', '')
timestamp = query.get('timestamp', '')
nonce = query.get('nonce', '')
echostr = query.get('echostr', '')
s = [timestamp, nonce, token]
s.sort()
s = ''.join(s)
if hashlib.sha1(s).hexdigest() == signature:
return make_response(echostr)
3、返回到微信公众平台的基本配置,进行提交,token就验证通过啦(撒花。。)
实现文字图片回复
1、原理:
微信公众号在前台收到关注者的信息,就会发送一段xml信息到请求网址,这时服务端的flask解析这段xml,然后将要回复的信息再打包成规定的xml信息进行返回。根据解析出的MsgType判断消息类型,文本是"text",图片是"image",进行相应的处理。
2、编写代码,先编写两个模型实体,代表接收消息体和返回消息体。
# -*- coding: utf-8 -*-
# filename: receive.py
import xml.etree.ElementTree as ET
'''
该文件的类是接受体模型
'''
#进行消息类型判断,返回相应的接收体
def parse_xml(web_data):
if len(web_data) == 0:
return None
xmlData = ET.fromstring(web_data)
msg_type = xmlData.find('MsgType').text
if msg_type == 'text':
return TextMsg(xmlData)
elif msg_type == 'image':
return ImageMsg(xmlData)
#消息基类
class Msg(object):
def __init__(self, xmlData):
self.ToUserName = xmlData.find('ToUserName').text
self.FromUserName = xmlData.find('FromUserName').text
self.CreateTime = xmlData.find('CreateTime').text
self.MsgType = xmlData.find('MsgType').text
self.MsgId = xmlData.find('MsgId').text
#文本消息类
class TextMsg(Msg):
def __init__(self, xmlData):
Msg.__init__(self, xmlData)
self.Content = xmlData.find('Content').text.encode("utf-8")
#图片消息类
class ImageMsg(Msg):
def __init__(self, xmlData):
Msg.__init__(self, xmlData)
self.PicUrl = xmlData.find('PicUrl').text
self.MediaId = xmlData.find('MediaId').text
# -*- coding: utf-8 -*-
# filename: reply.py
import time
'''
该文件的类是发送体模型,传参数进来即返回要发送的xml信息
'''
class Msg(object):
def __init__(self):
pass
def send(self):
return "success"
class TextMsg(Msg):
def __init__(self, toUserName, fromUserName,content):
self.__dict = dict()
self.__dict['ToUserName'] = toUserName
self.__dict['FromUserName'] = fromUserName
self.__dict['CreateTime'] =int(time.time())
self.__dict['Content'] = content
def send(self):
XmlForm = """
<xml>
<ToUserName><![CDATA[{ToUserName}]]></ToUserName>
<FromUserName><![CDATA[{FromUserName}]]></FromUserName>
<CreateTime>{CreateTime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[{Content}]]></Content>
</xml>
"""
return XmlForm.format(**self.__dict)
class ImageMsg(Msg):
def __init__(self, toUserName, fromUserName, mediaId):
self.__dict = dict()
self.__dict['ToUserName'] = toUserName
self.__dict['FromUserName'] = fromUserName
self.__dict['CreateTime'] = int(time.time())
self.__dict['MediaId'] = mediaId
def send(self):
XmlForm = """
<xml>
<ToUserName><![CDATA[{ToUserName}]]></ToUserName>
<FromUserName><![CDATA[{FromUserName}]]></FromUserName>
<CreateTime>{CreateTime}</CreateTime>
<MsgType><![CDATA[image]]></MsgType>
<Image>
<MediaId><![CDATA[{MediaId}]]></MediaId>
</Image>
</xml>
"""
return XmlForm.format(**self.__dict)
3、主文件编写,代码都进行了注释,阅读代码即可
# -*- coding: utf-8 -*-
# filename: weixin.py
from flask import Flask, request, make_response
import time, hashlib
import xml.etree.ElementTree as ET
import reply
import receive
app = Flask(__name__)
@app.route('/test/')
def test():
return '<h1 style ="color:red">喂喂,我已经收到你发来的请求啦</h1>'
@app.route('/wechat/', methods=['GET', 'POST'])
def wechat():
# 微信验证token
if request.method == 'GET':
token = '你的token'
query = request.args
signature = query.get('signature', '')
timestamp = query.get('timestamp', '')
nonce = query.get('nonce', '')
echostr = query.get('echostr', '')
s = [timestamp, nonce, token]
s.sort()
s = ''.join(s)
if hashlib.sha1(s).hexdigest() == signature: #哈希加密跟signature进行比对
return make_response(echostr)
else:
rec_msg = receive.parse_xml(request.stream.read()) #判断当前的消息类型,获取到接收实例
if rec_msg.MsgType == 'text':
content = unicode(rec_msg.Content,"utf-8") #转换编码为unicode,方便提取需要的文字进行判断
if content.startswith(u"笑话",0,2): #如果是以笑话两字开头,则进行相应回复
rep_text_msg = reply.TextMsg(rec_msg.FromUserName, rec_msg.ToUserName, "哈哈,我给你讲个笑话吧哈哈哈 \n %s"%getTime() )
return rep_text_msg.send() #返回需要返回的xml信息
else:
rep_text_msg = reply.TextMsg(rec_msg.FromUserName,rec_msg.ToUserName,"复述:%s \n %s"%(rec_msg.Content,getTime()))
return rep_text_msg.send()
elif rec_msg.MsgType =="image": #我这里的处理是,如果是图片,就返回同样的MediaId,即是回复同样的图片
rep_img_msg = reply.ImageMsg(rec_msg.FromUserName,rec_msg.ToUserName,rec_msg.MediaId)
return rep_img_msg.send()
else:
return "success" #微信公众号规定,超过5秒未进行回复,则发起重请求,所以如果是无法识别的消息,则返回“success”,
# 就不会在消息界面提示公众号异常,提升用户体验。
#获取时间戳
def getTime():
return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
4、git提交代码,测试
总结:
实践出真知,看似简单的几行代码,对于新手来说,是要不断的进行查阅文档和资料,不断的进行试错的,我连git课本都给你准备好了,你还有什么理由不去动手实践一下?仔细的去琢磨一下官方的文档,没有什么比文档更加标准的啦。本文只是实现了一种回复消息和判断消息的大体思路,更多好玩的功能等你去发掘。码字辛苦,如果你觉得好就点个喜欢吧。
参考:
微信公众平台开发之用Flask+SAE实现简单被动消息回复功能