RabbitMQ的消息确认机制是怎样的

RabbitMQ 的消息确认机制（Message Acknowledgement）是一种确保消息在传输过程中被正确处理和传递的机制。它主要有两种类型：生产者确认机制和消费者确认机制。

生产者确认机制

生产者确认机制确保消息已经被成功发送到 RabbitMQ 服务器。当生产者发送消息后，需要等待 RabbitMQ 服务器的确认消息，以确保消息已经被成功地发送到 RabbitMQ 服务器。如果 RabbitMQ 服务器没有收到消息或者消息发送失败，生产者会收到一个确认消息，从而可以进行重发或者其他处理。

消费者确认机制

消费者确认机制确保消息已经被成功接收并处理。消费者接收到消息后，需要向 RabbitMQ 服务器发送确认消息，以告诉服务器已经成功地接收并处理了该消息。如果消费者没有发送确认消息，RabbitMQ 服务器会认为该消息没有被正确地处理，从而会将该消息重新发送给其他消费者进行处理。

消息确认的实现方式

• 自动确认（Auto-ack）：当 autoAck 参数设置为 true 时，RabbitMQ 会自动将消息标记为已确认，并从内存（或者磁盘）中删除，而不管消费者是否真正处理了这些消息。
• 手动确认（Manual-ack）：当 autoAck 参数设置为 false 时，RabbitMQ 会等待消费者显式地调用 Basic.Ack 命令后才从内存（或者磁盘）中移除消息。这种模式适合对消息可靠性要求较高的场景。

手动确认的方法又分为三种：

• 肯定确认：Channel.basicAck(long deliveryTag, boolean multiple)：RabbitMQ 已知道该消息并且成功处理消息，可以将其丢弃。
• 否定确认：Channel.basicReject(long deliveryTag, boolean requeue)：消费者客户端可以调用 channel.basicReject 方法来告诉 RabbitMQ 拒绝这个消息。
• 否定批量确认：Channel.basicNack(long deliveryTag, boolean multiple, boolean requeue)：Basic.Reject 命令一次只能拒绝一条消息，如果想要批量拒绝消息，则可以使用 Basic.Nack 这个命令。

相关配置和使用注意事项

• 在配置文件中配置 spring.rabbitmq.publisher-confirms=true 在创建 ConnectionFactory 的时候设置 PublisherConfirms(true) 选项，开启 confirm callback。
• 使用 ConfirmCallback 是一个回调函数，用于在消息被确认时进行回调，以确保消息已经被正确地发送到 RabbitMQ Broker 并被处理。
• 使用 ReturnCallback 机制是在消息无法路由到指定队列时触发回调，生产者可以在回调函数中处理这种情况。

通过上述机制，RabbitMQ 提供了强大的工具来确保消息的正确消费。开发者可以根据具体的业务需求和场景，选择合适的策略来优化消息处理的可靠性和一致性。