RocketMQ消息重复消费（同一条消息2毫秒内分别在两台机器上被消费）

我问题已解决，就是楼上说的instanceName 的原因，可以把mq客户端rocketmq-spring-boot-starter升级到最新版本，我目前最新版是2.2.1，见org.apache.rocketmq.spring.support.RocketMQUtil.getInstanceName()的方法，在254行处，如下，就解决了重复消费问题

public static String getInstanceName(String identify) { char separator = '@'; StringBuilder instanceName = new StringBuilder(); instanceName.append(identify).append(separator).append(UtilAll.getPid()).append(separator).append(System.nanoTime()); return instanceName.toString(); }

有可能，如果出现网络波动，重新负载均衡，会出现多台机器在某个时间窗口拿到同一个队列。

我也遇到了同样的问题，折腾了好久。我的问题是因为给所有消费者（consumer）设置了相同的instanceName导致消息被ConsumerGroup中的每个Consumer都消费一次。 解决方案：去除consumer的instanceName设置。 //consumer.setInstanceName(); 本地环境测试后可以正常消费消息了。

但使用Docker部署项目后，发现又再次出现重复消费问题。经过一番查询后，发现不设置instanceName时，rocketmq会使用ip@pid作为instanceName(pid代表jvm名字)。又再次导致instanceName相同。 解决方案：设置consumer的instanceName,给一个UUID使instanceName不相同，解决。 consumer.setInstanceName(UUID);

我也遇到这个问题，不知道楼主有没有找出原因，我这边现象是同一个进程内部不同处理线程同时收到同一条消息，rocketmq日志会有如下这条日志：Note: accumulation consume occurs on mq:*，系统以前很少出现，但是昨天复位业务进程之后频繁出现，目前还没有分析出来为什么有这个问题

RocketMQ不解决消息重复推送问题。解决的话一是在客户端做幂等性处理，二是消息有唯一编号，消费完的消息，存到消息表里，这样做去重。第二种对消息系统的吞吐量有巨大的需求，能用客户端去解决的话，最好用客户端的幂等性