【发布时间】:2018-10-25 05:42:48
【问题描述】:
我在 nodejs 中使用 rabbitmq 生产者和消费者。如果我在一秒钟内将 1000 条消息推送到队列中,我不想一次将其全部消耗掉。我想在一秒钟内消费 10 条消息,依此类推。如何做到这一点?
【问题讨论】:
我在 nodejs 中使用 rabbitmq 生产者和消费者。如果我在一秒钟内将 1000 条消息推送到队列中,我不想一次将其全部消耗掉。我想在一秒钟内消费 10 条消息,依此类推。如何做到这一点?
【问题讨论】:
您应该熟悉 AMQP 和 RabbitMQ 的工作原理,尤其是通过执行 tutorials。
Tutorial two 引入了prefetch(也称为QoS)的概念,它将限制发送给消费者的未确认消息的数量。
注意:RabbitMQ 团队监控 the rabbitmq-users mailing list,并且有时只回答 * 上的问题。
【讨论】:
prefetch 和计时器是解决此问题的一种方法。我不会为他们编写代码。