AMQP/RabbitMQ的 - 如何避免競爭條件

Question

我有以下結構： Architecture

• 有輸入源的固定數量。每個輸入源都是等效的。
• AMQP經紀人。我在使用RabbitMQ。
• 目前，有2個消費者。同樣，每個消費者都是相同的。

輸入源正在發送要處理的命令。這些命令由經紀人轉發，並由兩位消費者中的一位提取。

我需要以下行爲：

• 如果一個輸入源發送多個命令，所有命令必須被順序地處理。也就是說，在2個命令的示例中，當消費者2同時處理命令2時，消費者1正在處理命令1的是不允許。
• 但是，可以同時處理源自兩個不同輸入源的兩個命令。

是否可以用AMQP/RabbitMQ強制執行此行爲？

Answer 1

您可以爲每個隊列使用一位消費者來覆蓋您的方案。 每個隊列都可以按順序處理消息。

另一種方式是僅使用一個隊列，並使用envelope.getExchange()瞭解源，或tag使用AMQP.BasicProperties properties

這樣你的消息，例如，你可以消耗多線程的消息和分配每個線程一個線程tag

Answer 2

爲了保證順序，您可能需要聚合消息。在發佈到隊列之前，您可以將來自一個源的命令批量處理爲消息，因此消息進入隊列可以包含一個或多個將由消費者執行的命令。