me.chanjar.weixin.cp.message

类 WxCpMessageRouter

java.lang.Object

me.chanjar.weixin.cp.message.WxCpMessageRouter

public class WxCpMessageRouter
extends Object

 微信消息路由器，通过代码化的配置，把来自微信的消息交给handler处理

 说明：
 1. 配置路由规则时要按照从细到粗的原则，否则可能消息可能会被提前处理
 2. 默认情况下消息只会被处理一次，除非使用 WxCpMessageRouterRule.next()
 3. 规则的结束必须用WxCpMessageRouterRule.end()或者WxCpMessageRouterRule.next()，否则不会生效

 使用方法：
 WxCpMessageRouter router = new WxCpMessageRouter();
 router
   .rule()
       .msgType("MSG_TYPE").event("EVENT").eventKey("EVENT_KEY").content("CONTENT")
       .interceptor(interceptor, ...).handler(handler, ...)
   .end()
   .rule()
       // 另外一个匹配规则
   .end()
 ;

 // 将WxXmlMessage交给消息路由器
 router.route(message);

 

作者:

Daniel Qian

字段概要

字段

限定符和类型	字段和说明
protected org.slf4j.Logger	log

构造器概要

构造器

构造器和说明
WxCpMessageRouter(WxCpService wxCpService)

方法概要

方法

限定符和类型	方法和说明
protected boolean	isDuplicateMessage(WxCpXmlMessage wxMessage)
WxCpXmlOutMessage	route(WxCpXmlMessage wxMessage) 处理微信消息
WxCpXmlOutMessage	route(WxCpXmlMessage wxMessage, Map<String,Object> context) 处理微信消息
WxCpMessageRouterRule	rule() 开始一个新的Route规则
protected void	sessionEndAccess(WxCpXmlMessage wxMessage) 对session的访问结束
void	setExceptionHandler(WxErrorExceptionHandler exceptionHandler) 设置自定义的WxErrorExceptionHandler 如果不调用该方法，默认使用 LogExceptionHandler
void	setExecutorService(ExecutorService executorService) 设置自定义的 ExecutorService 如果不调用该方法，默认使用 Executors.newFixedThreadPool(100)
void	setMessageDuplicateChecker(WxMessageDuplicateChecker messageDuplicateChecker) 设置自定义的 WxMessageDuplicateChecker 如果不调用该方法，默认使用 WxMessageInMemoryDuplicateChecker
void	setSessionManager(WxSessionManager sessionManager) 设置自定义的WxSessionManager 如果不调用该方法，默认使用 StandardSessionManager

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

log

protected final org.slf4j.Logger log

构造器详细资料

WxCpMessageRouter

public WxCpMessageRouter(WxCpService wxCpService)

方法详细资料

setExecutorService

public void setExecutorService(ExecutorService executorService)

 设置自定义的 ExecutorService
 如果不调用该方法，默认使用 Executors.newFixedThreadPool(100)
 

参数:

executorService -

setMessageDuplicateChecker

public void setMessageDuplicateChecker(WxMessageDuplicateChecker messageDuplicateChecker)

 设置自定义的 WxMessageDuplicateChecker
 如果不调用该方法，默认使用 WxMessageInMemoryDuplicateChecker
 

参数:

messageDuplicateChecker -

setSessionManager

public void setSessionManager(WxSessionManager sessionManager)

 设置自定义的WxSessionManager
 如果不调用该方法，默认使用 StandardSessionManager
 

参数:

sessionManager -

setExceptionHandler

public void setExceptionHandler(WxErrorExceptionHandler exceptionHandler)

 设置自定义的WxErrorExceptionHandler
 如果不调用该方法，默认使用 LogExceptionHandler
 

参数:

exceptionHandler -

rule

public WxCpMessageRouterRule rule()

开始一个新的Route规则

route

public WxCpXmlOutMessage route(WxCpXmlMessage wxMessage,
                      Map<String,Object> context)

处理微信消息

参数:

wxMessage -

context -

route

public WxCpXmlOutMessage route(WxCpXmlMessage wxMessage)

处理微信消息

参数:

wxMessage -

isDuplicateMessage

protected boolean isDuplicateMessage(WxCpXmlMessage wxMessage)

sessionEndAccess

protected void sessionEndAccess(WxCpXmlMessage wxMessage)

对session的访问结束

参数:

wxMessage -