次の構成のRabbitMQセットアップがあります。
- 各取引所は
FANOUTタイプ - 各 Exchange に接続された複数のキュー。
BlockingConnection消費者によって作られます。- すべてのコールバックを処理する単一のコンシューマー。
問題 -
一部のペイロードは他のペイロードよりも処理に時間がかかるため、他のキューにペイロードがある場合でも、コンシューマーはアイドル状態のままになります。
質問 -
- 長い待ち時間を避けるために、コンシューマーをどのように実装すればよいですか? モジュールごとに個別のコンシューマーを実行する必要がありますか? ユーザーエクスペリエンスはありますか？
- これらの状況を処理するように RabbitMQ を構成できますか? もしそうなら、どのように。