如何将 RabbitMQ 扩展到某些消费者

Question

我正在使用 RabbitMQ 向 2 个或更多消费者发送消息。 看着the simple tutorial我可以很容易地做到这一点。

但我也想扩展我的一些消费者，并允许 一些 消费者始终处理消息，而 一些 消费者只在消息未处理时才处理该消息已经被另一个“类似”消费者。

    |-------> cA
    |
P --|-------> cB'
    |   
    |-------> cB"

在我上面的例子中：

• cA 将始终处理消息，无论如何。
• 如果cB" 尚未处理邮件，cB' 将仅处理邮件。
• 如果cB' 尚未处理消息，cB" 将仅处理该消息。

我们的想法是尽可能快地处理数据，并且（看上图）如果cB' 或cB" 需要联系数据库或 API，我希望另一个消费者从尽可能快地排队。 但我也不希望这些数据被多次提取。

我总是可以添加另一个发布者并将消息从队列中删除，但我不确定这是否真的是实现我所追求的最有效的方法。

    |-------> cA
    |
P --|-------> p'--|-------> cB'
                  |
                  |-------> cB"

这在 RabbitMQ 中可以实现吗？

Answer 1

阅读Consumer Priorities 还有Dead Letter Exchanges

Answer 2

如果我正确理解了您的问题，那么带有 2 个队列的设置将解决您的问题。

两个队列都必须使用相同的路由键绑定到 exchange(X)。

如果您按以下模式订阅队列：

• cA 作为 queue1 的唯一订阅者
• cB' 和 cB" 共享队列2

路由和订阅概述：

         |--<routing key>---queue1-----cA
 P---X---|                          
         |                          |--cB'
         |--<routing key>---queue2--|
                                    |--cB"

消息将：

• 始终由 cA 和
处理
• 以循环方式通过 cB' 或 cB"（在默认队列配置中）。您可以配置 cB' 和 cB" 之间如何共享负载的行为。详情请参阅https://www.rabbitmq.com/tutorials/tutorial-two-dotnet.html。