java - 在读取超时时写入 channel

Question

每当我发现 Reader Idle 超时时，我都想写超时错误。

public class TimeOutHandler extends IdleStateAwareChannelHandler {

      @Override
         public void channelIdle(ChannelHandlerContext ctx, IdleStateEvent e) {
             if (e.getState() == IdleState.READER_IDLE) {
                 System.out.println("Reader TimeOut");
                    HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
                    response.setHeader(Names.CONTENT_TYPE, "application/json; charset=UTF-8");
                    response.setContent(ChannelBuffers.copiedBuffer("{\"timeout\":true}", CharsetUtil.UTF_8));
                     ChannelFuture future = e.getChannel().write(response);
                     future.addListener(ChannelFutureListener.CLOSE);
             } 
         }
}

处理程序正在工作，但没有任何内容写入 channel 。这种情况可能吗？

更新:

我的管道工厂:

public class AsyncServerPipelineFactory implements ChannelPipelineFactory {

    static HashedWheelTimer timer = new HashedWheelTimer();

    private final ChannelHandler idleStateHandler = new IdleStateHandler(timer, 10, 20, 0);
    public ChannelPipeline getPipeline() throws Exception {
        ChannelPipeline pipeline = Channels.pipeline( idleStateHandler,new TimeOutHandler());
     pipeline.addLast("decoder", new HttpRequestDecoder());
     pipeline.addLast("encoder", new HttpResponseEncoder());
     pipeline.addLast("handler", new HTTPRequestHandler());
    return pipeline;
    }
}

Answer 1

您的管道配置错误。任何写入 HttpResponse 的处理程序都必须插入到您的 HttpResponseEncoder 之后。例如

 ChannelPipeline pipeline = Channels.pipeline();
 pipeline.addLast("idler", idleStateHandler);
 pipeline.addLast("decoder", new HttpRequestDecoder());
 pipeline.addLast("encoder", new HttpResponseEncoder());
 pipeline.addLast("timer-outer", new TimeOutHandler());
 pipeline.addLast("handler", new HTTPRequestHandler());