リストなしの集約メッセージ

Question

私は春の統合を使用しており、私は10kでメッセージのグループをパックする必要があります。後で10kがもっと大きくなり、永続的なストレージが私の選択ではないので、リストに格納したくない。私は、いくつかのスレッドが1つのスレッドにメッセージを送信して、それらを数え、10k行を含むファイルにディスクに書き込むことを望みます。カウンタが10kに達したら、私はゼロへの新しいファイルセットカウンタを作成します。それは直接チャネルでうまくいくでしょうが、いくつかのスレッド（私は

<int:dispatcher task-executor="executor" /> 

）を使ってメッセージをシングルスレッドに送信する方法を教えてください。ありがとう

Answer 1

QueueChannelでタスクにアクセスできます。どのスレッドもメッセージを同時に送信できます。反対側では、あなたが要求した通りPollingConsumerをfixed-delayポーラー - シングルスレッドに設定してください。つまり、fixed-delayのポーラーと、DirectChannelの下流のすべてのポーラーは、1つのスレッドでのみ実行されます。したがって、カウントとロールオーバのロジックに到達することができます。

これは設定が単純であるため、あなたには表示されません。別のサービスが同じQueueChannelにメッセージを送信します。 fixed-delayポーラーは、シングルスレッド読み取りを保証します。