私はakkaストリームを学んでいますが、明らかにそれはあらゆるストリーミングフレームワークに関連しています:)
akkaのドキュメントを引用：
Reactive Streams は、損失、バッファリング、またはリソースの枯渇なしに非同期境界を越えてデータを移動する方法の一般的なメカニズムを定義するためのものです。
さて、私が理解していることは、ストリームの前まで、たとえばhttpサーバーを例にとると、リクエストが来て、受信者がリクエストを終了したときに、来ている新しいリクエストがバッファに収集されるということですは待機中のリクエストを保持しますが、このバッファのサイズが不明であるという問題があり、ある時点でサーバーが過負荷になると、待機していたリクエストが失われる可能性があります。
そのため、ストリーム処理が開始され、制御可能になるようにこのバッファーが制限されました...そのため、並べたいメッセージ (私の例では要求) の数を事前に定義でき、一度にそれぞれを処理できます。
私の質問ですが、サーバーのソースが最大で 3 つのメッセージを持つことができるように実装すると、4 番目の ID が来るとどうなりますか?
つまり、別のサーバーが私たちに電話をかけてきて、私たちはすでに 3 つのリクエストを処理しているということです...彼のリクエストはどうなりますか?