Netty - 如果通道中有多个读取，则触发 ReadTimeoutHandler

Question

我的 I/O 流程如下：

1. 客户端向通道发送数据#1
2. server(handler)根据客户端数据从数据库接收数据并发送给客户端
3. 客户端将数据#2 发送到通道
4. server(handler)根据客户端数据再次从数据库中接收数据并发送回客户端并关闭通道

如果第一次读取通道时间过长，ReadTimeoutHandler 会按预期触发异常。但是，如果第一次读取正常（= 足够快）并且第二次读取通道花费的时间太长，则不会抛出 TimeoutException 并且处理程序等待 5 分钟直到它关闭通道。似乎 ReadTimeoutHandler 仅适用于通道中的第一次读取。是否有可能让 ReadTimeoutHandler 在通道中进行多次读取？

使用的 Netty 版本：4.0.12

公共类 MyServer {

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

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

如果第一次读入频道时间过长，ReadTimeoutHandler 会按预期触发异常。

以上对我来说听起来不正确。 如果你想根据写响应的延迟来超时，你可以考虑 WriteTimeoutHandler。