我想使用node-amqp库为 RabbitMQ 创建多个消费者,但我不明白该prefetch-count
选项是否指的是每个消费者的计数。我希望每个消费者都有自己的不依赖于其他消费者的预取计数。
谢谢。
可以针对单个消费者,但可以同时为多个消费者设置。只需在此处查找标题示例 - 单一消费者 。所以 AMQP 支持它。我不确定您提到的库,但在官方 java lib 上就是这样 - 对 AMQP 的 basic.qos 方法透明。也来自上述链接
请注意,在大多数 API 中,全局标志的默认值为 false
当 global==false 时,对于 rabbitmq
prefetch_count 分别应用于通道上的每个新消费者
所以你需要找出它是如何在那个库中实现的。
另外考虑使用 amqp.node 库,因为这个库用于 rabbimtq 教程。(编辑我现在才看到德里克贝利已经提到过。)