RocketMQ原理解析-consumer 2.消費端負載均衡

消費端負載均衡算法 消費端會經過RebalanceService線程,10秒鐘作一次基於topic下的全部隊列負載負載均衡   消費端遍歷本身的全部topic,依次調rebalanceByTopic異步  根據topic獲取此topic下的全部queue線程  選擇一臺broker獲取基於group的全部消費端(有心跳向全部broker註冊客戶端信息)對象  選擇隊列分配策略實例AllocateM
相關文章
相關標籤/搜索