issue #87 WxMessageRouter、Rule提供setter方法，便于使用spring等依赖注入框架

Author: chanjarster

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpMessageRouter.java

@@ -1,7 +1,9 @@
 package me.chanjar.weixin.cp.api;
 
-import me.chanjar.weixin.common.exception.WxErrorException;
-import me.chanjar.weixin.common.session.*;
+import me.chanjar.weixin.common.session.InternalSession;
+import me.chanjar.weixin.common.session.InternalSessionManager;
+import me.chanjar.weixin.common.session.StandardSessionManager;
+import me.chanjar.weixin.common.session.WxSessionManager;
 import me.chanjar.weixin.common.util.LogExceptionHandler;
 import me.chanjar.weixin.common.util.WxErrorExceptionHandler;
 import me.chanjar.weixin.common.util.WxMessageDuplicateChecker;
@@ -12,23 +14,20 @@
 import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
-import java.util.regex.Pattern;
 
 /**
  * <pre>
  * 微信消息路由器，通过代码化的配置，把来自微信的消息交给handler处理
  *
  * 说明：
  * 1. 配置路由规则时要按照从细到粗的原则，否则可能消息可能会被提前处理
- * 2. 默认情况下消息只会被处理一次，除非使用 {@link Rule#next()}
- * 3. 规则的结束必须用{@link Rule#end()}或者{@link Rule#next()}，否则不会生效
+ * 2. 默认情况下消息只会被处理一次，除非使用 {@link WxCpMessageRouterRule#next()}
+ * 3. 规则的结束必须用{@link WxCpMessageRouterRule#end()}或者{@link WxCpMessageRouterRule#next()}，否则不会生效
  *
  * 使用方法：
  * WxCpMessageRouter router = new WxCpMessageRouter();
@@ -55,7 +54,7 @@ public class WxCpMessageRouter {
 
   private static final int DEFAULT_THREAD_POOL_SIZE = 100;
 
-  private final List<Rule> rules = new ArrayList<Rule>();
+  private final List<WxCpMessageRouterRule> rules = new ArrayList<WxCpMessageRouterRule>();
 
   private final WxCpService wxCpService;
 
@@ -100,20 +99,35 @@ public void setMessageDuplicateChecker(WxMessageDuplicateChecker messageDuplicat
   /**
    * <pre>
    * 设置自定义的{@link me.chanjar.weixin.common.session.WxSessionManager}
-   * 如果不调用该方法，默认使用 {@linke SessionManagerImpl}
+   * 如果不调用该方法，默认使用 {@link me.chanjar.weixin.common.session.StandardSessionManager}
    * </pre>
    * @param sessionManager
    */
   public void setSessionManager(WxSessionManager sessionManager) {
     this.sessionManager = sessionManager;
   }
 
+  /**
+   * <pre>
+   * 设置自定义的{@link me.chanjar.weixin.common.util.WxErrorExceptionHandler}
+   * 如果不调用该方法，默认使用 {@link me.chanjar.weixin.common.util.LogExceptionHandler}
+   * </pre>
+   * @param exceptionHandler
+   */
+  public void setExceptionHandler(WxErrorExceptionHandler exceptionHandler) {
+    this.exceptionHandler = exceptionHandler;
+  }
+
+  List<WxCpMessageRouterRule> getRules() {
+    return this.rules;
+  }
+
   /**
    * 开始一个新的Route规则
    * @return
    */
