MP_微信消息路由器

微信推送给公众号的消息类型很多，而公众号也需要针对用户不同的输入做出不同的反应。

如果使用if ... else ...来实现的话非常难以维护，这时可以使用WxMpMessageRouter来对消息进行路由。

WxMpMessageRouter支持从4个角度对消息进行匹配，然后交给事先指定的WxMpMessageRouter：

1. msgType
2. event
3. eventKey
4. content

在整个应用程序中，WxMessageRouter应该是单例的。

WxMpMessageRouter router = new WxMpMessageRouter();
router
    // 4个条件必须全部匹配的路由规则
    .rule()
    .msgType(WxConsts.XML_MSG_TEXT)
    .event(WxConsts.EVT_SUBSCRIBE)
    .eventKey("EVENT_KEY")
    .content("CONTENT")
    .rContent("content正则表达式")
    .handler(handler)
    .end()
        // 只匹配1个条件的路由规则
    .rule()
    .msgType("MSG_TYPE")
    .handler(handler)
    .end()
        // 消息经过这个规则后可以继续尝试后面的路由规则
    .rule()
    .msgType("MSG_TYPE")
    .handler(handler)
    .next()
        // 另一个同步处理的路由规则
    .rule()
    .async(false)
    .msgType("MSG_TYPE")
    .handler(handler)
    .end()
        // 添加了拦截器的路由规则
    .rule()
    .msgType("MSG_TYPE")
    .interceptor(interceptor)
    .handler(handler)
    .end()
        // 兜底路由规则，一般放到最后
    .rule()
    .handler(handler)
    .end()
;

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

1. 配置路由规则时要按照从细到粗的原则，否则可能消息可能会被提前处理
2. 规则的结束必须用Rule.end()或者Rule.next()，否则不会生效
3. 具体使用可以看源代码中的WxMpMessageRouterTest单元测试，或者查看Javadoc

关于如何构造WxMpXmlMessage请看消息的加解密。

WxMessageHandler

public interface WxMpMessageHandler {

  /**
   *
   * @param wxMessage
   * @param context  上下文，如果handler或interceptor之间有信息要传递，可以用这个
   * @param wxMpService
   * @return xml格式的消息，如果在异步规则里处理的话，可以返回null
   */
  public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
                                  Map<String, Object> context,
                                  WxMpService wxMpService,
                                  WxSessionManager sessionManager);

}

关于WxSessionManager请看WxSession的使用。

WxMessageInterceptor

public interface WxMpMessageInterceptor {

  /**
   * 拦截微信消息
   * @param wxMessage
   * @param context  上下文，如果handler或interceptor之间有信息要传递，可以用这个
   * @param wxMpService
   * @return  true代表OK，false代表不OK
   */
  public boolean intercept(WxMpXmlMessage wxMessage,
                           Map<String, Object> context,
                           WxMpService wxMpService,
                           WxSessionManager sessionManager);

}

关于WxSessionManager请看WxSession的使用。