如果通道中有多次读取，Netty - fire ReadTimeoutHandler

Question

我的I/O流如下：

< li >客户端向通道发送数据# 1 < li >服务器(处理程序)根据客户端数据从数据库接收数据，并将其发送给客户端 < li >客户端向通道发送数据# 2 < li >服务器(处理程序)根据客户端数据再次从数据库接收数据，并将其发送回客户端，然后关闭通道

如果首次在通道中读取花费的时间太长，则读取超时处理程序将按预期触发异常。但是，如果第一次读取没问题（= 足够快），并且通道中的第二次读取花费的时间太长，则不会引发超时异常，并且处理程序会等待 5 分钟，直到它关闭通道。似乎读取超时处理程序仅适用于通道中的第一个读取。甚至有可能让读取超时处理程序处理通道中的多个读取？

使用的Netty版本：4.0.12

公共类我的服务器 {

private static final class MyInitializer extends ChannelInitializer<SocketChannel> {

...

    @Override
    public void initChannel(SocketChannel channel) throws Exception {
        channel.pipeline().addLast(
                new ReadTimeoutHandler(5, TimeUnit.SECONDS),
                new MyHandler(server, serverConnection));
    }

...

}

}

公共类MyHandler扩展了SimpleChannelInboundHandler{

private static final Logger LOG = LoggerFactory.getLogger(MyHandler.class);

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
    super.channelActive(ctx);
}

@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
    Message message = database.getMessage(msg);
    ChannelFuture operation = ctx.writeAndFlush(message) 

if (message.isEnd()) operation.addListener(new CloseConverstationListener(ctx));
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
    if (cause instanceof ReadTimeoutException) {
        LOG.error("ReadTimeoutException");
    } 
}

@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
    super.channelInactive(ctx);
}

private class CloseConverstationListener implements GenericFutureListener<ChannelFuture> {
    private final ChannelHandlerContext ctx;

    private CloseConverstationListener(ChannelHandlerContext ctx) {
        this.ctx = ctx;
    }

    @Override
    public void operationComplete(ChannelFuture future) throws Exception {
        future.channel().close().sync();
    }
}

}

Answer 1

读取超时处理程序行为是 - 如果在指定的持续时间内通道中未发生读取，它将触发异常并关闭通道。这不是由于响应或处理读取的延迟。在通道开始时读取读取标志设置为 true，当读取完成时，该标志设置为 false。运行调度程序，检查通道是否打开且在指定持续时间内未读取，然后触发异常并关闭连接。

如果首次在通道中读取花费的时间太长，则读取超时处理程序将按预期触发异常。

以上听起来对我不正确。如果您希望基于写入响应的延迟而超时，您可以考虑使用WriteTimeoutHandler。