读取字符串并用Netty中的字节回复

Question

我是Netty的新手，已经成功创建了一个通过TLS工作的服务器。我现在正在设计第二台服务器，但我对管道有一些问题。我需要的是一个动态管道，比如Netty的port unification示例：http://netty.io/4.0/xref/io/netty/example/portunification/PortUnificationServerHandler.html

每个连接都从客户端发送UTF-8编码的字符串开始。我看得很清楚，但我的回答不清楚。我的回答只是一个3字节的字节数组。

这是我的服务器：

// Configure the server
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
            .channel(NioServerSocketChannel.class)
            .option(ChannelOption.SO_BACKLOG, 100)
            .handler(new LoggingHandler(LogLevel.INFO))
            .childHandler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ChannelPipeline pipeline = ch.pipeline();
                    pipeline.addLast(new LineBasedFrameDecoder(192));
                    pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));
                    pipeline.addLast(new ByteArrayEncoder());
                    pipeline.addLast(new TokenHandler());
                }
            });

    // Start the server
    ChannelFuture f = b.bind(port).sync();

    // Wait until the server socket is closed
    f.channel().closeFuture().sync();
}
finally {
    // Shut down all event loops to terminate all threads
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
}

我的TokenHandler是SimpleChannelInboundHandler：

public class TokenHandler extends SimpleChannelInboundHandler<String> {
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, String token) throws Exception {
        System.out.println("Token received: " + token);
        channelHandlerContext.writeAndFlush(new byte[] {2, 1, 0});
    }
}

我还试着用

channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer(new byte[] {2, 1, 0}));

从我的管道中删除ByteArrayEncoder，但这没有任何区别：没有发送字节。如果我添加一个StringEncoder，我可以发送字符串，Netty的Echo示例也可以工作（可从用户指南：http://netty.io/wiki/user-guide-for-4.x.html).我猜这对Netty来说是个基本的错误，但我找不到其他有类似问题的人。

编辑：我用的是Netty 4.0.34。最终的

Answer 1

我应该更仔细地阅读这些文件。解决方案是将super（true）添加到TokenHandler的构造函数中，因为默认情况下，SimpleChannelInboundHandler会在处理后释放其消息，从而阻止响应在管道中进一步传播。