RocketMQ的消费模式有2种
1 public enum MessageModel { 2 BROADCASTING("BROADCASTING"), 3 CLUSTERING("CLUSTERING"); 4 5 private String modeCN; 6 7 private MessageModel(String modeCN) { 8 this.modeCN = modeCN; 9 } 10 11 public String getModeCN() { 12 return this.modeCN; 13 } 14 }
查看一下源码，在默认情况下，就是集群消费（CLUSTERING）。另一种消费模式，是广播消费（BROADCASTING）。
其实，对于RocketMQ而言，通过ConsumeGroup的机制，实现了天然的消息负载均衡！通俗点来说，RocketMQ中的消息通过ConsumeGroup实现了将消息分发到C1/C2/C3/……的机制，这意味着我们将非常方便的通过加机器来实现水平扩展！
至于消息分发到C1/C2/C3，其实也是可以设置策略的：
原文：https://www.cnblogs.com/jelly12345/p/12789500.html