4.rocketmq源代碼學習----客戶端消息消費(負載均衡）

rocketmq是通過隊列來做負載均衡的 一個主題可以對應到多個隊列，通過分配隊列的數量來保障消費端的負載均衡，一個隊列只會被分配給一臺消費者，來保障消息不會被同一個消費者ID集羣消費。 例如：TopicA有5個隊列，消費者Group1部署了兩臺機器 則一臺機器消費queue0、queue1、queue2 另外一臺機器消費queue3、queue4 通過隊列來保障了消息的負載均衡 代碼如下： Re

>>阅读原文<<