netty do do nothing编解码器

Question

我正在编写HTTP-Server，它将执行一些非常重的计算。我有一些与业务逻辑和阻止IO有关的编码器数据管道。

public void initChannel(Channel ch) { 
    ch.pipeline()
         //All actions in these handlers are very heavy and involve some IO
        .addLast(logicGroup, new HttpRequestDecoder())
        .addLast(logicGroup, new HttpObjectAggregator(Int.MaxValue))
        .addLast(logicGroup, new HttpResponseEncoder())
        .addLast(logicGroup, new ChunkedWriteHandler())
        .addLast(logicGroup, new ResponseBodyDecoder())
        .addLast(logicGroup, new MyBusinessLogic())
}

所以我决定创建另一个工人

EventLoopGroup ioGroup = new NioEventLoopGroup(4)

一开始添加简单的处理程序：

.addLast(ioGroup, new ChannelDuplexHandler()) //<---- Only for IO
.addLast(logicGroup, new HttpRequestDecoder())
.addLast(logicGroup, new HttpObjectAggregator(Int.MaxValue))
.addLast(logicGroup, new HttpResponseEncoder())
.addLast(logicGroup, new ChunkedWriteHandler())
.addLast(logicGroup, new ResponseBodyDecoder())
.addLast(logicGroup, new MyBusinessLogic())

在Netty中喜欢这样做吗？还是有更好的方法？

Answer 1

通常，如果要在io线程上运行处理程序，则在将处理程序添加到管道时，您只是不会指定执行程序。我的建议是构建该管道：

EventExecutorGroup executorGroup = new DefaultEventExecutorGroup(numberOfThreads);
...
public void initChannel(Channel ch) { 
    ch.pipeline()
      .addLast(new HttpRequestDecoder())
      .addLast(new HttpObjectAggregator(Int.MaxValue))
      .addLast(new HttpResponseEncoder())
      .addLast(new ChunkedWriteHandler())
      .addLast(new ResponseBodyDecoder())
      .addLast(executorGroup, new MyBusinessLogic());
}

这将使您的MyBusinessLogic在另一个线程中运行，而不会阻止IO线程。如果您的ResponseBodyDecoder在CPU/或块上也很重，也可以在此处使用executorGroup。