1

競合する消費者を完全に動的に保つにはどうすればよいですか?
Camel 実装は、concurrentConsumers 値を要求しています。しかし、新しいコンシューマーが起動し、送信者メッセージの消費を開始したとしましょう。では、同時消費者の数をどのように数えますか?

4

1 に答える 1

2

JMS コンシューマについて話していると仮定します...

その場合、concurrentConsumers と maxConcurrentConsumers を設定して、アクティブなコンシューマー スレッドの数を需要に基づいて増減させることができます。このようなものは、ルートを明示的にセットアップします...

from("activemq:queue:input?concurrentConsumers=1&maxConcurrentConsumers=5")
.to("log:+++consumed+++");

つまり、同じリソース (入力キュー) から消費を開始する他のルート (または Spring JMSTemplates などのルート以外のコンシューマー) がある場合、コンシューマーの合計数ははるかに多くなる可能性があります...

AMQ Web コンソールまたは JMX を介して、アクティブなコンシューマーの総数をいつでも表示できます。

于 2012-05-31T22:02:15.127 に答える