私たちは、Spring AMQPを使用してrabbitmqからメッセージを受け取るJavaアプリケーションを持っています。 一部のキューでは、コンシューマの数が増えていないため、メッセージの配信速度が遅くなります。例: たとえ最大消費者が50に設定されていても、9000メッセージの負荷のために消費者の数はほとんどの場合6でした。RabbitMQコンシューマが追加されない
ただし、これは他のキューでは該当しません。私は消費者数が35に達するまで待ちました。
SimpleMessageListenerContainerのsetMaxConcurrentConsumers APIを使用して、最大コンシューマを設定しています。
誰か理解してもらえますか?
構成:同時消費者の
数:最大同時消費者の4
数:50
返信いただきありがとうございますゲーリー!私は使用している設定で質問を更新しました。キューに9000個のメッセージがあると、メッセージ配信率を高めるために消費者を増やしてはいけませんか? 6人の消費者では、配送料は0.60/sでした。各消費者が0.10/s(1msg/10sec)で出荷していると仮定できますか? これで、メッセージはキューに蓄積されていました。 とにかく、DEBUGレベルをオンにしてこのシナリオを再現しようとします。 –