com.kdayun.wecom.cp.message

类 WxCpMessageRouter

java.lang.Object

com.kdayun.wecom.cp.message.WxCpMessageRouter

public class WxCpMessageRouter
extends java.lang.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

构造器概要

构造器

构造器和说明
WxCpMessageRouter() 构造方法.

方法概要

限定符和类型	方法和说明
(专用程序包) java.util.List<WxCpMessageRouterRule>	getRules()
WxCpXmlOutMessage	route(WxCpXmlMessage wxMessage, java.util.Map<java.lang.String,java.lang.Object> context, WxCpService wxCpService) 处理微信消息.
WxCpXmlOutMessage	route(WxCpXmlMessage wxMessage, WxCpService wxCpService) 处理微信消息.
WxCpMessageRouterRule	rule() 开始一个新的Route规则.
void	setExceptionHandler(me.chanjar.weixin.common.api.WxErrorExceptionHandler exceptionHandler) 设置自定义的WxErrorExceptionHandler 如果不调用该方法，默认使用 LogExceptionHandler
void	setExecutorService(java.util.concurrent.ExecutorService executorService) 设置自定义的 ExecutorService 如果不调用该方法，默认使用 Executors.newFixedThreadPool(100)
void	setMessageDuplicateChecker(me.chanjar.weixin.common.api.WxMessageDuplicateChecker messageDuplicateChecker) 设置自定义的 WxMessageDuplicateChecker 如果不调用该方法，默认使用 WxMessageInMemoryDuplicateChecker

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

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

构造器详细资料

WxCpMessageRouter

public WxCpMessageRouter()

构造方法.

方法详细资料

setExecutorService

public void setExecutorService(java.util.concurrent.ExecutorService executorService)

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

参数:

executorService - executorService

setMessageDuplicateChecker

public void setMessageDuplicateChecker(me.chanjar.weixin.common.api.WxMessageDuplicateChecker messageDuplicateChecker)

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

参数:

messageDuplicateChecker - WxMessageDuplicateChecker

setExceptionHandler

public void setExceptionHandler(me.chanjar.weixin.common.api.WxErrorExceptionHandler exceptionHandler)

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

参数:

exceptionHandler - WxErrorExceptionHandler

getRules

java.util.List<WxCpMessageRouterRule> getRules()

rule

public WxCpMessageRouterRule rule()

开始一个新的Route规则.

返回:

WxCpMessageRouterRule

route

public WxCpXmlOutMessage route(WxCpXmlMessage wxMessage,
                               java.util.Map<java.lang.String,java.lang.Object> context,
                               WxCpService wxCpService)

处理微信消息.

参数:

wxMessage - wxMessage

context - context

wxCpService - wxCpService

返回:

WxCpXmlOutMessage

route

public WxCpXmlOutMessage route(WxCpXmlMessage wxMessage,
                               WxCpService wxCpService)

处理微信消息.

参数:

wxMessage - wxMessage

wxCpService - wxCpService

返回:

WxCpXmlOutMessage