Pub/Sub 与 RabbitMQ 中的工作队列混合
Mixing of Pub/Sub with workqueues in RabbitMQ
我正在评估使用 RabbitMQ 作为消息 queue/message 总线，并且一直在查看 RabbitMQ 页面上的示例 tutorials。
我正在寻找教程未涵盖的特定场景，我不确定是否可以以及如何通过 RabbitMQ 完成。
设置:
假设我有一个服务，我们称它为 "purchase orders" 并且我必须使用其他服务 "logistics" 和 "accounting"。
发送订单时，我想通过 RabbitMQ 将其作为消息发送。
有 2 个 "account" 和 3 个 "logistic" 服务
确保 "account" 和 "logistic" 只处理一次消息的正确方法是什么？如果我理解正确，使用 pub/sub 将导致消息被处理两次（帐户）或三次（物流）。
使用工作队列和 prefetch=1 可以确保只有一个得到它，但我有 2 个服务并希望每种类型的服务都得到一个。
有没有一种方法可以将两者结合起来并为每个服务设置一个工作队列，而无需向两个不同的交易所发送 2 个单独的 events/messages？
Using pub/sub will cause the messages to be processed twice (account) or trice (logistics) if i understand it correctly.
根据您的描述，您可能每个工作人员有 1 个队列，并且您正在将消息路由到所有工作人员队列。因此，每个工作人员都会得到消息的副本，因为您将消息路由到所有队列。
您想要的是单个 "account" 队列和单个 "logistic" 队列。您将从单个帐户队列中读取多个帐户服务；后勤服务/队列也是如此。
设置 prefetch=1 也很重要。这可以防止您一次向单个工作人员读取太多消息。
Is there a way to combine both and have a work queues for each of the service, without sending 2 separate events/messages to two different exchanges?
是 - 不要使用扇出交换。使用主题或直接交换，并使用多个路由键将单个消息路由到帐户和物流队列。
What would be the correct way to ensure that "account" and "logistic" will process the message only once?
没有办法保证这一点，100%。在某些时候，即使像我描述的那样进行了正确的设置，您也会遇到网络故障或工作人员崩溃或其他一些问题，并且一条消息将被处理两次。你必须在你的设计中考虑到这一点，在你的消息处理中使用某种形式的idempotence。
希望对您有所帮助！
我正在评估使用 RabbitMQ 作为消息 queue/message 总线，并且一直在查看 RabbitMQ 页面上的示例 tutorials。
我正在寻找教程未涵盖的特定场景，我不确定是否可以以及如何通过 RabbitMQ 完成。
设置:
假设我有一个服务，我们称它为 "purchase orders" 并且我必须使用其他服务 "logistics" 和 "accounting"。
发送订单时，我想通过 RabbitMQ 将其作为消息发送。
有 2 个 "account" 和 3 个 "logistic" 服务
确保 "account" 和 "logistic" 只处理一次消息的正确方法是什么？如果我理解正确，使用 pub/sub 将导致消息被处理两次（帐户）或三次（物流）。
使用工作队列和 prefetch=1 可以确保只有一个得到它，但我有 2 个服务并希望每种类型的服务都得到一个。
有没有一种方法可以将两者结合起来并为每个服务设置一个工作队列，而无需向两个不同的交易所发送 2 个单独的 events/messages？
Using pub/sub will cause the messages to be processed twice (account) or trice (logistics) if i understand it correctly.
根据您的描述，您可能每个工作人员有 1 个队列，并且您正在将消息路由到所有工作人员队列。因此，每个工作人员都会得到消息的副本，因为您将消息路由到所有队列。
您想要的是单个 "account" 队列和单个 "logistic" 队列。您将从单个帐户队列中读取多个帐户服务；后勤服务/队列也是如此。
设置 prefetch=1 也很重要。这可以防止您一次向单个工作人员读取太多消息。
Is there a way to combine both and have a work queues for each of the service, without sending 2 separate events/messages to two different exchanges?
是 - 不要使用扇出交换。使用主题或直接交换，并使用多个路由键将单个消息路由到帐户和物流队列。
What would be the correct way to ensure that "account" and "logistic" will process the message only once?
没有办法保证这一点，100%。在某些时候，即使像我描述的那样进行了正确的设置，您也会遇到网络故障或工作人员崩溃或其他一些问题，并且一条消息将被处理两次。你必须在你的设计中考虑到这一点，在你的消息处理中使用某种形式的idempotence。
希望对您有所帮助！