C++ gRPC 多发布者多订阅者设计模式示例

下面是一个基于 gRPC 实现多发布者多订阅者设计模式的 C++ 示例代码：

// 定义服务
service PubSubService {
  // 发布消息
  rpc Publish(Message) returns (Empty) {}

  // 订阅消息
  rpc Subscribe(Empty) returns (stream Message) {}
}

// 实现服务
class PubSubServiceImpl final : public PubSubService::Service {
public:
  // 发布消息
  grpc::Status Publish(grpc::ServerContext* context, const Message* request, Empty* response) override {
    // 将消息广播给所有订阅者
    for (auto& subscriber : subscribers) {
      subscriber->Send(*request);
    }
    return grpc::Status::OK;
  }

  // 订阅消息
  grpc::Status Subscribe(grpc::ServerContext* context, const Empty* request, grpc::ServerWriter<Message>* writer) override {
    subscribers.push_back(writer);
    return grpc::Status::OK;
  }

private:
  std::vector<grpc::ServerWriter<Message>*> subscribers;
};

int main() {
  std::string server_address('0.0.0.0:50051');
  PubSubServiceImpl service;

  // 创建gRPC服务器
  grpc::ServerBuilder builder;
  builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  builder.RegisterService(&service);

  // 启动服务器
  std::unique_ptr<grpc::Server> server(builder.BuildAndStart());
  std::cout << "Server listening on " << server_address << std::endl;

  // 等待服务器关闭
  server->Wait();

  return 0;
}

上述代码定义了一个 PubSubService 服务，包含了两个方法：Publish 用于发布消息，Subscribe 用于订阅消息。PubSubServiceImpl 类是服务的实现类，其中 Publish 方法将接收到的消息广播给所有订阅者，而 Subscribe 方法将订阅者添加到订阅者列表中。

在 main 函数中，创建了一个 gRPC 服务器，并将 PubSubServiceImpl 服务注册到服务器中，然后启动服务器并等待关闭。

你可以根据实际需求对上述代码进行修改和扩展。