JBoss Netty и UDP: многопоточность?

Question

Я написал простой UDP-сервер, используя Netty. Сервер прослушивает один порт на определенном интерфейсе.

ChannelFactory factory = 
      new NioDatagramChannelFactory(
        Executors.newCachedThreadPool()); 

ConnectionlessBootstrap bootstrap = new ConnectionlessBootstrap(factory); 

bootstrap.getPipeline().addLast("MyHandler", new TestHandler()); 

bootstrap.bind(new InetSocketAddress(InetAddress.getByName("192.168.1.100"), 8080)); 

Я использую клиент, который отправляет на сервер много дейтаграмм UDP. Когда я просматриваю свое приложение с помощью VisualVM, я вижу, что есть только один поток (с именем New I/O worker # 1), который обрабатывает входящие сообщения. Это так, как ожидалось?

Если да, то как один поток может обрабатывать большое количество входящих сообщений? Я уже написал приложение с интеграцией Spring, которое прослушивает порт для датаграмм UDP (с использованием адаптера входящего канала UDP), и есть один поток, который прослушивает порт, но этот поток передает входящие сообщения для обработки другим потокам бассейн.

Благодаря

Answer 1

Сколько ядер у вас есть на вашей машине?

Если линия вашего обработчика не выполняет никаких блокировок или длительной обработки, очень вероятно, что обработка ввода-вывода будет всегда намного быстрее, чем сеть, то есть поток ввода-вывода будет работать без нагрузки и ждать работы довольно большая часть времени. Не нужно выделять другой поток из пула.

Если, с другой стороны, обработчик требует длительной обработки или блокировки вызовов, например. базы данных или доступа к файлам, то вам следует передать обработку в ExecutionHandler, которая передает обработку из пула рабочих IO в другой пул потоков.

Answer 2

Я хотел бы предложить вам использовать шаблон реактора с java.nio - посмотрите на this -