rabbitmq - 如何用 Celery 和 Rabbitmq 实现 "Exclusive Consumer"或 "Exclusive Queue"？

Question

我正在尝试实现一种“独占消费者”或“独占队列”，以避免最终用户必须固定任何内容:代理将选择一个消息消费者来获取队列的所有消息，以确保< strong>排序，如果该消费者失败，代理将自动故障转移并选择另一个消费者。

我想知道 Celery 和 RabbitMQ 的组合是否可以做到。

Answer 1

尽管意识到这个问题已有 7 年多了，但有人可能会像我一样偶然发现这个页面。因此，在 2019 年，RabbitMQ 团队发布了 3.8 版本，支持名为“Single Active Consumer”的新功能。它提供了这种类型的消费者排他性与自动回退行为的结合，其中下一个(随机选择的)监听队列的消费者将在第一个消费者因任何原因脱落或断开连接时成为“单个活跃消费者”。而且这个功能不需要消息队列本身进行任何复杂的设置；它几乎适用于任何队列。

了解更多信息 https://www.cloudamqp.com/blog/2019-04-23-rabbitmq-3-8-feature-focus-single-active-consumer.html和 https://www.rabbitmq.com/consumers.html#single-active-consumer