低速クライアントでNettyサーバーを抑制する方法は？

Question

クライアントがACKを正しく読み込めないときにriemannサーバのOOMEを防ぐために、クライアントがパケットをすばやく読み込み/ ACKすることが原因であると仮定して、書き込みが不可能になったときにチャネルを閉じるためにsome logicを実装しました。

しかし、これは、おそらくサーバーがTCP経由で送信できるよりも速く結果を書き込もうとしているため、大きなishクエリ結果を送信するときにチャネルを閉じます。私の頭の上から、この状況を処理する最善の方法は、WriteTimeoutHandlerを使用して、書面でタイムアウトを設定することだと思います。

このケースを処理するために、nettyには既知の標準パターンがありますか？

Answer 1

基本的には、Channel.isWritable()がfalseを返し、再び真を返すと再び書き込みを開始します。 ChannelInboundHandler.channelWritabilityChanged(...)を無効にすることで、これを更新して通知することができます。