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

概述

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

准备事项

• 申请微信公众号

  微信公众号申请链接：

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

安装基础软件

本教程中使用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)
   
   
   
   $createtime
   
   
   

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消息处理代码是否一致。

验证

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