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(); }
赞0
踩0