Tiny微信框架是怎样设计的?

     微信对国人而言,想必大名鼎鼎,活跃用户数已经突破6.5亿,足以说明这款应用的生命力。但是使用人数众多,不代表微信的API设计优异,有过微信公众号开发经验的人,想必复杂的报文,众多的服务API以及各种公众号资源与权限设置搞得头痛。其实Tiny框架设计理念之一就是简化开发人员的工作,设计Tiny微信框架可以一定程度上减少一般开发人员的难度。

     前段时间本人写过一篇博文《微信框架的几个层次》,提到了十个层级,介绍之前先说一下微信的消息通讯机制,主要分为被动推送和主动请求两种模式:

 一、被动推送模式。此时微信服务器是通讯发起方,用户服务器是通讯接收方。

这种模式下推送报文分两类:消息和事件。如用户在微信客户端发送的文本消息、图片消息在通讯层面上就是消息报文;而事件报文一般用于处理异步响应,比如用户点击微信菜单触发菜单事件等。

     二、主动请求模式。此时用户服务器是通讯发起方,而微信服务器则是通讯接收方。

主动请求场景很多,微信开发平台提供的大部分API都是这种模式,如自定义菜单、素材管理、支付等。而微信服务器与微信客户端之间的数据更新有以下两种方式:

  1. 服务器主动推送信息。如微信的群发消息接口,在用户服务器触发群发消息后,由微信服务器往目标客户端主动推送消息。
  2. 客户端拉取信息。如自定义菜单的管理接口,在用户服务器修改了自定义菜单的内容后,微信服务器并不会主动推送内容,而是由微信客户端发现缓存过期后,自行向微信服务器请求更新。

     Tiny微信框架的核心接口如图所示:

 以上接口涵盖了微信通讯、报文转换、消息接收和发送、上下文会话、业务处理等诸多方面,接口说明如下:

接口

接口说明

WeiXinConnector

微信连接管理,管理接收消息和请求消息,同时保持微信的通讯信息(验证令牌和JS访问票据等)

WeiXinContext

微信上下文环境,支持保存微信的用户会话,也可以记录各个业务处理器的操作结果。

WeiXinConvert

微信消息/结果转换统一接口,支持优先级排序

WeiXinHandler

微信业务处理器,支持按优先级排序。按类型可以分为发送和接收处理器。开发人员需要扩展该接口实现业务逻辑。

WeiXinManager

微信配置管理器,负责加载微信API接口相关参数,和渲染微信URL。

WeiXinReceiver

微信接收消息器,负责接收微信服务器推送过来的消息和事件,WeiXinConnector委托其接收消息。

WeiXinSender

微信发送消息器,负责发送消息和上传文件到微信服务器,并处理响应,WeiXinConnector委托其发送消息。

WeiXinSession

微信用户会话,目前以微信的openId做主键。

WeiXinSessionManager

微信会话管理器,负责新增、修改和清理微信用户会话。

第一层次:通信处理

微信的服务主要是基于HTTP协议,安全通过访问令牌(access_token)保证;少数业务场景使用HTTPS加密协议,甚至涉及安全证书,例如微信商户的支付接口。

Tiny微信框架的通讯处理由WeiXinConnector总调度,接口定义如下:

1public interface WeiXinConnector { 2 3 /** 4 * 默认的bean配置名称 5 */ 6 public static final String DEFAULT_BEAN_NAME="weiXinConnector"; 7 8 public static final String ACCESS_TOKEN="ACCESS_TOKEN"; 9 10 /** 11 * 获取当前的管理号客户端信息 12 * @return 13 */ 14 Client getClient(); 15 16 /** 17 * 获得微信消息发送者,负责往微信服务器发送消息 18 * @return 19 */ 20 WeiXinSender getWeiXinSender(); 21 22 /** 23 * 获得微信消息接收者,负责解析微信服务器推送过来的消息 24 * @return 25 */ 26 WeiXinReceiver getWeiXinReceiver(); 27 28 /** 29 * 获取微信的会话管理者 30 * @return 31 */ 32 WeiXinSessionManager getWeiXinSessionManager(); 33 34 /** 35 * 获取微信验证令牌 36 * @return 37 */ 38 AccessToken getAccessToken(); 39 40 /** 41 * 获得微信的JS访问票据 42 * @return 43 */ 44 JsApiTicket getJsApiTicket(); 45 46 /** 47 * 发送微信消息 48 * @param message 49 */ 50 void send(ToServerMessage message); 51 52 /** 53 * 上传微信文件 54 * @param upload 55 */ 56 void upload(WeiXinHttpUpload upload); 57 58 /** 59 * 接收微信消息 60 * @param request 61 * @param response 62 */ 63 void receive(HttpServletRequest request,HttpServletResponse response); 64 65}

