在 RabbitMQ 中混合使用 Pub/Sub 和工作队列

Tse*_*eng 4 c# rabbitmq

我正在评估使用 RabbitMQ 作为消息队列/消息总线,并且一直在查看RabbitMQ 页面上的示例教程

我正在寻找教程中未涵盖的特定场景,我不确定是否以及如何通过 RabbitMQ 来实现。

设置

  • 假设我有一项服务,我们称其为“采购订单”,而我需要其他称为“物流”和“会计”的服务。

  • 发送订单时,我想通过 RabbitMQ 将其​​作为消息发送。

  • 有 2 个“账户”和 3 个“物流”服务

确保“帐户”和“后勤”只处理一次消息的正确方法是什么?如果我理解正确,使用 pub/sub 将导致消息被处理两次(帐户)或三次(物流)。

使用工作队列和 prefetch=1 可以确保只有一个得到它,但我有 2 个服务并且希望每种类型的服务都得到一个。

有没有办法将两者结合起来并为每个服务设置一个工作队列,而无需向两个不同的交换发送 2 个单独的事件/消息?

Der*_*ley 5

如果我理解正确,使用 pub/sub 将导致消息被处理两次(帐户)或三次(物流)。

根据您的描述,您可能每个工作人员有 1 个队列,并且您正在将消息路由到所有工作人员队列。因此,每个工作人员都会获得一份消息副本,因为您将消息路由到所有队列。

您想要的是一个“帐户”队列和一个“后勤”队列。您将从单个帐户队列中读取多个帐户服务;物流服务/队列也是如此。

设置 prefetch=1 也很重要。这可以防止您一次将太多消息读入单个工作人员。

有没有办法将两者结合起来并为每个服务设置一个工作队列,而无需向两个不同的交换发送 2 个单独的事件/消息?

是的 - 不要使用扇出交换。使用主题或直接交换,并使用多个路由键将单个消息路由到帐户和物流队列。

确保“帐户”和“后勤”只处理一次消息的正确方法是什么?

没有办法保证这一点,100%。在某些时候,即使像我所描述的那样进行了正确的设置,您也会遇到网络故障或工作程序崩溃或其他一些问题,并且一条消息将被处理两次。您必须在设计中考虑到这一点,在消息处理中使用某种形式的幂等性

希望有帮助!