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();

这就是< code>SO_BACKLOG选项的作用吗？它说它是用于正在排队的连接，但是我对正在为特定连接排队的数据包感兴趣。

Answer 1

如果您的唯一目标是避免缓冲区溢出（背压），则此方法就足够了：

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

Answer 2

这就是SO_BACKLOG选项的作用吗？

这就是SO_BACKLOG选项的作用吗？

上面说是用来连接排队的

对的

但是我对为特定连接排队的数据包感兴趣

所以你对SO_BACKLOG不感兴趣。

Answer 3

执行此操作的一种方法是使用“写入缓冲区水印”。引用爪哇语：

WriteBufferWaterMark用于设置写缓冲区的低水位标记和高水位标记，如果写缓冲区中排队的字节数超过高水位标记，Channel.isWritable（）将开始返回false。如果写缓冲区中排队的字节数超过高水位标记，然后下降到低水位标记以下，Channel.isWritable（）将再次开始返回true。

在您的子通道配置上设置适当的水印，慢速消费者将在“长”时间内标记通道不可写，而不是快速消费者。因此，侦听通道可写状态的变化并跟踪通道不可写的时间量应该可以识别慢速消费者和积压的相对严重程度，然后如果客户端的迟钝达到某个阈值，您可以断开客户端。