在 ZeroMQ 中使用 Protocol Buffers 实现 RPC

Question

我有一个客户端和一个服务器的简单设置。客户端想要在服务器中执行一个使用 ZeroMQ 进行通信的方法。我将使用 REQ 和 REP 套接字，因为它们适用于这个用例。不过，我对 protobuf 的定义有疑问。我认为这两个选项可用于实现目标：

message ControlService{
    string control = 1;
    int32 serverId = 2;
    bool block = 3;
    double temperature = 4;
}

其中“control”包含要远程执行的方法的名称。另一种选择可以是：

message InputParameters{
    int32 serverId = 1;
    bool block = 2;
    double temperature = 3;
}
message Empty{

}
service ControlService{
    rpc control (InputParameters) returns (Empty);
}

最好的方法是什么？或者至少使用一种方法而不是另一种方法的权衡是什么？

Answer 1

不要那样做。留言：

message InputParameters{
    req oneof
    {
        InputParametersA a = 1;
        InputParametersB b = 2;
    }
}
message InputParametersA
{
    bool block = 1;
    float temperature = 2;
}
message InputParametersB
{
    <more fields>
}

这样你就只发送 InputParameters 消息。要调用的方法取决于 InputParameters.req 是否包含 InputParametersA（意味着应该调用方法 A）或 InputParmetersB（对于方法 B）。

这避免了解析字符串以确定方法名称（非常容易出错），而是为您提供一个枚举以打开（req 字段的可能内容）。根据您使用的 GPB 的实现（C++ 等），如果您的 switch 语句没有充分涵盖该枚举的所有值，您甚至可能会收到编译时警告。

这也意味着确定哪些字段应该传递给方法没有问题；您将 InputParameters.req.a 传递到方法 A 或 .b 到方法 B。无需将它们分解为方法的单独参数，只需将整个内容作为单个参数传递即可。

您可以以相同的方式定义不同的返回类型，通过单个oneof.

备择方案

现在，如果您使用的是 ASN.1（在概念上与 GPB 相同），您可以对消息字段的值和/或大小设置约束（请参阅此处，本 PDF 中的第 13 章。那样您自动执行参数验证，仅在 ASN.1 模式中定义。GPB 中缺少值/大小约束是一个明显的遗漏。

看看这里（概述），这里（看起来不错的 C/C++ 的免费模式编译器）和这里（PDF，参考手册）。

ASN.1 在其有线格式中具有更强的类型（如果您使用 BER 编码）。可以查询有线比特流以找出它包含的消息类型。因此，无需oneof像使用 GPB 那样将所有可能的消息打包成一个。