被问到MQ消息已丢失，该如何处理？
在分布式系统中，消息中间件（如RabbitMQ、Kafka等）用于解耦生产者和消费者，确保数据传输的可靠性和顺序性。尽管有多种措施防止消息丢失，如消息持久化、手动确认机制和重试机制，但消息丢失仍可能发生。本文探讨了四种常见丢失场景及补救措施：1. 生产者发送消息失败；2. 消息在传输过程中丢失；3. 消息中间件内部丢失；4. 消费者未处理完消息前丢失。针对每种场景，提出了相应的解决方案，如消息重发、本地存储、日志记录、高可用配置、死信队列等，以确保系统的可靠性和稳定性。
RocketMQ实战—5.消息重复+乱序+延迟的处理
本文围绕RocketMQ的使用与优化展开，分析了优惠券重复发放的原因及解决方案。首先，通过案例说明了优惠券系统因消息重复、数据库宕机或消费失败等原因导致重复发券的问题，并提出引入幂等性机制（如业务判断法、Redis状态判断法）来保证数据唯一性。其次，探讨了死信队列在处理消费失败时的作用，以及如何通过重试和死信队列解决消息处理异常。接着，分析了订单库同步中消息乱序的原因，提出了基于顺序消息机制的代码实现方案，确保消息按序处理。此外，介绍了利用Tag和属性过滤数据提升效率的方法，以及延迟消息机制优化定时退款扫描的功能。最后，总结了RocketMQ生产实践中的经验.