zoukankan      html  css  js  c++  java
  • RocketMQ的Consumer是如何做的负载均衡的

    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();

    坚持每天进步,自律改变自己
  • 相关阅读:
    jquery-追加元素
    mssql-异常value '0000-00-00' can not be represented as java.sql.Date
    lucene-Field.Store解析
    mysql-删除日志文件命令详解
    js-读取上传文件后缀
    js-处理回车事件
    maven-腾讯SDK(QQ)接口java引入pom配置
    ps制作gif图片
    java-commons-HttpClient超时设置setConnectionTimeout和setSoTimeout
    js-比较两个日期的大小
  • 原文地址:https://www.cnblogs.com/seakyfly/p/13395072.html
Copyright © 2011-2022 走看看