Java Netty-根据输入消息将结果作为StringEncoder或ObjectEncoder发送给客户端？

Question

我是Netty的新手，到目前为止，有一个可以使用StringEncoder和StringDecoder处理字符串消息的工作客户端服务器，例如：

        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup, workerGroup)
                       .channel(NioServerSocketChannel.class)
                       .handler(new LoggingHandler(LogLevel.TRACE))
                       .childHandler(new ChannelInitializer<SocketChannel>() {
                                            @Override
                                            public void initChannel(SocketChannel ch) throws Exception {
                                                ch.pipeline().addLast(
                                                    new LoggingHandler(LogLevel.TRACE),
                                                    new DelimiterBasedFrameDecoder(Integer.MAX_VALUE, Delimiters.lineDelimiter()),
                                                    new StringEncoder(),
                                                    new StringDecoder(),
                                                    new ReceiveMessageCommunicatorHandler(localNode, inpeerNodeRegistry, outpeerNodeRegistry));

输入消息如下：excute_this，服务器发回：ok。

现在，我需要做的是服务器接收到一条新的文本消息：get_对象，它应该将一个序列化对象作为字节数组发送回任何客户端（例如：telnet或使用普通套接字的java应用程序）。然后在这个客户机中，它可以将这个对象反序列化为Java对象。

我知道ObjectEncoder（）似乎是解决这个问题的方法。但是，它还将应该是字符串的响应序列化到序列化对象，同时它应该为某些特定消息（例如：仅get_对象）执行此操作。

我如何告诉Netty何时应该将结果编码为StringEncoder，何时应该将序列化对象编码为字节数组？

Answer 1

感谢里亚法·阿卜杜勒·哈米德的建议

当服务器接收到消息并将响应写入客户端时，它可以动态地切换编码器，如下面的代码所示。

@Override
protected void channelRead0(ChannelHandlerContext ctx, String message) throws Exception {
    InetSocketAddress address = (InetSocketAddress) ctx.channel().remoteAddress();
    MessageContainer messageContainer = new MessageContainer(message, address);
    log.debug("\n");
    log.debug("Message received: {}", message);

    // Handle received message and write result back to the sender
    Object response = this.handleMessage(messageContainer);
    if (response instanceof String) {
        ctx.channel().pipeline().names();
        ctx.channel().pipeline().remove(ObjectEncoder.class);
        ctx.channel().pipeline().addFirst(new StringEncoder());
    }

    if (response != null) {
        ctx.write(response);
        ctx.flush();
    }
    ctx.close();
}

Answer 2

可以动态修改管道。当您收到get_object消息时，只需删除StringEncoder并将ObjectEncoder添加到相关的ChannelInboundHandler

   ChannelPipeline p = ctx.pipeline();
    if (p.get(StringEncoder.class) != null) {
        p.remove(StringEncoder.class);
    }
    p.addLast(new YourObjectEncoder())

或者如果你知道你的编码器的名称，你可以做一个替换：

p.replace("encoder", "encoder", new YourObjectEncoder());