我想写一个udp服务器。我配置我的这样引导:为什么netty只使用一个线程?
ChannelFactory factory = new NioDatagramChannelFactory(Executors.newCachedThreadPool());
ConnectionlessBootstrap bootstrap = new ConnectionlessBootstrap(factory);
bootstrap.setPipelineFactory(new UDPServerPipelineFactory());
bootstrap.setOption("sendBufferSize", 1048576*2);
bootstrap.setOption("receiveBufferSize", 1048576*2);
bootstrap.setOption("tcpNoDelay", true);
bootstrap.setOption("receiveBufferSizePredictorFactory", new AdaptiveReceiveBufferSizePredictorFactory(1048576, 1048576, 2000000));
bootstrap.bind(new InetSocketAddress(11000));
Pipline这样:
@Override
public ChannelPipeline getPipeline() throws Exception
{
ChannelPipeline pipeline = Channels.pipeline();
pipeline.addFirst("execution-handler", new ExecutionHandler(new OrderedMemoryAwareThreadPoolExecutor(16, 2333444, 3444333)));
pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("counter", new UDPHandler());
return pipeline;
}
但我总是UDPHandler一个线程仅管理。我究竟做错了什么?
请问您可以添加'jstack'输出吗? – ericson 2013-02-28 14:39:34
感谢您的回复。最后我发现有多个线程。我很困惑,因为他们很少变化,对我来说就像一条线。我的错。 – Moses 2013-02-28 14:50:51