我的 RabbitMQ 集群中有一个请求流，并且有多个消费者处理它们。问题是 - 出于性能原因，每个消费者都必须批量处理请求。具体来说，有一个网络 IO 操作，我可以通过批处理请求来摊销。
因此，每个消费者都希望最大程度地增加可以批处理的请求数量，但又不会增加太多延迟。
当消费者收到第一个请求时，我可能会启动一个计时器并继续收集请求，直到发生以下两种情况之一 - 计时器到期或收到 500 个请求。
有没有更好的方法来实现这一点 - 不阻止每个消费者？
【问题讨论】：
通常，“批处理消息”的网络方面是在basic.qos(prefetch-size, prefetch-count) 参数级别处理的。在此方案中，代理将发送一些字节/消息（分别）超出消费者的未确认消息，但客户端库在处理中向应用程序一次发送一条消息。
为了最大化利益，应用程序可以为每条消息保留basic.ack()，并定期发出basic.ack(delivery-tag=n, multiple=True)以确认所有带有传递标签
【讨论】：
basic.consume 而不是basic.get；预取不适用于basic.get。如果有意义，您应该以异步样式设计您的应用程序，因为 amqp 更适合该模型。