DefaultMessageListenerContainer concurrentConsumers

Question

複数のconcurrentConsumersを持つDefaultMessageListenerContainerについて質問がありますが、コンテナはコンシューマごとに異なるセッションを作成しますが、私の問題はコンテナがすべてのコンシューマ間で1つのメッセージリスナーインスタンスしか共有できないことです各スレッドがリスナーが使用可能になるのを待つため、並行して処理します。各コンシューマに、メッセージを処理するためのメッセージリスナーの排他的インスタンスを持たせることはできません。

Answer 1

コンテナは、スレッドセーフ（ステートレス）リスナー、つまり保護されていないグローバル状態で使用するように設計されています。

状態を保護するために​​を使用するように聞こえます。これにより、一度に1つのリスナースレッドしか許可されません。

リスナーBeanをスレッドセーフにすることができない場合は、複数のコンテナを使用する必要があります。それぞれ異なるリスナーBean（プロトタイプスコープを使用できるため、コンテナごとに独自のBeanを取得できます）を使用する必要があります。