首页 > 其他 > 详细

RocketMQ的Consumer是如何做的负载均衡的

时间:2020-07-29 10:54:25      阅读:130      评论:0      收藏:0      [点我收藏+]

https://zhuanlan.zhihu.com/p/159017211

看着这算法凌乱的很,太复杂了!说实话,确实挺复杂,蛮罗嗦的,但是代数法可以得到如下表格:

假设4个queueConsumer有2个可以整除Consumer有3个不可整除Consumer有5个无法都分配queue[0]Consumer[0]Consumer[0]Consumer[0]queue[1]Consumer[0]Consumer[0]Consumer[1]queue[2]Consumer[1]Consumer[1]Consumer[2]queue[3]Consumer[1]Consumer[2]Consumer[3]

所以得出如下真香定律(也是回击面试官的最佳答案):

  • queue个数大于Consumer个数,且queue个数能整除Consumer个数的话, 那么Consumer会平均分配queue。(比如上面表格的Consumer有2个 可以整除部分)
  • queue个数大于Consumer个数,且queue个数不能整除Consumer个数的话, 那么会有一个Consumer多消费1个queue,其余Consumer平均分配。(比如上面表格的Consumer有3个 不可整除部分)
  • queue个数小于Consumer个数,那么会有Consumer闲置,就是浪费掉了,其余Consumer平均分配到queue上。(比如上面表格的Consumer有5个 无法都分配部分)

当一个consumer出现宕机后,默认最多20s,其它机器将重新消费已宕机的机器消费的queue

新启动Consumer的话会立即唤醒沉睡的线程, 让他立马进行this.mqClientFactory.doRebalance();

RocketMQ的Consumer是如何做的负载均衡的

原文:https://www.cnblogs.com/seakyfly/p/13395072.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!