【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端: 持久化队列和交换机，使用镜像队列。
• 消费者端： 开启手动确认机制，实现消费重试或使用死信队列。