2016-09-30 14 views
0

私たちは、Spring AMQPを使用してrabbitmqからメッセージを受け取るJavaアプリケーションを持っています。 一部のキューでは、コンシューマの数が増えていないため、メッセージの配信速度が遅くなります。例: たとえ最大消費者が50に設定されていても、9000メッセージの負荷のために消費者の数はほとんどの場合6でした。RabbitMQコンシューマが追加されない

ただし、これは他のキューでは該当しません。私は消費者数が35に達するまで待ちました。

SimpleMessageListenerContainerのsetMaxConcurrentConsumers APIを使用して、最大コンシューマを設定しています。

誰か理解してもらえますか?


構成:同時消費者の
数:最大同時消費者の4
数:50

答えて

0

このような質問をするとき、あなたは常に設定を示さなければなりません。詳細を記入して質問を編集してください。

これは設定によって異なります。デフォルトでは、新しいコンシューマは10秒に1回しか追加されません。また、既存のコンシューマがギャップなしで10個のメッセージを受信した場合にのみ追加されます。

まだ質問に答えられない場合は、DEBUGログを有効にしてください。それを理解できない場合は、pastebinやdropboxのような場所にログを投稿してください(少なくともstartConsumerMinIntervalミリ秒をカバーしてください)。

+0

返信いただきありがとうございますゲーリー!私は使用している設定で質問を更新しました。キューに9000個のメッセージがあると、メッセージ配信率を高めるために消費者を増やしてはいけませんか? 6人の消費者では、配送料は0.60/sでした。各消費者が0.10/s(1msg/10sec)で出荷していると仮定できますか? これで、メッセージはキューに蓄積されていました。 とにかく、DEBUGレベルをオンにしてこのシナリオを再現しようとします。 –

関連する問題