RocketMQ原理解析-consumer 2.消费端负载均衡

消费端负载均衡算法 消费端会经过RebalanceService线程,10秒钟作一次基于topic下的全部队列负载负载均衡   消费端遍历本身的全部topic,依次调rebalanceByTopic异步  根据topic获取此topic下的全部queue线程  选择一台broker获取基于group的全部消费端(有心跳向全部broker注册客户端信息)对象  选择队列分配策略实例AllocateM
相关文章
相关标签/搜索