playframework で tcp フロー制御を自動的にパススルーするようにしようとしているので、バックアップされたクライアントは、サーバー上のリソースを使用せずに、サーバーを介してバックアップをダウンストリームに渡すだけです。ただし、これを行うには、WriteCallback が必要です。これにより、netty を使用してチャンクを書き込むときに、チャンクが実際に書き込まれたときに通知されます。書き込まれていない場合、コールバックは呼び出されず、メモリが少し消費されますが、書き込みが発生するまで、それ以上のリクエストは読み込まれません。
したがって、playframework では、これが Netty ChunkedWriteHandler で呼び出されていることがわかります。
chunkedWriteHandler.resumeTransfer();
本当に必要なのは、コールバックを渡して、書き込みがいつ終了したかを知ることです。これを簡単に達成するための他の方法や方法はありますか?おそらく、これは非常に複雑に見えますが、当分の間 netty を fork して、何らかの方法でコールバックを追加することができます。どんなアイデアでも大歓迎です。
ありがとう、ディーン