RabbitMQ学习(十五)：消极确认(Negative Acknowledgements)

叁歲伎倆 2021-12-14 01:57 100阅读 0赞

# 说明 #

在之前的一篇博文[《RabbitMQ学习(十三)：死信交换机 (Dead Letter Exchanges)》][RabbitMQ_ _Dead Letter Exchanges]中我们了解到，消息变为死信有三个原因，其中就有因为消费者的消极确认(negative acknowledgements)，并且将requeue标记设置为false导致消息变为死信。本篇博文将继续翻译学习RabbitMQ官方文档中有关Negative Acknowledgements的内容，了解basic.reject和basic.nack方法的区别，及消息被拒绝后的处理方式。

# 正文 #

## 概述 ##

在AMQP 0-9-1协议中，消费者可以选择使用手动确认的方式确认消息。

**AMQP 0-9-1协议定义了basic.reject方法，允许客户端拒绝接收到的消息。消息被拒绝后，服务器会将消息丢弃或者重新入队派发。但这个方法不支持批量拒绝确认消息。**

为了解决这个问题，**RabbitMQ提供了basic.nack方法**，该方法支持basic.reject方法的所有功能，同时**允许客户端可以批量地处理消息**。

--------------------

## 使用 ##

**要批量拒绝消息，客户端需要使用basic.nack方法并且将multiple标记设置为true。服务器将处理所有的已发送但未确认的消息，同时也包括在basic.nack方法中delivery\_tay字段标记的消息**。这样，basic.nack方法就可以实现与basic.ack方法相似的批量处理消息的操作。

不管是长期运行的消费者还是基于poll方式(使用basic.get方法)消费的消费者，都可以使用两种方法进行消极确认。

**当一个消息被重新入队，它可能会被放置在原来在队列的位置上**。但也会因为存在多个消费者共享一个队列进行消费的情况，**不会回到原来位置。但是消息重新入队后也会被放到尽可能靠近队头的位置。**

--------------------

## 示例 ##

使用java客户端，在poll方式消费的情况下拒绝一个消息，并要求重新入队(basicNack方法第三个参数是requeue标记)。

GetResponse gr = channel.basicGet("some.queue", false);
    channel.basicNack(gr.getEnvelope().getDeliveryTag(), false, true);

以下示例，调用一次方法拒绝两个消息(basicNack方法的第二个参数是multiple标记)

GetResponse gr1 = channel.basicGet("some.queue", false);
    GetResponse gr2 = channel.basicGet("some.queue", false);
    channel.basicNack(gr2.getEnvelope().getDeliveryTag(), true, true);

原文地址: [https://www.rabbitmq.com/nack.html][https_www.rabbitmq.com_nack.html]

[RabbitMQ_ _Dead Letter Exchanges]: https://blog.csdn.net/sinat_36553913/article/details/93350313
[https_www.rabbitmq.com_nack.html]: https://www.rabbitmq.com/nack.html