RabbitMQ：タスクキューとファンアウト/ルーティング/トピックモデルを結合する方法は？

Question

私は1人のプロデューサーと多数の消費者を持つ環境を持っています。

1. のみONE消費者によって処理される必要があるメッセージ（任意の消費者が行います）：
   プロデューサは、メッセージの2種類を作成します。
2. すべてのコンシューマが処理する必要があるメッセージ。

これはどのように実装できますか？
メッセージタイプ1では、作業キューが適切なモデルです。
メッセージタイプ2では、ファンアウト/ダイレクト/ルーティング/トピックが適しています。
どうすれば組み合わせることができますか？

Answer 1

RabbitMQは非常に柔軟性があり、要件を満たすためのさまざまな交換とキューの設計ソリューションがあります。

しかし、まず、私たちはキューと消費者との関係や、基本的なルールを理解しておく必要があります

• メッセージタイプが唯一のすべての消費者のによって消費されるようにしたい場合は、あなたが言ったように、あなたが必要ワーカーキューには、すべてのコンシューマーがそれにサブスクライブする必要があります。
• コンシューマごとにメッセージタイプを使用する場合は、コンシューマごとにキューを用意する必要があり、各コンシューマは独自のキューにのみサブスクライブします。

上記の理解に基づいてキューの数が明確な場合。残りのものは、メッセージをこれらのキューにルーティングする方法です。多くのソリューションがあります。以下はいくつかの例です。

1つの実行可能な解決策は、メッセージタイプごとに1つずつ、2つの交換を作成することです。

| message type | exchange name | exchange type | bound queues  | 
|------------------------------------------------------------------| 
| type_1  | exchange1  | fanout  | shared_queue  | 
| type_2  | exchange2  | fanout  | queue1,queue2,... | 

あなたに2つのメッセージタイプを公開するための唯一の交流を持つようにしたい場合は、別の可能な解決策は、ある、「直接」交換タイプを使用します。

| routing_key | binding_key | bound queues  | 
|-----------------------------------------------| 
| type_1  | type_1  | shared_queue  | 
| type_2  | type_2  | queue1,queue2,... | 

一つの交換がにバインドされた複数のキューを持っている可能性を同じバインディングキーを使用しています。したがって、パブリッシュルーティングキー（type_1）を使用してメッセージタイプ1をパブリッシュする場合、shared_queueだけがメッセージを受信します。パブリッシュルーティングキー - 「type_2」を使用してメッセージタイプ2をパブリッシュすると、すべてのqueue1、queue2、...がメッセージを受信します。

メッセージごとに異なるバインディングキーを使用すると、より多くのメッセージタイプがあり、同じルーティングキーを使用したくない場合に、実際のケースには適していない可能性があります。その場合は、代わりに「トピック」交換タイプを使用することをおすすめします。

| routing_key | binding_key | bound queues  | 
|-----------------------------------------------| 
| type_1.1 | type_1.* | shared_queue  | 
| type_2.2 | type_2.* | queue1,queue2,... | 

Answer 2

直接ルーティングとファンアウトルーティングは、RabbitMQエクスチェンジのプロパティです。すべてのRabbitMQメッセージは、キューに直接送信されるのではなく、エクスチェンジに公開されます。エクスチェンジを明示的に作成せずにキューを作成して使用する場合、実際には既定の既定の交換が使用されます。

1つのRabbitMQブローカに複数の交換を作成し、1つのキューを複数の交換にバインドすることができます。ワーカーが両方のメッセージタイプに同じキューを使用するようにするには、直接交換（メッセージタイプ1の場合）とファンアウト交換（メッセージタイプ2の場合）を作成し、各キューを両方の交換にバインドします。それ以外の場合は、各交換タイプごとに別々のキューを作成できます。

RabbitMQのAMQP concept guideには交換とキューの説明があり、RabbitMQ Getting Startedのチュートリアル3には、交換の作成とバインド方法が示されています。