了解netty通道缓冲区和水印

Question

我试图理解netty缓冲区和水印。

作为一个测试用例，我有一个netty服务器，它向客户端写入数据，客户端被阻塞（每次读取之间的睡眠时间基本上为10秒）

>

它是否正在写入操作系统或TCP缓冲区，netty通道是否也有内部缓冲区？如果是这样，我如何配置它？

我跟踪bytesBeforeUnWritable，但它们似乎没有减少

代码如下：

@Override
    public void channelRead(final ChannelHandlerContext ctx, Object msg) {

        if (server2OutboundChannel.isActive()) {
            if(server2OutboundChannel.isWritable()) {
                server2OutboundChannel.writeAndFlush(msg).addListener(new ChannelFutureListener() {
                    @Override
                    public void operationComplete(ChannelFuture future) {
                        if (future.isSuccess()) {
                            // was able to flush out data, start to read the next chunk
                            //System.out.println(server2OutboundChannel.bytesBeforeUnwritable());
                            ctx.channel().read();
                        } else {
                            future.channel().close();
                        }
                    }
                });
            }else{
                System.out.println("Channel is no longer writeable");
                System.out.println(server2OutboundChannel.bytesBeforeUnwritable());
                System.out.println(server2OutboundChannel.bytesBeforeWritable());
            }
        }
    }

使用端到端源代码重新创建的详细步骤：

>

具体来说，代理代码如下：

<代码>https://github.com/nipunarora/nettyDuplicator/tree/master/src/main/java/org/columbia/parikshan/proxy

>

编译和构建：

mvn包

启动服务器

sh脚本/服务器。sh 3380

启动netty代理

sh脚本/nettyProxy.sh-l0.0.0.0:3379-o127.0.0.1:3380

启动客户端

sh脚本/客户端。sh 127.0.0.1 3379

将“hello”作为std输入发送到客户端

一段时间后发送的netty块和bytesTillUnwritable不会减少。




Answer 1

匿名用户

这些数据在哪里写入？netty的flush（）中也会有流量控制吗？

数据进入了ChannelOutboundBuffer。没有像tcp那样的流控制。数据将保存在ChannelOutboundBuffer中，直到tcp的发送缓冲区中有空间为止。

它是否正在写入操作系统或TCP缓冲区，netty通道是否也有内部缓冲区？如果是这样，我如何配置它？

Netty具有ChannelOutboundBuffer，它在将数据发送到操作系统缓冲区之前保留数据。你可以像下面那样配置它。

    Bootstrap bootstrap = new Bootstrap();
    bootstrap.option(ChannelOption.SO_RCVBUF, soRcvBufSize);
    bootstrap.option(ChannelOption.SO_SNDBUF, soSndBufSize);
    bootstrap.option(ChannelOption.WRITE_BUFFER_HIGH_WATER_MARK, writeBufferHighWaterMark);

我跟踪bytesBeforeUnWritable，但它们似乎没有减少

我编写了一个示例代码，服务器将其写入被阻止的客户端

您的代理的自动读取为falsenettyproxy前端处理程序#channelRead仅在ctx.channel（）时调用。read（）（在未来的侦听器中）被调用。监听器将在writeAndFlush完成后调用writeAndFlush将生成一个任务，当消息写入操作系统的缓冲区时，该任务将完成。如果操作系统的缓冲区已填充，则任务将被阻止。netty的缓冲区不可能不可写，它始终是可写的。

默认的高低水印是什么？我没有在我的应用程序中设置任何东西。有什么方法可以代替它吗？

您可以在DefaultChannelConfig中检查defualt水印-

 /**
 * Returns {@code true} if and only if the I/O thread will perform the
 * requested write operation immediately.  Any write requests made when
 * this method returns {@code false} are queued until the I/O thread is
 * ready to process the queued write requests.
 */
boolean isWritable();