我将rabbitmq producer和consumer用于nodejs。如果我在一秒钟内将1000条消息推送到一个队列中,我不想一下子把它们全部消耗掉。我想在一秒钟内消耗10条信息,以此类推。如何做到这一点?
您应该熟悉amqp和rabbitmq的工作原理,特别是通过执行 tutorials .
Tutorial two 介绍了 prefetch (也称为 QoS )这将限制发送给消费者的未确认消息的数量。
prefetch
QoS
注: rabbitmq团队监控 the rabbitmq-users mailing list 有时只在stackoverflow上回答问题。
rabbitmq-users
