搭建微信公众号后台——收发文本消息

概述

在本教程中，您将学会使用弹性云服务器（以下简称 ECS）搭建微信公众号处理后台，使用Python语言编写对应的微信消息处理逻辑代码，接收从微信服务端转发过来的消息，并返回处理结果给最终用户，如图1所示。

准备事项

• 申请微信公众号

  微信公众号申请链接：https://mp.weixin.qq.com/

  本教程中使用订阅号“云图说”为例说明。

安装基础软件

本教程中使用Python+Web.py组合完成微信公众号开发，需要安装或升级Python、pip、Web.py框架、WinSCP软件版本。

上传代码

1. 新建main.py文件，复制如下代码：

   # -*- coding: utf-8 -*-
   # filename: main.py
   import web
   from handle import Handle
   
   urls = (
       '/wx', 'Handle',
   )
   
   if __name__ == '__main__':
       app = web.application(urls, globals())
       app.run()

2. 新建handle.py文件，复制如下代码：

   # -*- coding: utf-8 -*-
   # filename: handle.py
   
   import hashlib
   import web
   import receive
   import time
   import os
   
   class Handle(object):
   
       def __init__(self):
           self.app_root = os.path.dirname(__file__)
           self.templates_root = os.path.join(self.app_root, 'templates')
           self.render = web.template.render(self.templates_root)
   
       def GET(self):
           try:
               data = web.input()
               if len(data) == 0:
                   return "hello, this is handle view"
               signature = data.signature
               timestamp = data.timestamp
               nonce = data.nonce
               echostr = data.echostr
               token = "此处内容与公众号基本配置里Token字段取值保持一致"
   
               list = [token, timestamp, nonce]
               list.sort()
               s = list[0] + list[1] + list[2]
               hashcode = hashlib.sha1(s.encode('utf-8')).hexdigest()
               print( "handle/GET func: hashcode, signature: ", hashcode, signature)
               if hashcode == signature:
                   return echostr
               else:
                   return echostr
           except (Exception) as Argument:
               return Argument
   
       def POST(self):
           try:
               webData = web.data()
               print("Handle Post webdata is:\n", webData)
               #打印消息体日志
               recMsg = receive.parse_xml(webData)
   
               if isinstance(recMsg, receive.Msg) and recMsg.MsgType == 'text':
                   toUser = recMsg.FromUserName
                   fromUser = recMsg.ToUserName
                   content = "欢迎关注云图说！" + str(recMsg.Content)
                   print('Reply message info:\n')
                   print('toUser =', toUser)
                   print('fromUser = ', fromUser)
                   print('content = ', content)
                   return self.render.reply_text(toUser, fromUser, int(time.time()), content)
               else:
                   print("不支持的消息类型：",recMsg.MsgType)
                   return "success"
           except (Exception) as Argment:
               return Argment

3. 新建receive.py文件，复制如下代码：

   # -*- 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)
       elif msg_type == 'location':
           return LocationMsg(xmlData)
       elif msg_type == 'event':
           return EventMsg(xmlData)
   
   class Event(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.Eventkey = xmlData.find('EventKey').text
   
   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
   
   class ImageMsg(Msg):
       def __init__(self, xmlData):
           Msg.__init__(self, xmlData)
           self.PicUrl = xmlData.find('PicUrl').text
           self.MediaId = xmlData.find('MediaId').text
   
   class LocationMsg(Msg):
       def __init__(self, xmlData):
           Msg.__init__(self, xmlData)
           self.Location_X = xmlData.find('Location_X').text
           self.Location_Y = xmlData.find('Location_Y').text
   
   class EventMsg(Msg):
       def __init__(self, xmlData):
           Event.__init__(self, xmlData)
           self.Event = xmlData.find('Event').text

4. 新建templates文件夹，在文件夹下新建reply_text.xml文件，复制如下代码：

   $def with (toUser,fromUser,createTime,content)
   <xml>
   <ToUserName><![CDATA[$toUser]]></ToUserName>
   <FromUserName><![CDATA[$fromUser]]></FromUserName>
   <CreateTime>$createTime</CreateTime>
   <MsgType><![CDATA[text]]></MsgType>
   <Content><![CDATA[$content]]></Content>
   </xml>

5. 最终本地代码文件形成如下：
   图15 本地文件
   
6. 通过WinSCP工具将上述文件与目录上传至ECS指定目录下：
   图16 上传文件
   

启动服务

使用如下命令启动服务：

启用开发者模式

1. 登录微信公众平台，选择“开发 > 基本配置”，单击“修改配置”。
2. 填写配置信息，单击“提交”。
   • URL：https://ECS的弹性公网IP/wx，不用添加80端口。
   • Token：需要与handle.py中对应token取值完全一致。
   • EncodingAESKey：随机生成。
   • 消息加解密方式：此为示例，选择简单的“明文模式”。
3. 验证token成功，单击“启用”。
   

   如果token验证失败，请检查Token配置与handle.py中GET消息处理代码是否一致。

验证

使用微信关注公众号，任意发送一条文本消息，看是否能够收到回复。如能收到回复则表明系统处理正常。