Netty UDP服务器中不并发执行的线程

Question

ExecutorService threadPool = Executors.newCachedThreadPool();

然后是数据报通道、pipelineFactory和Bootstrap：

int workerCount = 10;
DatagramChannelFactory datagramChannelFactory = new NioDatagramChannelFactory(threadPool, workerCount);
ChannelPipelineFactory pipelineFactory = new SNMPTrapsPipeLineFactory();

ConnectionlessBootstrap bootStrap = new ConnectionlessBootstrap(datagramChannelFactory);
bootStrap.setPipelineFactory(pipelineFactory);
bootStrap.bind(new InetSocketAddress(host, port));

在pipelineFactory中，getPipeline()添加自定义处理程序。

就像中所说的：UDP消息的多线程处理

然后我根据这些条目修改了一些代码。现在创建线程池的条件是：

int corePoolSize = 5;
ExecutorService threadPool = new OrderedMemoryAwareThreadPoolExecutor(corePoolSize, 1048576, 1048576);

和ExecutionHandler的pipelineFactory：

ExecutionHandler executionHandler = new ExecutionHandler(threadPool);
ChannelPipelineFactory pipelineFactory = new SNMPTrapsPipeLineFactory(executionHandler);

getPipeline（）添加处理程序，如所描述的：

public class SNMPTrapsPipeLineFactory implements ChannelPipelineFactory {

    private ExecutionHandler executionHandler = null;

    public SNMPTrapsPipeLineFactory(ExecutionHandler executionHandler) { 
        this.executionHandler = executionHandler;
    }

    @Override
    public ChannelPipeline getPipeline() throws Exception {

        ChannelPipeline pipeline = Channels.pipeline();
        pipeline.addFirst("ExecutorHandler", executionHandler);

        // Here the custom handlers are added
        pipeline.addLast( ... )
    }

但它们不同时处理。messageReceived（）下的处理必须在一个线程上完成，下一个线程才能处理下一个消息。我从不同的客户机向服务器发送了大量的消息，而我得到的日志并不是交错的。我还尝试在messageReceived（）中使用thread.sleep（）来确认前面的内容。

我是不是漏掉了什么？有没有办法用Netty实现真正的多线程UDP服务器？如何让不同的线程并发执行messageReceived（）？

Answer 1

根据我的经验和我对使用UDP的Netty的理解，只有一个线程处理UDP消息进行解码是正常的。由于UDP是无会话的，因此只有一个线程可以在一个UDP端口上接收数据并对其进行解码。

一旦解码了数据并将其包装到缓冲区或特定java对象中，就可以将该对象放入将处理它的线程池（执行处理程序->您的业务处理程序）。然后，一旦将先前解码的数据释放到执行处理程序中，就可以解码UDP端口上即将出现的新数据。

创建NioDatagramChannelFactory时可以指定的池线程仅在侦听多个端口上的数据时才使用。每个端口只有一个线程是有意义的。即使在该构造函数中指定了100个工作者，如果配置了一个UDP端口，也只会使用一个工作者。