使用协议缓冲区在ZeroMQ中实现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。没有必要将它们分解为方法的单独参数，只需将整个内容作为单个参数传递。

您可以以相同的方式定义不同的返回类型，将它们全部通过单个one of传回。

替代品

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

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

ASN.1的线格式具有更强的类型（如果您使用BER编码）。可以询问线比特流以找出它包含的消息类型。因此，没有必要像使用GPB一样将所有可能的消息包装成单个one of。