rocketmq 两个线程同时消费一个消息

Posted rocky-fang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketmq 两个线程同时消费一个消息相关的知识,希望对你有一定的参考价值。

1.问题描述

线上项目A部署两台机器,每台机器两个实例,订阅同一个topic,消费心跳数据。

(两台机器host1,host2)

运维同事 部署时 有一个实例用root账户重启的, 然后该实例出现两个线程同时消费一个消息的情况,并且后台查看该消费group delay很多。

图一  host1机器两个实例 一个为root启动

图二  rocketmq 监控后台  该group共5个消费者 delay 60多万

图三  host1 实例2(即root启动那个) 日志    显示同时有两个线程消费同一个消息

图四  其他账号重启后 rocketmq 情况正常

以上是关于rocketmq 两个线程同时消费一个消息的主要内容,如果未能解决你的问题,请参考以下文章

RocketMQ 死信队列 | 消费者出现异常如何处理?

RocketMQ 顺序消费

rocketmq之顺序消费

单Broker集群,RocketMQ宕机时消费失败会有什么问题

RocketMQ与Dubbo之间线程之间如何阻塞和唤醒

RocketMQ的顺序消息(顺序消费)