如何使用netty在单独的线程池中执行业务逻辑处理程序

Question

我有一个需要执行一些业务逻辑的处理程序，我希望它在单独的线程池中执行，以不阻塞io事件循环。我已将DefaultEventExecutorGroup添加到管道中，如http://netty.io/4.0/api/io/netty/channel/ChannelPipeline.htmljavadoc和http://netty.io/wiki/new-and-noteworthy-in-4.0.html#no-more-executionhandler---its-in-the-corewiki中指定的：

ch.pipeline().addLast(new DefaultEventExecutorGroup(10), new ServerHandler());

只是为了测试目的，我的服务器处理程序只是将当前线程置于Hibernate状态 5 秒钟：

protected void channelRead0(ChannelHandlerContext ctx, Command cmd) throws Exception {
    System.out.println("Starting.");

    try {
        Thread.currentThread().sleep(5000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    System.out.println("Finished.");        
}

但显然业务逻辑仍然是同步执行的：

Starting.
Finished.
Starting.
Finished.
Starting.
Finished.

我错过了什么？

Answer 1

因为Netty处理由同一个EventExecutor从同一套接字发送的请求，所以您可以启动多个客户端，并查看结果。

Answer 2

如果您的目标不是阻止IO事件循环-您做得对。但是由于特定于网络，您的处理程序将始终附加到EventExecutorGroup的同一线程，因此您上面描述的行为是预期的。

如果您想在阻塞操作到达后立即并行执行阻塞操作，则需要使用另一种方式 - 单独的线程池计算器。喜欢这个：

ch.pipeline().addLast(new ServerHandler(blockingThreadPool));

其中，阻塞线程池是常规线程池计算器。

例如：

ExecutorService blockingThreadPool = Executors.newFixedThreadPool(10);

现在，在您的逻辑处理程序中，您可以如下所示向该执行器提交阻塞任务：

protected void channelRead0(ChannelHandlerContext ctx, Command cmd) throws Exception {

    blockingIOProcessor.execute(new Runnable() {
        @Override
        public void run() {
            System.out.println("Starting.");

            try {
                Thread.currentThread().sleep(5000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            System.out.println("Finished.");
        }
    });

}

如果需要，还可以将上下文传递给这个runnable，以便在处理完成时返回响应。