2013-02-28 25 views
1

我想写一个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一个线程仅管理。我究竟做错了什么?

+0

请问您可以添加'jstack'输出吗? – ericson 2013-02-28 14:39:34

+0

感谢您的回复。最后我发现有多个线程。我很困惑,因为他们很少变化,对我来说就像一条线。我的错。 – Moses 2013-02-28 14:50:51

回答

0

你没有做错任何事。看起来Netty UDP只使用一个线程来处理请求。还有一个issue就此报道。

您最好创建一个ExecutorService以在接收请求后执行您的业务逻辑。

相关问题