rocketmq 消费者负载均衡-分布式下的messageQueue的分配和锁定

思考一个问题,分布式环境,网络不稳定.java a台broker上有messageQueue,b台queue.算法 a,b都会随着网络不稳定而变更,你如何分配,而且保证messageQueue都被分配出去.缓存 rocketMq实现: 客户端实现负载均衡,每一个人的算法都同样. (源自于你们都从zk上获取, topic总messageQueue和consumers )网络 而后平均分配. 有可能由

>>阅读原文<<