如何使用 SimpleMessageListenerContainer 禁用 RabbitMQ 预取计数

Question

RabbitMQ 提供了选择设置预取计数的能力。

使用 spring-amqp 的 SimpleMessageListenerContainer，我注意到预取计数始终设置。我无法将预取计数设置为 0，因为 SimpleMessageListenerContainer 将其设置为至少 txSize 必须大于零（即使不涉及事务）。那么有没有办法禁用预取计数，即使其无限制？

这里是 spring-amqp 的相关代码：

SimpleMessageListenerContainer.createBlockingQueueConsumer() 这样做：

    int actualPrefetchCount = prefetchCount > txSize ? prefetchCount : txSize;

BlockingQueueConsumer.start() 这样做：

    if (!acknowledgeMode.isAutoAck()) {
        // Set basicQos before calling basicConsume (otherwise if we are not acking the broker
        // will send blocks of 100 messages)
        try {
            channel.basicQos(prefetchCount);
        }

Springs 的BlockingQueueConsumer 中总是调用 basicQos() 的原因是什么？没有禁用预取计数的用例吗？ （显然自动确认除外）。

The rabbitmq documentation 讨论了使用通道（全局）范围设置预取计数的开销。没有明确提到使用消费者范围设置它与根本不设置它相比是否有任何开销。如果我没记错的话，spring 总是将它设置为消费者范围。它真的没有任何开销吗？没有选项不设置它似乎仍然很奇怪。

谢谢

Answer 1

由于当前实现移交给内部队列，由于早期 rabbitmq 客户端的工作方式，如果消费者跟不上，不设置 qos 将导致 OOM 条件。

事实上，在 Spring AMQP 的早期版本中，自动确认会发生这种情况，因此队列会根据预取大小进行限制，以阻止代理在这种情况下发送消息。

在 2.0 中，我们是 planning a new container implementation that avoids this queue，因为兔子客户端不再有需要它的问题。那么我们可以考虑支持qos=0。