RabbitMQ 提供了多种机制来确保消息不丢失，可以通过以下方式来保证消息的可靠性：
- 持久化消息：
- 在生产者发送消息时，设置消息的投递模式为持久化（persistent），使得消息在 RabbitMQ 服务器重启后仍然存在。
- 在消费者消费消息时，确保消费者所绑定的队列和交换机都是持久化的，这样即使 RabbitMQ 服务器重启，队列和交换机也能够恢复，消息不会丢失。
- 开启消息确认模式：
- 在生产者发送消息时，开启消息确认模式（publisher confirms）或事务机制，确保消息成功发送到 RabbitMQ 服务器。
- 生产者可以通过等待 RabbitMQ 返回的确认消息来判断消息是否成功到达服务器，如果没有收到确认消息，则可以进行重试或其他处理。
- 采用可靠性投递机制：
- RabbitMQ 提供了可靠性投递机制，包括生产者确认（publisher confirms）和消费者手动应答（manual acknowledgements）。(PS: 下面有详解)
- 生产者确认机制允许生产者在消息发送后，等待 RabbitMQ 发送确认消息，以确保消息已被正确处理。
- 消费者手动应答机制允许消费者在处理完消息后，显式地发送应答给 RabbitMQ，告知消息已经成功处理，只有在收到应答之后，RabbitMQ 才会将消息标记为已消费，否则会进行重试。
- 设计完善的消息处理机制：
- 在应用程序中，可以采用合理的消息处理策略，例如使用消息重试机制、补偿机制等来处理消息发送或消费过程中的异常情况，确保消息的可靠性。
综上所述，通过持久化消息、开启消息确认模式、采用可靠性投递机制和设计合理的消息处理机制，可以有效地保证 RabbitMQ 中的消息不丢失。
生产者确认（publisher confirms）和消费者手动应答（manual acknowledgements）是RabbitMQ 提供的两种机制，用于确保消息的可靠性。
- 生产者确认（Publisher Confirms）：
- 生产者发送消息到 RabbitMQ 之后，可以等待 RabbitMQ 的确认消息，以确保消息已经成功发送到 RabbitMQ 服务器。
- 生产者通过将频道设置为确认模式来启用生产者确认。在确认模式下，每个发送的消息都会分配一个唯一的标识符。
- RabbitMQ 在接收到消息后，会向生产者返回一个确认消息或者拒绝消息，生产者可以根据这些确认消息来判断消息是否成功到达 RabbitMQ 服务器。
- 如果消息被确认，则可以继续发送下一条消息；如果消息被拒绝，则可能进行重试或其他处理。
- 消费者手动应答（Manual Acknowledgements）：
- 消费者在接收到消息后，可以显式地向 RabbitMQ 发送应答消息，告知 RabbitMQ 消息已经成功处理。
- 在手动应答模式下，消费者需要在适当的时机调用 basicAck 方法来发送应答消息，通知 RabbitMQ 标记消息为已消费。
- 如果消费者没有发送应答消息，RabbitMQ 将会认为消息未被成功处理，然后可以将其交给其他消费者进行处理或进行重试。
- 消费者还可以使用 basicNack 方法来拒绝消息或 basicReject 方法来否定消息，这些方法也可以触发消息的重新投递或进入死信队列等处理。
通过生产者确认和消费者手动应答机制，可以在消息发送和消费过程中确保消息的可靠传输和处理。这样可以避免消息丢失或重复处理的情况，提高了系统的可靠性和稳定性。