-  public Rule rule() {
-    return new Rule(this);
+  public WxCpMessageRouterRule rule() {
+    return new WxCpMessageRouterRule(this);
   }
 
   /**
@@ -125,13 +139,13 @@ public WxCpXmlOutMessage route(final WxCpXmlMessage wxMessage) {
       // 如果是重复消息，那么就不做处理
       return null;
     }
-    
-    final List<Rule> matchRules = new ArrayList<Rule>();
+
+    final List<WxCpMessageRouterRule> matchRules = new ArrayList<WxCpMessageRouterRule>();
     // 收集匹配的规则
-    for (final Rule rule : rules) {
+    for (final WxCpMessageRouterRule rule : rules) {
       if (rule.test(wxMessage)) {
         matchRules.add(rule);
-        if(!rule.reEnter) {
+        if(!rule.isReEnter()) {
           break;
         }
       }
@@ -143,9 +157,9 @@ public WxCpXmlOutMessage route(final WxCpXmlMessage wxMessage) {
 
     WxCpXmlOutMessage res = null;
     final List<Future> futures = new ArrayList<Future>();
-    for (final Rule rule : matchRules) {
+    for (final WxCpMessageRouterRule rule : matchRules) {
       // 返回最后一个非异步的rule的执行结果
-      if(rule.async) {
+      if(rule.isAsync()) {
         futures.add(
             executorService.submit(new Runnable() {
               public void run() {
@@ -216,252 +230,5 @@ protected void sessionEndAccess(WxCpXmlMessage wxMessage) {
 
   }
 
-  public static class Rule {
-
-    private final WxCpMessageRouter routerBuilder;
-
-    private boolean async = true;
-
-    private String fromUser;
-
-    private String msgType;
-
-    private String event;
-
-    private String eventKey;
-
-    private String content;
-
-    private String rContent;
-
-    private WxCpMessageMatcher matcher;
-
-    private boolean reEnter = false;
-
-    private Integer agentId;
-
-    private List<WxCpMessageHandler> handlers = new ArrayList<WxCpMessageHandler>();
-
-    private List<WxCpMessageInterceptor> interceptors = new ArrayList<WxCpMessageInterceptor>();
-
-    protected Rule(WxCpMessageRouter routerBuilder) {
-      this.routerBuilder = routerBuilder;
-    }
-
-    /**
-     * 设置是否异步执行，默认是true
-     * @param async
-     * @return
-     */
-    public Rule async(boolean async) {
-      this.async = async;
-      return this;
-    }
-
-    /**
-     * 如果agentId匹配
-     * @param agentId
-     * @return
-     */
-    public Rule agentId(Integer agentId) {
-      this.agentId = agentId;
-      return this;
-    }
-
-    /**
-     * 如果msgType等于某值
-     * @param msgType
-     * @return
-     */
-    public Rule msgType(String msgType) {
-      this.msgType = msgType;
-      return this;
-    }
-
-    /**
-     * 如果event等于某值
-     * @param event
-     * @return
-     */
-    public Rule event(String event) {
-      this.event = event;
-      return this;
-    }
-
-    /**
-     * 如果eventKey等于某值
-     * @param eventKey
-     * @return
-     */
-    public Rule eventKey(String eventKey) {
-      this.eventKey = eventKey;
-      return this;
-    }
-
-    /**
-     * 如果content等于某值
-     * @param content
-     * @return
-     */
-    public Rule content(String content) {
-      this.content = content;
-      return this;
-    }
-
-    /**
-     * 如果content匹配该正则表达式
-     * @param regex
-     * @return
-     */
-    public Rule rContent(String regex) {
-      this.rContent = regex;
-      return this;
-    }
-
-    /**
-     * 如果fromUser等于某值
-     * @param fromUser
-     * @return
-     */
-    public Rule fromUser(String fromUser) {
-      this.fromUser = fromUser;
-      return this;
-    }
-
-    /**
-     * 如果消息匹配某个matcher，用在用户需要自定义更复杂的匹配规则的时候
-     * @param matcher
-     * @return
-     */
-    public Rule matcher(WxCpMessageMatcher matcher) {
-      this.matcher = matcher;
-      return this;
-    }
-
-    /**
-     * 设置微信消息拦截器
-     * @param interceptor
-     * @return
-     */
-    public Rule interceptor(WxCpMessageInterceptor interceptor) {
-      return interceptor(interceptor, (WxCpMessageInterceptor[]) null);
-    }
-
-    /**
-     * 设置微信消息拦截器
-     * @param interceptor
-     * @param otherInterceptors
-     * @return
-     */
-    public Rule interceptor(WxCpMessageInterceptor interceptor, WxCpMessageInterceptor... otherInterceptors) {
-      this.interceptors.add(interceptor);
-      if (otherInterceptors != null && otherInterceptors.length > 0) {
-        for (WxCpMessageInterceptor i : otherInterceptors) {
-          this.interceptors.add(i);
-        }
-      }
-      return this;
-    }
-
-    /**
-     * 设置微信消息处理器
-     * @param handler
-     * @return
-     */
-    public Rule handler(WxCpMessageHandler handler) {
-      return handler(handler, (WxCpMessageHandler[]) null);
-    }
-
-    /**
-     * 设置微信消息处理器
-     * @param handler
-     * @param otherHandlers
-     * @return
-     */
-    public Rule handler(WxCpMessageHandler handler, WxCpMessageHandler... otherHandlers) {
-      this.handlers.add(handler);
-      if (otherHandlers != null && otherHandlers.length > 0) {
-        for (WxCpMessageHandler i : otherHandlers) {
-          this.handlers.add(i);
-        }
-      }
-      return this;
-    }
-
-    /**
-     * 规则结束，代表如果一个消息匹配该规则，那么它将不再会进入其他规则
-     * @return
-     */
-    public WxCpMessageRouter end() {
-      this.routerBuilder.rules.add(this);
-      return this.routerBuilder;
-    }
-
-    /**
-     * 规则结束，但是消息还会进入其他规则
-     * @return
-     */
-    public WxCpMessageRouter next() {
-      this.reEnter = true;
-      return end();
-    }
-
-    protected boolean test(WxCpXmlMessage wxMessage) {
-      return
-          (this.fromUser == null || this.fromUser.equals(wxMessage.getFromUserName()))
-          &&
-          (this.agentId == null || this.agentId.equals(wxMessage.getAgentId()))
-          &&
-          (this.msgType == null || this.msgType.equals(wxMessage.getMsgType()))
-          &&
-          (this.event == null || this.event.equals(wxMessage.getEvent()))
-          &&
-          (this.eventKey == null || this.eventKey.equals(wxMessage.getEventKey()))
-          &&
-          (this.content == null || this.content.equals(wxMessage.getContent() == null ? null : wxMessage.getContent().trim()))
-          &&
-          (this.rContent == null || Pattern.matches(this.rContent, wxMessage.getContent() == null ? "" : wxMessage.getContent().trim()))
-          &&
-          (this.matcher == null || this.matcher.match(wxMessage))
-      ;
-    }
-
-    /**
-     * 处理微信推送过来的消息
-     * @param wxMessage
-     * @return true 代表继续执行别的router，false 代表停止执行别的router
-     */
-    protected WxCpXmlOutMessage service(WxCpXmlMessage wxMessage,
-                                        WxCpService wxCpService,
-                                        WxSessionManager sessionManager,
-                                        WxErrorExceptionHandler exceptionHandler) {
-
-      try {
-
-        Map<String, Object> context = new HashMap<String, Object>();
-        // 如果拦截器不通过
-        for (WxCpMessageInterceptor interceptor : this.interceptors) {
-          if (!interceptor.intercept(wxMessage, context, wxCpService, sessionManager)) {
-            return null;
-          }
-        }
-
-        // 交给handler处理
-        WxCpXmlOutMessage res = null;
-        for (WxCpMessageHandler handler : this.handlers) {
-          // 返回最后handler的结果
-          res = handler.handle(wxMessage, context, wxCpService, sessionManager);
-        }
-        return res;
-
-      } catch (WxErrorException e) {
-        exceptionHandler.handle(e);
-      }
-
-      return null;
-
-    }
-
-  }
 
 }