在netty中，如何使用单独的任务执行器来阻塞子任务？

Question

情况：考虑到telnet客户端

这是Netty 4！

通道处理程序在一段时间内阻塞线程，而不是echo回复消息(就像telnet服务器演示所做的那样)(在现实世界中，像JDBC或JSch，...).

try { Thread.sleep(3000); } catch (InterruptedException e) {};
future = ctx.write("Task finished at " + new Date());
future.addListener(ChannelFutureListener.CLOSE);

这实际上是可行的：我正在用echo“Hello”|nc-localhost$port）测试它，线程将被阻塞（并且ncwaitis），直到3秒钟后返回。

然而，这意味着我正在用一个不相关的任务阻塞Netty的事件循环工作组的线程。

因此，我更改了频道注册并应用了自定义执行器：

public class TelnetServerInitializer extends ChannelInitializer<SocketChannel> {

    private static final StringDecoder DECODER = new StringDecoder();
    private static final StringEncoder ENCODER = new StringEncoder();

    private TelnetServerHandler serverHandler;
    private EventExecutorGroup executorGroup;

    public TelnetServerInitializer() {
        executorGroup = new DefaultEventExecutorGroup(10);
        serverHandler = new TelnetServerHandler();
    }

    @Override
    protected void initChannel(final SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
            8192, Delimiters.lineDelimiter()));

        pipeline.addLast("decoder", DECODER);
        pipeline.addLast("encoder", ENCODER);

        // THIS!
        pipeline.addLast(executorGroup, "handler", serverHandler);
    }
}

不幸的是，在此配置后，套接字将在退出处理程序的< code>channelRead0()后立即关闭。我可以看到任务本身将被处理，包括调用处理程序的事件方法。但是相应的通道已经与客户端断开连接(我的< code>nc命令已经退出)。

整合另一个执行者是如何工作的？我是否遗漏了一个细节？

Answer 1

您的网络服务器正在按预期工作，这是回显|您正在测试的nc命令正在提前退出。

尝试使用“telnet localhost 3000”与您的测试服务器进行交互会话，输入一些文本，您将看到在延迟后会写入正确的响应，然后通道关闭。

或者只需使用“nc -v -w10 localhost 3000”，写一些文本，按回车键，在延迟和频道关闭后，您再次看到预期的输出。