Nettyサーバー - 遅いコンシューマーのTCPで

Question

Netty v4を使用してTCPサーバーを作成しています。サーバーはクライアントからの複数の接続を処理し、それらにデータをストリームします。

クライアントが低速でデータを消費していることを検出できるようにしたいと考えています。私は基本的にクライアントが遅いためにTCPバッファがいっぱいにならないようにしたい！

これは基本的にZeroMQの機能です（「低速加入者検出（自殺カタツムリパターン）」と呼ばれています）。 Nettyを使ってどうすればいいですか？

私の現在のコードは、（私は、サーバーのセットアップを単に紹介します）です：

 ServerBootstrap b = new ServerBootstrap(); 
     b.group(bossGroup, workerGroup) 
      .channel(NioServerSocketChannel.class) 
      .option(ChannelOption.SO_BACKLOG, 1000) 
      .handler(new LoggingHandler(LogLevel.INFO)) 
      .childHandler(new ChannelInitializer<SocketChannel>() { 
      @Override 
      public void initChannel(SocketChannel ch) throws Exception { 
       ChannelPipeline p = ch.pipeline(); 
       p.addLast(new Handler()); 
      } 
      }); 

     ChannelFuture f = b.bind(8000).sync(); 
     f.channel().closeFuture().sync(); 

は義和SO_BACKLOGオプションがないことですか？それは接続がキューに入れられていることを示していますが、特定の接続に対してキューに入れられるパケットに興味があります。

Answer 1

これを行う方法は、WriteBufferWaterMarkを使用することです。 Javadocから引用：

WriteBufferWaterMarkは、ライトバッファのための低ウォーターマークと高ウォーターマーク を設定するために使用されています。書き込み バッファにキューイングされたバイト数が最高水準点を超えると、Channel.isWritable（）は falseに戻ります。書き込みバッファーにキューイングされたバイト数が最高水準点を超えてから、水位が低い水位 に下がった場合、Channel.isWritable（）は再び真を返すようになります。

子供のチャンネルconfigsに適切なウォーターマークを設定すると、遅い消費者は、「長い」時間の間書き込みができないチャネルを、うっとりする消費者に対してマークします。したがって、チャネルの書き込み可能状態の変化をリッスンし、チャネルが書き込み不能な時間を追跡すると、低速のコンシューマとバックログの相対的な重大度を識別し、低速がある閾値に達した場合にクライアントを切断できます。

Answer 2

SO_BACKLOGオプションは何ですか？

SO_BACKLOGオプションは何ですか？

それは

正しいをキューに登録されている接続のためだと言います。

が、私はあなたがSO_BACKLOGに興味を持っていない特定の接続

のためにキューイングされるパケットに興味があります。

Answer 3

はケースで、あなたの唯一の目標は、このアプローチは十分だろうバッファオーバーフロー（背圧）を避けるためです：

if (ctx.channel().isWritable()) { 
    ctx.writeAndFlush(msg); 
}