RabbitMQ多队列消费者(独立消费队列)

TL; DR

是否有任何(Node.JS)模式在一段时间(10秒)后停止使用队列,并closures连接,而不中断消息的处理还没有收到?

更长的版本

我们每天都会向客户发送数百万次推送通知。 生成消息后,我们将它们插入到RabbitMQ中,然后将它们发送给数百个消费者。 通常客户想要几乎同时发送大量的消息,并且如果这些消息进入同一队列,则一个客户的消息将具有另一个客户的消息的处理时间。

我们想要创build一个dynamic的多队列设置,其中一个广告系列的消息正在发送消息。 队列,客户dynamic订阅,处理上千条消息,然后切换到另一个队列。 我们的想法是,我们正在分享我们之间的资源,所以他们将在同一时间并行发送。

我们目前的解决scheme是生成的消息比我们发送出来的要慢,所以它们按照混合顺序插入到队列中。 这不是理想的解决scheme,因为很难find足够慢的速度,但速度并不慢。

我已经尝试创build一个简单的setTimeout,强制消费者在几秒钟后完成消费(Channel#cancel),然后订阅一个队列的消费者最less。 问题是这会中断一些消息的处理。 我已经尝试使用通道#来处理一堆消息(然后select一个不同的队列),但文档说,它是理想的只有几条消息,但不是数百万的消息,使用通道#消耗是好得多性能。

任何想法如何做得好?

       

网上收集的解决方案 "RabbitMQ多队列消费者(独立消费队列)"