src/org/redkale/mq/MessageMultiConsumer.java

@@ -10,9 +10,38 @@ import static java.lang.annotation.ElementType.*;
 import static java.lang.annotation.RetentionPolicy.RUNTIME;
 
 /**
- * 多消费组，需要同 @RestService 一起使用
+ * 多消费组，需要同 @RestService 一起使用
  * <p>
- * 标记 @MessageMultiConsumer 的Service的@RestMapping方法都只能是void返回类型
+ * 通常一个topic只会被一个RestService消费， 当一个topic需要被其他RestService消费时，就需要使用&#64;MessageMultiConsumer
+ *
+ * <blockquote><pre>
+ * &#64;RestService(name = "user", comment = "用户服务")
+ * public class UserService implements Service{
+ *
+ *      &#64;RestMapping(comment = "用户登录")
+ *      public RetResult login(LoginBean bean){
+ *          //do something
+ *      }
+ * }
+ * </pre></blockquote>
+ *
+ * 需求：统计用户登录次数， 可以创建一个MessageMultiConsumer 的 RestService：
+ * <blockquote><pre>
+ * <b>&#64;MessageMultiConsumer(module = "user") </b>
+ * &#64;RestService(name = "loginstat", comment = "用户统计服务")
+ * public class LoginStatService implements Service{
+ *
+ *      private AtomicLong counter = new AtomicLong();
+ *
+ *      &#64;RestMapping(name = "login", comment = "用户登录统计")
+ *      public void stat(LoginBean bean){     //参数必须和UserService.login方法一致
+ *          counter.incrementAndGet();
+ *      }
+ * }
+ * </pre></blockquote>
+ *
+ * <p>
+ * 注： 标记 &#64;MessageMultiConsumer 的Service的&#64;RestMapping方法都只能是void返回类型
  *
  * <p>
  * 详情见: https://redkale.org