博客

设置SocketChannel

    private static final long MILLISECONDS=4*1000L;//超时时间
                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                        ChannelPipeline pipeline = ch.pipeline();           

                        pipeline.addLast(new ReadTimeoutHandler(MILLISECONDS,TimeUnit.MILLISECONDS));//读取超时 在设置时间内没有读取操作 
                        pipeline.addLast(new WriteTimeoutHandler(MILLISECONDS,TimeUnit.MILLISECONDS));//写入超时 在设置时间内没有写入操作 
                }