具体到底层的HTTP和HTTPS协议通讯,org.tinygroup.weixinhttp工程提供了业务接口WeiXinHttpConnector实现具体的协议通讯。

1public interface WeiXinHttpConnector { 2 3 /** 4 * 默认的bean配置名称 5 */ 6 public static final String DEFAULT_BEAN_NAME="weiXinHttpConnector"; 7 8 /** 9 * 用get方式访问微信URL 10 * 11 * @param url 要访问的微信URL 12 * @return 请求结果 13 */ 14 String getUrl(String url); 15 16 /** 17 * 用post方式访问微信URL 18 * 19 * @param url 要访问的微信URL 20 * @param content 21 * @param cert 22 * @return 请求结果 23 */ 24 String postUrl(String url, String content,WeiXinCert cert); 25 26 /** 27 * 上传文件 28 * @param url 29 * @param upload 30 * @return 31 */ 32 String upload(String url,WeiXinHttpUpload upload); 33}

目前微信框架实现了HttpClient3.1和HttpClient4.5.1两个版本的底层通讯方案,对开发人员而言只需要配置不同的依赖,而无需关心具体通讯代码。

第二层次:报文解析

本人一直对微信的报文设计颇有微词,从整体上看微信报文缺乏统一规范,XML、JSON格式混用,字段命名也不规范。Tiny微信提供WeiXinConvert接口负责报文与对象之间的转换,目前XML报文通过Xsteam转换,JSON报文通过fastjson转换。接口定义如下:

1public interface WeiXinConvert extends Comparable<WeiXinConvert> { 2 3 /** 4 * 获得优先级 5 * @return 6 */ 7 int getPriority(); 8 9 /** 10 * 设置优先级 11 * @param priority 12 */ 13 void setPriority(int priority); 14 15 /** 16 * 获得报文的状态 17 * @return 18 */ 19 WeiXinConvertMode getWeiXinConvertMode(); 20 21 /** 22 * 获得结果类型 23 * @return 24 */ 25 Class<?> getCalssType(); 26 27 /** 28 * 判断转换接口能否处理输入信息(微信报文会出现不同类型报文字段一致的情况,需要根据上下文判断) 29 * @param <INPUT> 30 * @param input 31 * @param context 32 * @return 33 */ 34 <INPUT> boolean isMatch(INPUT input,WeiXinContext context); 35 36 /** 37 * 转换消息(微信报文会出现不同类型报文字段一致的情况,需要根据上下文判断) 38 * @param input 39 * @return 40 */ 41 <OUTPUT,INPUT> OUTPUT convert(INPUT input,WeiXinContext context); 42 43}

对开发人员而言,无需思考如何构建复杂的报文,只需依赖对应微信业务模块的子工程,构建不同的消息对象,而底层的报文解析与转换甚至通讯都由tiny框架处理。

第三层次:报文模拟发送

微信发送报文调试最麻烦的地方就是访问令牌(access_token),这个是根据用户应用动态生成的,而且只保持两个小时有效。Tiny微信框架提供了模拟测试页面,只需要bean配置页面设置相关appId和APP秘钥等参数,开发人员在页面就无需手动输入访问令牌。测试页面如下:

第四层次:报文模拟接收

接收报文通常是用来模拟手机端的发送消息,特别是一些复杂交互场景:如命令行菜单,如果每次都通过手机端调试。效率非常低。而通过本测试页面,直接输入模拟的手机报文直接就可以得到报文结果,准确并且快速。模拟页面如图:

第五层次:报文处理框架

前面在介绍微信核心接口时提到过WeiXinReceiver和WeiXinSender,分别处理微信推送消息与主动发送消息。但是用户的业务是复杂多变的,Tiny是如何保证微信框架的可扩展性呢?其实WeiXinReceiver和WeiXinSender是由一组有序WeiXinHandler组成,而每一个WeiXinHandler都可以处理一类消息,接口定义如下:

