java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > RabbitMQ消息确认机制

一文总结RabbitMQ中的消息确认机制

作者：土豆鱼_

RabbitMQ消息确认机制指的是在消息传递过程中，发送方发送消息后，接收方需要对消息进行确认，以确保消息被正确地接收和处理，本文为大家整理了RabbitMQ中的消息确认机制，需要的可以参考一下

RabbitMQ的消息确认机制

RabbitMQ消息确认机制指的是在消息传递过程中，发送方发送消息后，接收方需要对消息进行确认，以确保消息被正确地接收和处理。RabbitMQ的消息确认机制分为两种：

在RabbitMQ中，消息确认机制是通过ACK机制来实现的。ACK代表Acknowledgement，即确认消息。当消息发送方发送消息后，接收方需要向消息发送方发送ACK消息，以表示已经成功地接收和处理了该消息。如果消息发送方没有收到ACK消息，就会认为该消息没有被正确地处理，从而进行重发或者其他处理。

总之，RabbitMQ的消息确认机制可以保证消息的可靠性，从而提高系统的稳定性和可靠性。

消息可靠抵达-ConfirmCallback

RabbitMQ的消息确认机制确保了消息的可靠抵达，其中ConfirmCallback是其中一种实现方式。

ConfirmCallback是一个回调函数，用于在消息被确认时进行回调，以确保消息已经被正确地发送到RabbitMQ Broker并被处理。当生产者发送消息时，可以通过调用channel的confirmSelect()方法将channel设置为confirm模式，然后通过添加ConfirmCallback回调函数来处理消息确认。

当消息被发送到Broker后，如果Broker成功地将消息路由到目标队列，则会调用ConfirmCallback回调函数的handleAck()方法，表示消息已被确认。如果Broker无法将消息路由到目标队列，则会调用handleNack()方法，表示消息未被确认。

使用ConfirmCallback可以确保消息已经被正确地发送到RabbitMQ Broker并被处理，从而避免了消息丢失或重复发送的情况。同时，ConfirmCallback还可以在消息未被确认时进行重试或记录日志等操作，以确保消息的可靠性和稳定性。

ConfirmCallback使用说明： 在配置文件中配置：spring.rabbitmq.publisher-confirms=true 在创建 connectionFactory 的时候设置 PublisherConfirms(true) 选项，开启 confirmcallback 。 CorrelationData：用来表示当前消息唯一性。 消息只要被 broker 接收到就会执行 confirmCallback，如果是 cluster 模式，需要所有broker 接收到才会调用 confirmCallback。 被 broker 接收到只能表示 message 已经到达服务器，并不能保证消息一定会被投递 到目标 queue 里。所以需要用到接下来的 returnCallback 。

消息可靠抵达-ReturnCallback

RabbitMQ的ReturnCallback机制是为了解决消息无法路由到指定队列的问题。当发送的消息无法被路由到指定队列时，RabbitMQ会将消息返回给生产者，这时候如果生产者设置了ReturnCallback回调函数，就可以在回调函数中处理这种情况。

ReturnCallback机制的使用场景一般是在消息发送时，指定了mandatory参数为true，表示如果消息无法被路由到指定队列，则将消息返回给生产者。如果mandatory参数为false，则消息会被直接丢弃。

当生产者设置了ReturnCallback回调函数后，RabbitMQ在将消息返回给生产者时，会触发该回调函数。在ReturnCallback回调函数中，可以处理消息无法路由的情况，例如重发消息、记录日志等。

下面是一个使用ReturnCallback机制的示例代码：

channel.addReturnListener(new ReturnCallback() {
    @Override
    public void handle(ReturnedMessage returnedMessage) {
        String message = new String(returnedMessage.getBody());
        System.out.println("Message returned: " + message);
    }
});
channel.basicPublish(exchangeName, routingKey, true, null, message.getBytes());

在上面的代码中，我们通过addReturnListener方法设置了ReturnCallback回调函数，当消息无法路由到指定队列时，会触发该回调函数。在回调函数中，我们将返回的消息打印出来，以便处理。

需要注意的是，ReturnCallback机制只有在消息被发送到交换机后，才会触发。如果消息发送的交换机不存在，或者路由键不符合任何绑定规则，消息会被直接丢弃，不会触发ReturnCallback回调函数。

在配置文件中配置：

spring.rabbitmq.publisher-returns=true
spring.rabbitmq.template.mandatory=true

confrim 模式只能保证消息到达 broker，不能保证消息准确投递到目标 queue 里。在有 些业务场景下，我们需要保证消息一定要投递到目标 queue 里，此时就需要用到return 退回模式。

这样如果未能投递到目标 queue 里将调用 returnCallback ，可以记录下详细到投递数据，定期的巡检或者自动纠错都需要这些数据。

RabbitMQ自动确认和手动确认

RabbitMQ消息确认机制是一种保证消息可靠抵达的机制。在RabbitMQ中，消息确认机制分为两种模式：自动确认模式和手动确认模式。

在自动确认模式下，当消费者收到消息并将其处理完毕后，RabbitMQ会自动将该消息标记为已确认，然后将其从队列中删除。这种模式比较简单，但是存在消息丢失的风险，因为如果消费者在处理消息的过程中出现异常，消息就会被丢失。

在手动确认模式下，当消费者收到消息并将其处理完毕后，需要向RabbitMQ发送一个确认消息，告诉RabbitMQ该消息已经被处理完毕，可以从队列中删除。如果消费者在处理消息的过程中出现异常，可以选择不发送确认消息，这样消息就不会被从队列中删除，可以重新被其他消费者获取。

手动确认模式可以保证消息不会被丢失，但是需要消费者编写额外的代码来处理确认消息的发送。此外，手动确认模式还可以设置确认模式为批量确认模式，即一次性确认多个消息，可以提高消息处理的效率。

总结：

1.自动ACK模式

在自动ACK模式下，消息一旦被消费者接收到，就会自动被确认。这种模式下，消息一旦被发送到消费者，就会从队列中删除，无论消费者是否已经成功消费该消息。

2.手动ACK模式

在手动ACK模式下，消费者必须手动发送ACK消息来确认消息已经被成功消费。如果消费者没有发送ACK消息，RabbitMQ服务器就会认为该消息还没有被消费，会将该消息重新发送给其他消费者。这种模式下，消费者可以选择性地确认消息，只有当消费者成功消费一条消息并确认后，该消息才会从队列中删除。

手动ACK模式可以保证消息的可靠性，但是需要消费者在处理消息时进行额外的处理，消费者需要在处理消息后发送ACK消息，否则消息会被重新发送。

在 RabbitMQ 中，消费者可以通过设置 channel.basicAck(deliveryTag, multiple) 方法来发送 ack 消息。其中，deliveryTag 表示消息的唯一标识符，multiple 表示是否批量确认。如果 multiple 为 true，表示要确认该 deliveryTag 及其之前的所有消息；如果 multiple 为 false，表示只确认该 deliveryTag 指定的一条消息。

需要注意的是，如果消费者在处理消息时发生了异常，消息并没有被成功处理，那么不应该发送 ack 消息，而应该将消息重新放回队列中，让其他消费者来处理。

RabbitMQ处理消息方法

RabbitMQ提供了一些基本的方法来处理消息，这些方法包括：

这些方法都是基于AMQP协议定义的，可以使用RabbitMQ提供的客户端库或者自己实现AMQP协议来调用这些方法。

到此这篇关于一文总结RabbitMQ中的消息确认机制的文章就介绍到这了,更多相关RabbitMQ消息确认机制内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:
阅读全文