小编use*_*201的帖子

Netty简单通道处理程序断开连接被阻止

My Netty频道处理程序channelClosed ()被阻止,而另一条消息正在接收messageReceived().
我用于OrderedMemoryAwareThreadPoolExecutor同步消息.
channelClosed()由低优先级线程处理?

你能告诉netty中的线程优先级吗?谢谢

    objChannelPipeline.addLast("ipFilter", objCustomIPFilterHandler);
    objChannelPipeline.addLast("idleHandler", new IdleStateHandler(timer,5,5, 0));
    objChannelPipeline.addLast("loggingHandler", objLoggingHandler);        
    objChannelPipeline.addLast("frameDecoder",
            new DelimiterBasedFrameDecoder(Integer.MAX_VALUE, false, ChannelBuffers.copiedBuffer("\n\n".getBytes(CharsetUtil.UTF_8))));
    objChannelPipeline.addLast("messageDecoder", new CustomMessageDecoder());
    objChannelPipeline.addLast("groupOrder", executionHandler);
    objChannelPipeline.addLast("ProtocolMultiplexer", CustomHandler);
Run Code Online (Sandbox Code Playgroud)

java netty

5
推荐指数
1
解决办法
591
查看次数

标签 统计

java ×1

netty ×1