1public interface WeiXinHandler extends Comparable<WeiXinHandler> { 2 3 int getPriority(); 4 5 void setPriority(int priority); 6 7 WeiXinHandlerMode getWeiXinHandlerMode(); 8 9 /** 10 * 是否匹配对象和上下文 11 * @param <T> 12 * @param message 13 * @return 14 */ 15 <T> boolean isMatch(T message,WeiXinContext context); 16 17 18 /** 19 * 处理对象 20 * @param <T> 21 * @param message 22 * @param context 23 */ 24 <T> void process(T message,WeiXinContext context); 25}

简单举个例子,比如开发一个图片消息处理器ImageMessageHandler,用来处理微信客户端的图片类消息,代码如下:

1public class ImageMessageHandler extends AbstractWeiXinHandler{ 2 public WeiXinHandlerMode getWeiXinHandlerMode() { 3 return WeiXinHandlerMode.RECEIVE; 4 } 5 public <T> boolean isMatch(T message, WeiXinContext context) { 6 return message instanceof ImageMessage; 7 } 8 //具体业务处理 9 public <T> void process(T message, WeiXinContext context) { 10 ImageMessage mess = (ImageMessage) message; 11 12 //逻辑处理 13 TextReplyMessage replyMessage= new TextReplyMessage(); 14 replyMessage.setContent("回复图片消息["+mess.getPicUrl()+"]"); 15 replyMessage.setToUserName(mess.getFromUserName()); 16 replyMessage.setFromUserName(mess.getToUserName()); 17 replyMessage.setCreateTime((int)(System.currentTimeMillis()/1000)); 18 19 context.setOutput(replyMessage); 20 } 21}

用户主要是编写isMatch和process这两个函数,前者决定这个业务类能处理哪些微信消息和事件,后者是真正的业务处理类。微信消息的包装和转换由微信框架提供,用户应该关心业务处理逻辑,原则上一个Handler只建议处理一类消息。编写完毕后,需要将Handler配置成bean文件,微信框架就能调用了。

ImageMessageHandler的作用是接收微信客户端发送的图片类消息,并返回图片地址给用户,效果如下:

第六层次:上下文保持

微信是有上下文概念的,比如微信应用的小游戏:猜数字。用户输入一个数字,而服务器告诉用户比目标值偏大还是偏小,直到用户猜中为止。游戏很简单,但是这就涉及到上下文会话,Tiny微信框架提供WeiXinSession接口作为上下文统一接口,而WeiXinSessionManager作为上下文的管理接口存在。

WeiXinSession接口定义如下:

1public interface WeiXinSession extends Serializable{ 2 3 /** 4 * 会话Id 5 * @return 6 */ 7 String getSessionId(); 8 9 /** 10 * 是否包含某元素 11 * @param name 12 * @return 13 */ 14 boolean contains(String name); 15 16 /** 17 * 返回指定name的序列化对象 18 * @param <T> 19 * @param name 20 * @return 21 */ 22 <T extends Serializable> T getParameter(String name); 23 24 /** 25 * 设置序列化的参数对象 26 * @param <T> 27 * @param name 28 * @param value 29 */ 30 <T extends Serializable> void setParameter(String name,T value); 31 32 /** 33 * 取得session的创建时间。 34 * 35 * @return 创建时间戮 36 */ 37 long getCreationTime(); 38 39 /** 40 * 取得最近访问时间。 41 * 42 * @return 最近访问时间戮 43 */ 44 long getLastAccessedTime(); 45 46 /** 47 * 取得session的最大不活动期限,超过此时间,session就会失效。 48 * 49 * @return 不活动期限的秒数,0表示永不过期 50 */ 51 int getMaxInactiveInterval(); 52 53 /** 54 * 设置session的最大不活动期限,单位秒 55 * @param maxInactiveInterval 56 */ 57 void setMaxInactiveInterval(int maxInactiveInterval); 58 59 /** 60 * 判断session有没有过期。 61 * 62 * @return 如果过期了,则返回<code>true</code> 63 */ 64 boolean isExpired(); 65 66 /** 67 * 更新session 68 */ 69 void update(); 70}

WeiXinSessionManager管理接口主要提供创建、删除、查询上下文会话的操作API,接口定义如下:

1public interface WeiXinSessionManager { 2 3 /** 4 * 默认的bean配置名称 5 */ 6 public static final String DEFAULT_BEAN_NAME="weiXinSessionManager"; 7 8 /** 9 * 创建会话 10 * @param sessionId 11 * @return 12 */ 13 WeiXinSession createWeiXinSession(String sessionId); 14 /** 15 * 查询会话 16 * @param sessionId 17 * @return 18 */ 19 WeiXinSession getWeiXinSession(String sessionId); 20 21 /** 22 * 添加会话 23 * @param session 24 */ 25 void addWeiXinSession(WeiXinSession session); 26 27 /** 28 * 手动删除会话 29 * @param sessionId 30 * @return 31 */ 32 void removeWeiXinSession(String sessionId); 33 34 /** 35 * 遍历会话 36 * @return 37 */ 38 WeiXinSession[] getWeiXinSessions(); 39 40 /** 41 * 清理会话过期的Session 42 */ 43 void expireWeiXinSessions(); 44 45 /** 46 * 清理全部Session 47 */ 48 void clear(); 49 50 /** 51 * Session最大过期时间设置,单位s,默认0 52 * @return 53 */ 54 int getMaxInactiveInterval(); 55 56 /** 57 * Session清理线程首次延迟时间,单位s,默认值60 58 * @return 59 */ 60 int getExpireTimerDelay(); 61 62 /** 63 * Session清理线程运行周期,单位s,默认值300 64 * @return 65 */ 66 int getExpireTimePeriod(); 67}

当然Tiny微信框架提供了上下文相关接口,不代表每一类消息强制进行会话管理,比如简单文本消息,微信客户端的位置消息,完全可以请求-响应这种模式进行处理。

第七层次:处理的水平扩展能力

前文讲过Tiny微信框架的具体业务是由WeiXinHandler接口完成的,而WeiXinHandler接口是不依赖WeiXinConnector等委托对象,因此通过扩展WeiXinHandler接口完全可以实现处理能力的水平扩展,比如Tiny框架本身有服务中心,支持分布式服务,那么我们可以在WeiXinHandler接口包装服务中心,从而实现分布式服务。

第八层次:命令处理框架

实际上一个微信公众号,许多的时候都是通过使用者用文字(语音识别也归到用文字)的方式与平台进行交互,这个时候,其实就是一个命令行的处理。Tiny微信框架通过org.tinygroup.menucommand实现相关需求,开发人员只需要配置XML就可完成复杂的命令行处理。目前支持两种模式:

  1. 简单模式。用户不需要动态数据,仅需要配置即可。类似电话黄页,支持逐级递归,针对这种模式,Tiny支持配置方式,用户无需编码。
  2. 动态模式。用户除了静态数据,还涉及动态交互,无法通过配置解决。Tiny框架提供了MenuCommandHandler接口,然后在配置中指定具体类或bean,框架就能解决。

配置文件是以menuconfig.xml为结尾,以演示工程的command.menuconfig.xml为例:

1<!-- 菜单命令节点支持多个菜单配置节点和系统命令节点 --> 2<menu-configs> 3 <!-- 菜单配置节点可以嵌套,支持定义子菜单和菜单命令节点 --> 4 <menu-config id="m001" name="menu" title="功能目录" > 5 <regex><![CDATA[m|menu|菜单]]></regex> 6 <description><![CDATA[微信服务列表]]></description> 7 <menu-config id="g001" name="guess" title="数字竞猜" path="/game/guessNumber.page"> 8 <regex><![CDATA[guess|猜数字]]></regex> 9 <description><![CDATA[猜数字小游戏,输入guess或者猜数字]]></description> 10 <menu-command name="new" title="新建游戏" event-type="enter" 11 class-name="org.tinygroup.weixinservice.commandhandler.NewGuessGameHandler"> 12 <regex><![CDATA[new|新游戏]]></regex> 13 <description><![CDATA[输入“新游戏”或者“new,重新开始猜数字]]></description> 14 </menu-command> 15 <menu-command name="input" title="输入数值" 16 class-name="org.tinygroup.weixinservice.commandhandler.GuessNumberHandler" 17 path="/game/guessNumberResult.page"> 18 <regex><![CDATA[^[1-9]\d*$]]></regex> 19 <description><![CDATA[请输入1-50之间的整数]]></description> 20 </menu-command> 21 <menu-command name="del" title="清理用户数据" event-type="exit" 22 class-name="org.tinygroup.weixinservice.commandhandler.DelGuessNumberSessionHandler" 23 path="/menucommand/showMenuConfig.page"> 24 <regex><![CDATA[del|delete]]></regex> 25 <description><![CDATA[输入del或者delete]]></description> 26 </menu-command> 27 </menu-config> 28 <menu-config id="g002" name="robot" title="机器人" > 29 <regex><![CDATA[robot]]></regex> 30 <description><![CDATA[输入robot]]></description> 31 <menu-command name="input" title="问答环节" event-type="enter" 32 system-enable="false" bean-name="askRobotHandler" path="/game/answer.page"> 33 <regex><![CDATA[[\u4e00-\u9fa5_a-zA-Z0-9]+$]]></regex> 34 <description><![CDATA[向智能机器人进行提问]]></description> 35 </menu-command> 36 </menu-config> 37 <menu-config id="g003" name="time" title="时间转换"> 38 <menu-command name="1" title="显示中式时间" 39 class-name="org.tinygroup.weixinservice.commandhandler.TimeHandler" 40 path="/game/chineseTime.page"> 41 <regex><![CDATA[1]]></regex> 42 <description><![CDATA[输入1展示中式时间]]></description> 43 </menu-command> 44 <menu-command name="2" title="显示英式时间" 45 class-name="org.tinygroup.weixinservice.commandhandler.TimeHandler" 46 path="/game/englishTime.page"> 47 <regex><![CDATA[2]]></regex> 48 <description><![CDATA[输入2展示英式时间]]></description> 49 </menu-command> 50 <regex><![CDATA[time]]></regex> 51 <description><![CDATA[展示中式和英式的系统时间]]></description> 52 </menu-config> 53 </menu-config> 54 <!-- 系统命令节点 --> 55 <system-command name="root" title="返回根菜单" bean-name="homeCommandHandler" 56 path="/menucommand/showMenuConfig.page"> 57 <regex><![CDATA[root]]></regex> 58 <description>输入root返回菜单的最上级</description> 59 </system-command> 60 <system-command name="up" title="回到上一级" bean-name="backCommandHandler" 61 path="/menucommand/showMenuConfig.page"> 62 <regex><![CDATA[up]]></regex> 63 <description>输入up,回到当前菜单的上一级</description> 64 </system-command> 65 <system-command name="list" title="列出子列表" bean-name="queryCommandHandler" 66 path="/menucommand/query.page"> 67 <regex><![CDATA[list|list\s+[\u4e00-\u9fa5_a-zA-Z0-9]+$]]></regex> 68 <description>列出系统命令和当前菜单的列表,支持“list 关键字”的方式</description> 69 </system-command> 70 <system-command name="help" title="显示详情" bean-name="helpCommandHandler" 71 path="/menucommand/help.page"> 72 <regex><![CDATA[help|help\s+[\u4e00-\u9fa5_a-zA-Z0-9]+$]]></regex> 73 <description>列出命令详情</description> 74 </system-command> 75 <system-command name="exit" title="退出菜单" bean-name="exitCommandHandler" 76 path="/menucommand/exit.page"> 77 <regex><![CDATA[exit]]></regex> 78 <description>输入exit退出菜单</description> 79 </system-command> 80</menu-configs>

      menu-configs是总结点,它包含两类子节点:菜单节点menu-config和系统命令节点system-command。菜单节点支持树结构,也就是可以自包含,菜单节点可以包含菜单命令节点menu-command,仅在当前菜单有效。系统命令不支持嵌套,而且只在menu-configs下面,它是全局有效的。最终效果如下:

    

第九层次:模板语言的引入

我们都知道,在做业务开发时,肯定都不希望把文本信息都放在程序代码中,这个时候就可以引入模板语言来把数据和展示来进行一个分割,做业务的只管做业务,做显示的只管做显示,井水河水两不犯。比如命令菜单,无论是显示信息还是处理结果都是配置在XML或者模板文件里,而非硬编码在java类。

第十层次:模块化

这也是Tiny微信框架的特色之一。其实在本人设计微信架构之前,也阅读过不少微信框架的源代码,它们绝大多数都是定义一个大接口,跟微信服务器API基本上是一一对应的关系,这样开发人员在使用时要么引入所有资源,要么不用。而Tiny微信框架是根据微信公众号API分类,每一类API接口实现一类工程,这样用户在开发时用多少资源就引入多少工程,比如我的公众号应用是视频类,可能用到素材管理接口和消息类接口,但是和微信商户无关,那开发人员在创建工程时只需要引入前两者即可。

好了,关于Tiny微信框架大致介绍如此,如果有开发人员对本框架感兴趣,想做一些扩展开发,可以联系本人。

如果您对我的博客感兴趣,请点击左上角的关注,以便及时收到我的相关通知。

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )