Нетти 4. Параллельная обработка после ByteToMessageCodec

Question

Если NioEventLoopGroup используется в качестве workerGroup, сообщения после ByteToMessageDecoder обработчика (для одного соединения) обрабатываются в последовательном (однопоточный) способом с помощью следующих обработчиков в пределах NioEventLoop.

Возможно ли, чтобы их обработали другие «рабочие» после обработчика ByteToMessageDecoder?

Answer 1

Да, просто добавьте ChannelHandler со специальным EventExecutorGroup в ChannelPipeline. Например, UnorderedThreadPoolEventExecutor (src).

Так что-то вроде:

UnorderedThreadPoolEventExecutor executorGroup = ...; 
pipeline.addLast(executorGroup, new MyChannelHandler());