問題タブ [reactor-netty]

私の Spring webflux コントローラーは、リモート TCP サーバーにアクセスする必要があります。TCP サーバーからクライアントへの応答をストリーミングするにはどうすればよいですか?

何かのようなもの：

ただし、(WebClient ではなく) TcpClient を使用します。

ありがとう、

--ニック

HttpClient から 1024 バイトを超えるデータを送信する Reactor-Netty HttpServer があります。

クライアントでは、データを最終的に解析できる文字列に連結するという考えで、リクエストのさまざまな部分を Flux で取得します。私はこれが HttpObjectAggregator によって行われた可能性があるという意見でしたが、残念ながら違います。

クライアントがコンテンツを受け取ると、次のようになります。

DefaultHttpContent(データ: PooledSlicedByteBuf(ridx: 1024、widx: 1024、キャップ: 1024/1024、アンラップ: PooledUnsafeDirectByteBuf(ridx: 1024、widx: 1024、キャップ: 1024))、decoderResult: 成功)

と

DefaultLastHttpContent(データ: PooledSlicedByteBuf(ridx: 98、widx: 98、キャップ: 98/98、アンラップ: PooledUnsafeDirectByteBuf(ridx: 98、widx: 98、キャップ: 1024))、decoderResult: 成功)

バイトを「抽出」しようとすると、それらが利用できないことがわかります。

サーバ

クライアント

どうすればデータを取得できますか？

データはコンソールに記録されます。例:

98B +------------------------------------------------ -+ | 0 1 2 3 4 5 6 7 8 9 abcdef | +--------+-------------------------------------------- ------+----------------+ |00000000| 54 68 61 6e 31 30 32 34 62 79 74 65 73 6d 6f 72 |Than1024bytesmor| |00000010| 65 54 68 61 6e 31 30 32 34 62 79 74 65 73 6d 6f |eThan1024bytesmo| |00000020| 72 65 54 68 61 6e 31 30 32 34 62 79 74 65 73 6d |reThan1024bytesm| |00000030| 6f 72 65 54 68 61 6e 31 30 32 34 62 79 74 65 73 |oreThan1024bytes| |00000040| 6d 6f 72 65 54 68 61 6e 31 30 32 34 62 79 74 65 |moreThan1024byte| |00000050| 73 6d 6f 72 65 54 68 61 6e 31 30 32 34 62 79 74 |smoreThan1024byt| |00000060| 65 73 |es | +--------+-------------------------------------------- ------+----------------+ | | +--------+-------------------------------------------- ------+----------------+ | | +--------+-------------------------------------------- ------+----------------+

ありがとう

デフォルトでは、Spring Web Flux はシングル スレッドのイベント ループである netty を使用します。コアごとにスレッドが作成されるようにスプリング ブートを構成する方法。

ありがとう、

ロケシュ