乘与零-cenyuio

RabbitMQ 消息重复消费问题处理方案（消息幂等性）

本文讨论了RabbitMQ中消息重复消费的问题及其解决方案，特别是如何通过幂等性来确保消息处理的可靠性。文章首先分析了消息重复消费的三个主要原因：生产者重试、消费者确认超时和网络波动。接着，解释了幂等性的概念，即同一条消息被多次消费时，业务结果应与一次性消费一致。为实现消息的幂等性，文章提出了三种解决方案： 1. **唯一标识 + 幂等表**：为每条消息分配唯一ID，消费者在处理消息前通过查询幂等表来确认消息是否已被消费过。如果未消费，则处理消息并更新幂等表；否则，直接丢弃消息。 2. **基于Redis的SETNX**：利用Redis的SETNX命令，以消息唯一ID作为key，在消费前检查key是否存在，若不存在则处理消息，否则直接丢弃。 3. **业务逻辑天然幂等**：某些业务操作本身天然具有幂等性，如更新操作或查询操作，执行多次结果一致。最后，文章强调了实现幂等性时需要注意的关键事项，如消息唯一ID的生成、手动ACK机制、幂等表或Redis的过期设置，以及异常处理的区分。总结来说，保证RabbitMQ消息幂等性的核心是通过唯一标识和幂等校验，确保消息不会被重复处理，从而提高系统的可靠性和稳定性。

2026-03-18 疑难杂症 49

cenyuio

RabbitMQ 工作模式

消息队列（MQ）是一种在分布式系统中用于传递消息的中间件，常见的有ActiveMQ、RabbitMQ、Kafka等。MQ的主要作用包括解决应用耦合、异步处理和流量削峰等问题，从而实现高性能、高可用、可伸缩和最终一致性架构。 1. **应用解耦**：通过引入MQ，订单系统可以与其他系统解耦，订单系统只需发送消息给MQ，由MQ通知其他系统执行操作，减少系统间的依赖，提高系统的独立性和容错性。 2. **异步处理**：MQ适用于无需即时返回且耗时的操作，如订单系统处理业务逻辑时，引入MQ可以将响应时间从600ms缩短至5ms，显著提升系统性能。 3. **流量削峰**：在大流量访问时，MQ可以帮助限制流量，确保服务器正常运行，避免因流量过大而导致系统崩溃。总之，MQ通过解耦、异步处理和流量削峰，提升了系统的性能、可维护性和稳定性。