网络超时后频道未关闭答案

【问题标题】：Channel not closing after timeout in netty网络超时后频道未关闭
【发布时间】：2019-03-29 15:55:13
【问题描述】：

当频道在特定秒后没有收到任何数据时，我想关闭频道。我尝试了 IdleHandler，但它不起作用。我的主要处理程序是扩展 SimpleChannelInboundHandler 的 clientHandler。这以字符串形式发送数据并以字符串格式接收数据。有时，我希望我的频道在特定超时后关闭，但目前它正在等待来自服务器的数据。

另一个观察结果是，当我检查数据包发送者以验证相同的请求时。我从服务器收到空响应，但我的 ClientHandler 没有收到此响应。

以下是代码。

clientBootstrap.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch){
                    ch.pipeline()
                            .addLast(new IdleStateHandler(5, 5, 10))
                            .addLast(new MyHandler())
                            .addLast(new ClientHandler(cardIssueRequest,promise));
                }
            });

我的处理程序：

public class MyHandler extends ChannelDuplexHandler {
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent e = (IdleStateEvent) evt;
            if (e.state() == IdleState.READER_IDLE) {
                ctx.close();
            } else if (e.state() == IdleState.WRITER_IDLE) {
                ctx.close();
            }
        }
    }
}

客户端处理程序：

public  class ClientHandler extends SimpleChannelInboundHandler {

    RequestModel request;
    private final Promise<String> promise;

    public ClientHandler(RequestModel request, Promise<String> promise) {
        this.request = request;
        this.promise = promise;
    }

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, Object o) {
        String response = ((ByteBuf) o).toString(CharsetUtil.UTF_8);
        log.info("Client received: " + response);
        promise.trySuccess(response);
    }

    @Override
    public void channelActive(ChannelHandlerContext channelHandlerContext) {
        log.info("Client sent: " + request);
        channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer((request.toString()), CharsetUtil.UTF_8));
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext channelHandlerContext, Throwable cause) {
        cause.printStackTrace();
        channelHandlerContext.close();
        promise.setFailure(cause);
    }
}

【问题讨论】：

标签： java sockets asynchronous netty

【解决方案1】：

在进行线程转储后，我发现问题是我的程序在 promise 语句中等待。因此，在为承诺设置超时后，我的问题得到了解决。

promise.get(60, TimeUnit.SECONDS)

【讨论】：