如何解决RabbitMQ消息的重复消费问题
什么情况下会导致消息的重复消费——在消费者还没成功发送自动确认机制时发生:
- 网络抖动
- 消费者挂了
解决方案
- 每条消息设置一个唯一的标识id
- 幂等方案:【Redis分布式锁、数据库锁(悲观锁、乐观锁)】
面试官:如何解决MQ消息重复消费的问题
候选人:我们当时是设置了自动确认机制,当服务还没来得及给MQ确认的时候,服务宕机了,导致服务重启之后,又消费了一次消息。这样就重复消费了。
因为我们当时有一个业务的唯一标识,我们再处理消息时,先到数据库查询一下,这个数据是否存在,如果不存在,说明没有处理过,这个时候就可以正常处理这个消息了。如果已经存在这个数据了,就说明消息重复消费了,我们就不需要再消费了。
第二种就是典型的幂等性问题,比如,Redis分布式锁、数据库的锁都是可以的。