消息重复消费如何解决?

影响消息正常发送和消费的重要原因是网络的不确定性。

引起重复消费的原因

1)ACK

正常情况下在consumer真正消费完消息后应该发送ack,通知broker该消息已正常消费,从 queue中剔除

当ack因为网络原因无法发送到broker,broker会认为词条消息没有被消费,此后会开启消息 重投机制把消息再次投递到consumer

2)消费模式

在CLUSTERING模式下,消息在broker中会保证相同group的consumer消费一次,但是针 对不同group的consumer会推送多次

解决方案

1)数据库表

处理消息前,使用消息主键在表中带有约束的字段中insert

2)Map

单机时可以使用map ConcurrentHashMap -> putIfAbsent guava cache

3)Redis

分布式锁搞起来。