美文网首页
应用扩容导致的mq消息积压和重发消费问题

应用扩容导致的mq消息积压和重发消费问题

作者: luncene_e110 | 来源:发表于2021-01-07 09:14 被阅读0次

    背景:

       为应对元旦促销活动,导致的突发流量,决定对应用进行扩容,新增多个节点。

    现象:

    根据topic来看,queue没有分配均匀,有没有被分配consumer的queue,消费的模式是cluster

    且根据应用日志查看,发现有消息被多台应用同时消费间隔。

    根据代码核实:consumer在注册到broker的时候,是用broker的ip@进程号来做为clientId的,我们应用扩容时,docker的内部的ip都是一样的,然后每个应用的进程号都为1,导致broker无法区分client,在client端做reblance的时候也会出现问题。

    相关文章

      网友评论

          本文标题:应用扩容导致的mq消息积压和重发消费问题

          本文链接:https://www.haomeiwen.com/subject/yuiaoktx.html