内蒂+ ProtoBuffer：一个连接的一些通信消息

Question

在阅读 Netty 教程时，我发现了一个简单的 描述 如何集成 Netty 和 Google Protocol缓冲区。我已经开始研究它的示例（因为文档中没有更多信息）并编写了一个简单的应用程序，例如示例本地时间应用程序。但这个例子在 PipeFactory 类中使​​用静态初始化，例如：（

import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.handler.codec.protobuf.ProtobufDecoder;
import org.jboss.netty.handler.codec.protobuf.ProtobufEncoder;
import org.jboss.netty.handler.codec.protobuf.ProtobufVarint32FrameDecoder;
import org.jboss.netty.handler.codec.protobuf.ProtobufVarint32LengthFieldPrepender;

import static org.jboss.netty.channel.Channels.pipeline;

/**
 * @author sergiizagriichuk
 */
class ProtoCommunicationClientPipeFactory implements ChannelPipelineFactory {

    public ChannelPipeline getPipeline() throws Exception {
        ChannelPipeline p = pipeline();
        p.addLast("frameDecoder", new ProtobufVarint32FrameDecoder());
        p.addLast("protobufDecoder", new ProtobufDecoder(Communication.DataMessage.getDefaultInstance()));

        p.addLast("frameEncoder", new ProtobufVarint32LengthFieldPrepender());
        p.addLast("protobufEncoder", new ProtobufEncoder());

        p.addLast("handler", new ProtoCommunicationClientHandler());
        return p;
    }

}

请看一下 p.addLast("protobufDecoder", new ProtobufDecoder(Communication.DataMessage.getDefaultInstance())); 行 并且只能为 ClientBootstrap 类创建一个工厂（据我所知），我的意思是 bootstrap.setPipelineFactory() 方法。因此，在这种情况下，我可以使用一条消息发送到服务器，并使用一条消息从服务器接收，这对我来说不好，而且我认为不仅仅是对我来说： （我如何才能在一个连接中使用不同的消息来往？ 创建一些 protobufDecoder

p.addLast("protobufDecoder", new ProtobufDecoder(Communication.DataMessage.getDefaultInstance()));
p.addLast("protobufDecoder", new ProtobufDecoder(Communication.TestMessage.getDefaultInstance()));
p.addLast("protobufDecoder", new ProtobufDecoder(Communication.SrcMessage.getDefaultInstance()));

也许我可以像这样或其他技术 ？ 多谢。

Answer 1

我在 Google 群组 中找到了 netty 作者的帖子，并了解这一点我必须改变我的架构或编写我自己的解码器，就像我上面写的那样，所以，开始思考什么方法会更简单、更好。

Answer 2

如果您无论如何都要编写自己的编解码器，您可能需要考虑为自定义数据对象实现Externalized 接口。

• 可序列化是省力的，但性能最差（序列化所有内容）。
• Protobuf 是工作量和性能之间的一个很好的权衡（需要 .proto 维护）。Externalized
• 工作量很大，但性能最佳（自定义最小编解码器）。

如果您已经知道您的项目必须像山羊一样扩展，那么您可能必须去艰难的道路。 Protobuf 不是灵丹妙药。

Answer 3

理论上，这可以通过修改每个传入消息的管道以适应传入消息来完成。查看端口统一 Netty 中的示例。

顺序是：
1）在帧解码器或另一个“DecoderMappingDecoder”中检查传入消息的消息类型
2）如示例所示动态修改管道

但是为什么不使用不同的连接并遵循以下顺序：
1) 仅根据传入消息在管道中添加其他解码器一次。
2) 添加通道上游处理程序的相同实例作为管道中的最后一个处理程序，这样所有消息都会路由到同一个实例，这几乎就像拥有单个连接一样。

Answer 4

问题是无法以二进制格式区分两个不同的 protobuf 消息。但有一种方法可以在 protobuf 文件中解决这个问题：

message AnyMessage {
    message DataMessage { [...] }
    optional DataMessage dataMessage = 1;
    message TestMessage { [...] }
    optional TestMessage testMessage = 2;
    message SrcMessage { [...] }
    optional SrcMessage srcMessage = 3;
}

未设置的可选字段不会产生任何开销。此外，您可以添加一个枚举，但这只是一个额外的好处。

Answer 5

该问题不完全是 Netty 限制或编码器/解码器限制。问题是 Google Protocol Buffers 仅提供了一种序列化/反序列化对象的方法，但不提供协议。他们有某种 RPC 实现作为标准发行版的一部分，但如果您尝试实现他们的 RPC 协议，那么您最终会得到 3 层间接。
我在其中一个项目中所做的就是定义一条基本上是消息联合的消息。该消息包含一个字段（类型）和另一字段（实际消息）。您最终仍然会得到 2 个间接层，但不是 3 个。这样，Netty 中的示例将适合您，但正如上一篇文章中提到的，您必须在业务逻辑处理程序中放入更多逻辑。

Answer 6

您可以使用消息隧道来发送各种类型的消息作为单个消息中的负载。
希望有帮助

Answer 7

经过长期的研究和痛苦...
我想出了将消息组合到一个包装消息中的想法。在该消息中，我使用 oneof 键将允许的对象数量限制为唯一一个。查看示例：

message OneMessage {
    MessageType messageType = 1;

    oneof messageBody {
        Event event = 2;
        Request request  = 3;
        Response response = 4;
    }

    string messageCode = 5; //unique message code
    int64 timestamp = 6; //server time
}