spring-integration - 競合する消費者

Question

スプリング統合アプリケーションを構成して、それぞれが1つのメッセージで表される多数のタスクをチャネルに配置すると、エンドポイントのグループの1つが次のタスクを選択して処理するようにします。これには、スレッドプールエグゼキュータサービスが必要になると思います。

Answer 1

はい、チャネル（別名ExecutorChannel）でディスパッチャ+タスクエグゼキュータを使用します。service-activatorそうすれば、チャネルから消費するエンドポイント（たとえば）は、ディスパッチャのスレッドプールを使用して非同期的に呼び出されます。

次の例では、チャネルに到達するメッセージは、いずれかのスレッド内のサービスchannel01によって消費されます。jobLaunchertaskExecutor

<int:channel id="channel01">
    <int:dispatcher task-executor="taskExecutor">
</int:channel>

<task:executor id="taskExecutor" pool-size="2"/>

<int:service-activator input-channel="channel01" ref="jobLauncher">