【RabbitMQ】RabbitMQ如何保证消息不丢失？
为了保证消息不丢失，需要在生产者、RabbitMQ本身和消费者三个环节采取相应措施。
1.生产者端：确保消息发送成功
1.1开启消息确认机制(Publisher Confirms)
- 原理： 生产者发送消息后，RabbitMQ会返回一个确认(ACK),表示消息已成功接收。
1.2开启事务机制(Transactions)
- 原理： 生产者发送信息后，可以通过事务机制确保信息被成功接收。
- 注意： 事务机制性能较低，推荐消息确认机制。
1.3消息持久化
- 原理： 将消息标记为持久化，确保RabbitMQ重启后消息不会丢失。
2.RabbitMQ端：确保消息可靠存储
2.1队列持久化：
- 原理： 将队列标记为持久化，确保RabbitMQ重启后队列不会丢失。
2.2交换机持久化:
- 原理： 将交换机标记为持久化，确保RabbitMQ重启后交换机不会丢失。
2.3镜像队列
- 原理： 将队列镜像到多个节点，确保即使某个节点宕机，消息也不会丢失。
3.消费者端:确保消息成功处理
3.1手动确认
- 原理: 消费者在处理完消息后，手动发送确认(ACK)给RabbitMQ，表示消息已成功处理。
3.2消息重试机制:
- 原理： 如果消息处理失败，可以将消息重新放回队列或转移到私信队列(Dead Letter Queue DLQ)。
3.3死信队列:
- 原理： 将处理失败的消息转移到死信队列，避免消息丢失。
4.总结：
- 生产者端: 开启消息确认机制，发送持久化消息。
- RabbitMQ端: 持久化队列和交换机，使用镜像队列。
- 消费者端： 开启手动确认机制，实现消费重试或使用死信队列。