のRabbitMQ：ディスパッチャ私は多くのタスクが含まれているのRabbitMQを経由してメッセージを配布しようとしています多くのタスク

Question

を含むメッセージのために：

Producer --> RabbitMQ Exchange --> 10 Consumers 

例えば： ユーザーは、1000の作業が含まれている交換機へメッセージを送信します。取引所は、最短の待ち行列を有する消費者にタスクを均等に分配する必要がある。

RabbitMQで使用されるキューイングメカニズムについての知識がないため、注文をタスクに分割してコンシューマキューに配布するためのカスタムロジックが必要です。

これはどのように行われますか？あなたが単一のキューを使用し、そのキューとレバレッジConsumer Prefetch (QoS)に接続された複数の消費者を持っていた場合（私は生産者と消費者の両方でPython /ピカを使用しています。）

Answer 1

それはずっと簡単に聞こえます。この方法で、そのキューに1000個のメッセージを送信し、使用可能なコンシューマにメッセージを受け取らせることができます。

消費者プリフェッチ（QoS）は、基本的に、コンシューマがプリフェッチするメッセージの数を設定できることを意味します。例として、これを1に設定すると、pikaは一度に1つのメッセージをフェッチして処理し、他のコンシューマーに他の999メッセージを消費し処理する機会を与えます。