如何使用ZeroMQ为协议缓冲区编写自己的RPC实现

根据"定义服务"下的Google协议缓冲区文档，他们说

还可以将协议缓冲区与您自己的RPC实现一起使用。

据我所知，协议缓冲区并不是以本机方式实现RPC的。相反，它们提供了一系列必须由用户实现的抽象接口(这就是我！)。因此，我想利用ZeroMQ实现这些抽象接口用于网络通信。

我正试图使用ZeroMQ创建一个RPC实现，因为我正在进行的项目已经为基本消息传递实现了ZeroMQ(因此，正如文档所建议的，我而不是使用gRPC)。

在彻底阅读了proto文档后，我发现我必须实现抽象接口RpcChannel和RpcController才能实现自己的实现。

我已经用RPC实现构建了一个我目前所处位置的最小化示例

.proto文件：为简洁起见，省略了SearchRequest和SearchResponse模式

service SearchService {
rpc Search (SearchRequest) returns (SearchResponse);
}

SearchServiceImpl.h：

class SearchServiceImpl : public SearchService {
public:
void Search(google::protobuf::RpcController *controller,
const SearchRequest *request,
SearchResponse *response,
google::protobuf::Closure *done) override {
// Static function that processes the request and gets the result
SearchResponse res = GetSearchResult(request);
// Call the callback function
if (done != NULL) {
done->Run();
}
}
}
};

MyRPCController.h：

class MyRPCController : public google::protobuf::RpcController {
public:
MyRPCController();
void Reset() override;
bool Failed() const override;
std::string ErrorText() const override;
void StartCancel() override;
void SetFailed(const std::string &reason) override;
bool IsCanceled() const override;
void NotifyOnCancel(google::protobuf::Closure *callback) override;
private:
bool failed_;
std::string message_;
};

MyRPCController.cpp-基于此

void MyRPCController::Reset() {  failed_ = false; }
bool MyRPCController::Failed() const { return failed_; }
std::string MyRPCController::ErrorText() const { return message_; }
void MyRPCController::StartCancel() { }
void MyRPCController::SetFailed(const std::string &reason) {
failed_ = true;
message_ = reason;
}
bool MyRPCController::IsCanceled() const { return false; }
void MyRPCController::NotifyOnCancel(google::protobuf::Closure *callback) { }
MyRPCController::ChiRpcController() : RpcController() { Reset(); }

MyRpcChannel.h：

class MyRPCChannel: public google::protobuf::RpcChannel {
public:
void CallMethod(const google::protobuf::MethodDescriptor *method, google::protobuf::RpcController *controller,
const google::protobuf::Message *request, google::protobuf::Message *response,
google::protobuf::Closure *done) override;
};

到目前为止，我对我的例子有一些问题：

• 在哪里可以将ZeroMQ放入其中？
  • 它似乎应该进入RPCChannel，因为在我看到的示例中(请参阅此处的第三个代码块)，它们传递一个具有要绑定的端口的字符串(即MyRpcChannel channel("rpc:hostname:1234/myservice");)
• 我关心我的RPCController实现，它似乎太简单了。应该有更多的人来这里吗
• 我如何实现RPCChannel，它似乎与SearchServiceImpl非常相似。这些类中的1虚拟函数有一个非常相似的方法签名，只是它是泛型的

以下是我遇到的其他一些堆栈溢出问题，其中包含了一些关于该主题的有用信息：

1. Protobuf-Net:实现服务器、rpc控制器和rpc通道-这是我找到RPCController实现示例的地方
2. 使用协议缓冲区在ZeroMQ中实现RPC-这个答案很有趣，因为在最重要的答案中，他们似乎建议不要为.proto文件使用RPC格式中内置的Protobufs。
   • 我在这个文件中也注意到了同样的概念，在一个名为libpbrpc的存储库中，它似乎是一个很好的源代码，例如代码
3. 我可以/应该使用现有的实现(如RPCZ)吗

感谢您的帮助。我希望我提供了足够的信息，并且清楚地知道我在寻找什么。如果有什么不清楚或缺乏信息，请告诉我。我很乐意相应地编辑这个问题。