码迷,mamicode.com
首页 > 其他好文 > 详细

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

时间:2020-07-29 10:19:02      阅读:69      评论:0      收藏:0      [点我收藏+]

标签:其它   均衡   不能   factory   his   面试   不可   唤醒   cli   

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是如何做的负载均衡的

标签:其它   均衡   不能   factory   his   面试   不可   唤醒   cli   

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

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!