Spring Integrationポーリングなしの待ち行列でlistenする

Question

HTTPリクエストをリッスンするSpring Integrationを使用してHTTPエンドポイントを実装し、要求データをメッセージとしてチャネルに送信し、別のエンドポイントがこのチャネルのメッセージをリスンして処理する必要があります。

簡単な音です。しかし、私が達成したいのは次のとおりです。

1. メッセージは順番に処理する必要があります。
2. メッセージは早急に処理する必要があります（キューがすでに空の場合は、http要求後に遅延なし）。
3. httpリクエストは、メッセージが受信されるとすぐに応答され、処理された後ではないため、処理のためにそのメッセージのみが受信されます。
4. 私はRabbitMQのような外部キューを使いたくありません。

ですので、これにはQueueChannelが必要です。しかし、正しく理解すれば、キューからメッセージを受信する唯一の方法はpollerです。したがって、ポイント2は満たされません。メッセージが受信された後、ポーラーがそれを見る前に少し遅れるでしょう。

質問があります：Spring Integrationでこれを達成するための簡単な方法はありますか？

もちろん私はそれを自分で実装することができます。たとえば、SmartLifeCycleコンポーネントを作成します。これは、DirectChannelをリッスンし、メッセージをjava.util.concurrent.BlockingQueueに入れるだけです。また、このキューで待機して別のDirectChannelにメッセージを送信する専用スレッドを開始します。したがって、BlockingQueueが空でないとすぐにスレッドがブロック解除されるため、遅延はありません。

これはすべて「パターン」のように聞こえます。専用のスレッドに基づく2つのダイレクトチャネル間のキューです。

おそらくSpring Integrationで既に実装されている単純な方法がありますが、これはこの領域にはexpirienceがないため表示されません。

Answer 1

ポーラーを使用してもポイント2を満たすことができます。ちょうどfixed-delayを0に設定したり、受信タイムアウトを大きくする（デフォルトは1秒）。ポーラー・スレッドは、メッセージが到着するまでキュー内でブロックします。すぐにもう一度待ってください。

executorチャネルを使用することもできます（httpスレッドはexecutorスレッドにハンドオフします）。