我目前正在评估消息队列系统,并且 RabbitMq 似乎是一个不错的候选者,所以我正在深入研究它。
为了提供一点上下文,我希望有一个交换负载平衡消息发布到多个队列的东西。我不想复制消息,因此不能选择扇出交换。
另外,我考虑让多个队列与一个队列与消费者一起处理循环的原因是,我不希望我们的单点故障出现在队列级别。
听起来我可以在发布者端添加一些逻辑,通过编辑路由键并设置适当的绑定来模拟该行为。但这是一种被动的方法,它不会考虑每个队列上消息消费的速度,如果该队列的消费者应用程序死了,可能会导致填满一个队列。
我正在从交换实体方面寻找一种更积极主动的方式,它将根据每个队列大小或类似性质的东西来决定将下一条消息发送到哪里。
我读到了 Alice 和可用的 RESTful API,但这似乎是一种实现快速路由决策的重型解决方案。
任何人都知道交换队列之间的循环是否可以使用 RabbitMQ?谢谢。