微信路由消息机制--------Rule解决方案

本是古典何须时尚 2022-02-24 11:42 369阅读 0赞

**1.针对腾讯发来的微信信息，根据信息的相关维度，设置不同的路由规则。**

**2.路由规则每次设置维度后都会返回规则对象，方便之后继续调用。**

**3.每一条路由规则可以设置对应的处理器handlers和拦截器 interceptors **

**4.规则在被执行时service()会执行handlers+interceptors **

**5.规则可以设置为是否同步**

private String fromUser;
    private String msgType;
    private String event;
    private String eventKey;
    private String eventKeyRegex;
    private String content;
    private String rContent;

//设置当前规则是否异步执行
     private boolean async = true;

//消息匹配器 需要时继承接口 接口中只有matcher方法
    private WxMpMessageMatcher matcher;

//处理器-----业务处理责任链
    private List<WxMpMessageHandler> handlers = new ArrayList<>();

//消息拦截器
    private List<WxMpMessageInterceptor> interceptors = new ArrayList<>();

//设置属性，并返回对象，方便继续设置  
    public WxMpMessageRouterRule msgType(String msgType) {
        this.msgType = msgType;
        return this;
      }

// 规则结束，将自身入了添加到router，并返回router对象
      public WxMpMessageRouter end() {
        this.routerBuilder.getRules().add(this);
        return this.routerBuilder;
      }

// 规则结束，判断是否会进入其他规则
      public WxMpMessageRouter next() {
        this.reEnter = true;
        return end();
      }

/**
       * 处理微信推送过来的消息
       *
       * @param wxMessage
       * @return true 代表继续执行别的router，false 代表停止执行别的router
       */
      protected WxMpXmlOutMessage service(WxMpXmlMessage wxMessage,
                                          Map<String, Object> context,
                                          WxMpService wxMpService,
                                          WxSessionManager sessionManager,
                                          WxErrorExceptionHandler exceptionHandler) {
    
        if (context == null) {
          context = new HashMap<>();
        }
    
        try {
          // 如果拦截器不通过
          for (WxMpMessageInterceptor interceptor : this.interceptors) {
            if (!interceptor.intercept(wxMessage, context, wxMpService, sessionManager)) {
              return null;
            }
          }
    
          // 交给handler处理
          WxMpXmlOutMessage res = null;
          for (WxMpMessageHandler handler : this.handlers) {
            // 返回最后handler的结果
            if (handler == null) {
              continue;
            }
            res = handler.handle(wxMessage, context, wxMpService, sessionManager);
          }
          return res;
        } catch (WxErrorException e) {
          exceptionHandler.handle(e);
        }
        return null;
    
      }