AMQP：确认和预取

Question

我试图了解AMQP协议的一些方面。目前我有RabbitMQ项目并使用python pika库。所以问题是关于确认和消息预取。

>

假设我们有一个只有消费者的队列（确保这个队列被声明为独占的）。那么，我是否正确理解了：无论我使用ack标志还是不使用ack标志？无论如何，我不应该能够同时处理多条消息，而且没有其他消费者可以接收其他仍在排队的消息。最好不要打开确认，因为这可能会减少AMQP服务器的负载。

如果没有确认，预取计数就没有任何意义。对吗？

我不确定预取是如何工作的。我对新消息有一个回调，在它的最终语句中我承认或拒绝该消息。这是唯一的功能，无论预取计数有多大——无论如何，在当前消息完成之前不会处理另一条消息。那么为什么我需要更改prefetch_count值呢？

提前谢谢。

Answer 1

取消设置autoack标志后，如果应用程序在消息处理过程中失败，所有收到的消息都将丢失。如果这种情况非常罕见，并且message lose是应用程序中的适当选项（例如，但不限于日志处理），则可以关闭autoack。

是的，取消设置autoackunset需要更简单的代理逻辑，因此它使用的资源更少。

至于prefetch count（和prefetch size），这些选项告诉代理，对于单个消息，提前发送到客户端的有效负载可能有多大。通常用于节省网络操作等待新消息的时间。当prefetch size使用时，客户端将收到一条或多条消息，其总大小等于或小于预设的pretch size（和/或count，小于）。

应用预取计数和预取大小规则。当其中一个设置为零（未设置）时，将不应用该设置。

最重要的是，预取定义了在客户端未确认的更多消息之前发送消息的行为。

这两种设置结合起来会产生如下效果：

使用邮件计数限制预回迁并提前发送邮件：

条件：

• 队列：N条消息x 1kb

工作流程：

• 代理向客户端发送4条消息（受预取计数=4限制）。4消息将被标记为未确认并从队列中移出（这样它们就不会被传递到其他客户端）

使用大消息预回迁：

条件：

• 队列：1条消息x 5Kb，N条消息x 1kb
• 预取：预取大小=5kb，预取计数=2
• 自动确认：关闭

工作流程：

• Broker向客户端发送1条消息（受预取大小=5kb的限制），并将该消息标记为un-aked

使用自动确认：

条件：

• 队列：N条消息x 1kb
• 预取：预取大小=5kb，预取计数=10
• 自动确认：开启

工作流程：

• 当no ack设置为true时，prefetch size和prefetch count都被忽略（这是RabbitMQ和AMQP文档中调用自动确认功能的方式），消息将逐个发送到客户端，并在成功发送后从队列中删除

请注意，AMQP具有异步体系结构，因此在某些情况下，两个客户端可能会同时接收单个消息。此外，未确认的消息可能会被发送回同一个客户端（尤其是如果您只有一个客户端）。

此外，查看prefetch-size和prefetch-count官方留档，并尝试使用这些选项。

注意：autoack基本上是no ackAMQP标志设置为true。