RocketMQ 消息重复消费

现象

触发消息后，在1s内收到了两次消息消费的日志。

消息消费日志重复，reconsumeTimes=0，主机实例也不同，说明是同一条消息被消费了两次

分析

生产者发送消息的时候使用了重试机制，发送消息后由于网络原因没有收到MQ的响应信息，报了超时异常，然后又去重新发送了一次消息。

但其实MQ已经接到了消息，并返回了响应，只是因为网络原因超时了。

这种情况下，一条消息就会被发送两次。

解决

RocketMQ提供了ack机制，以保证消息能够被正常消费。发送者为了保证消息肯定消费成功，只有使用方明确表示消费成功，RocketMQ才会认为消息消费成功。中途断电，抛出异常等都不会认为成功——即都会重新投递。

经过分析发现：

• 这条消息先是被某一台主机消费了，当时服务正在重启，网络不稳定，mq没有收到成功的返回，就会重新发送到另外一台服务器上。

• MQ会因网络抖动的情况出现消息重复消费的问题，所以要做好幂等校验；

RocketMQ不保证消息不重复，如果业务需要保证严格的不重复消息，需要在业务端进行去重。