rocketmq 消費者負載均衡-分佈式下的messageQueue的分配和鎖定

思考一個問題,分佈式環境,網絡不穩定.java a臺broker上有messageQueue,b臺queue.算法 a,b都會隨着網絡不穩定而變更,你如何分配,而且保證messageQueue都被分配出去.緩存 rocketMq實現: 客戶端實現負載均衡,每一個人的算法都同樣. (源自於你們都從zk上獲取, topic總messageQueue和consumers )網絡 而後平均分配. 有可能由

>>阅读原文<<