2

如何在 nodejs 中将 amqplib 的预取计数设置为 1? 链接到 git 上的 Lib

期望的结果是消费者只从队列中获取一条消息处理它,并在完成后获取一条新消息。我有一个设置,其中一些消息需要很长时间才能处理,而另一些则需要很短的时间。因此,我不只是想在所有消费者身上平等地分享消息。

4

1 回答 1

5

我使用了 ch.prefetch(1); 在用任务断言队列之后和将队列绑定到交换之前。

于 2018-01-09T10:21:28.033 回答