对于消息队列（MQ）来说，消息丢失/消息重复/消费顺序/消息堆积是比较常见的问题，都属于消息异常，这几个问题比较重要，面试中也会经常问到。
重复消费
自动提交模式时
消费者收到消息后，要自动提交，但提交后，网络出故障，RabbitMQ服务器没收到提交消息，那么此消息会被重新放入队列，会再次发给消费者。
手动提交模式时
情景1：网络故障问题，同上。
情景2：接收到消息并处理结束了，此时消费者挂了，没有手动提交消息。
解决方案
造成消息重复的两个原因是：网络不可达、消费端宕机。无法避免这两个问题，解决方法就是绕过这个问题。
问题就变成了：如果消费端收到两条一样的消息，应该怎样处理？
方案1：消费者保证业务幂等性
消费端处理消息的业务逻辑保持幂等性。
- 比如你拿个数据要写库，先根据主键查一下，如果这数据有了，就别插入了，update 一下。
- 比如你是写 Redis，那没问题了，反正每次都是 set，天然幂等性。
方案2：消费者用消息日志保证幂等
利用一张日志表来记录已经处理成功的消息的 ID，如果新到的消息 ID 已经在日志表中，那么就不再处理这条消息。
注意：此时需要保证每个消息都有唯一的id。
本文转载自: https://blog.csdn.net/qq_63431773/article/details/134557403
版权归原作者 无语堵上西楼 所有， 如有侵权，请联系我们删除。
版权归原作者 无语堵上西楼 所有， 如有侵权，请联系我们删除。