RabbitMQ消息重复的原因与解决方案

简介

本文介绍RabbitMQ消息重复的原因以及解决方案（即：如何保证消息不重复消费）。

对于消息队列（MQ）来说，消息丢失/消息重复/消费顺序/消息堆积是比较常见的问题，都属于消息异常，这几个问题比较重要，面试中也会经常问到。

什么时候会重复消费

自动提交模式时

消费者收到消息后，要自动提交，但提交后，网络出故障，RabbitMQ服务器没收到提交消息，那么此消息会被重新放入队列，会再次发给消费者。

手动提交模式时

情景1：网络故障问题，同上。
情景2：接收到消息并处理结束了，此时消费者挂了，没有手动提交消息。

解决方案

简介

造成消息重复的两个原因是：网络不可达、消费端宕机。无法避免这两个问题，解决方法就是绕过这个问题。

问题就变成了：如果消费端收到两条一样的消息，应该怎样处理？

方案1：消费者保证业务幂等性

消费端处理消息的业务逻辑保持幂等性。

• 比如你拿个数据要写库，先根据主键查一下，如果这数据有了，就别插入了，update 一下。
• 比如你是写 Redis，那没问题了，反正每次都是 set，天然幂等性。

方案2：消费者用消息日志保证幂等

利用一张日志表来记录已经处理成功的消息的 ID，如果新到的消息 ID 已经在日志表中，那么就不再处理这条消息。

注意：此时需要保证每个消息都有唯一的id。 ​