gRPC 多发布者多订阅者模式 C++ 示例代码

以下是一个使用 gRPC 实现多发布者多订阅者模式的 C++ 程序的示例代码：

// 定义发布者服务
service Publisher {
  // 发布消息的方法
  rpc PublishMessage(Message) returns (Empty) {}
}

// 定义订阅者服务
service Subscriber {
  // 订阅消息的方法
  rpc SubscribeForMessages(Empty) returns (stream Message) {}
}

// 实现发布者服务
class PublisherImpl final : public Publisher::Service {
public:
  // 实现 PublishMessage 方法
  grpc::Status PublishMessage(grpc::ServerContext* context, const Message* request, Empty* response) override {
    // 将消息广播给所有订阅者
    for (auto subscriber : subscribers_) {
      subscriber->Write(*request);
    }
    return grpc::Status::OK;
  }

  // 添加订阅者的方法
  void AddSubscriber(std::unique_ptr<grpc::ServerWriter<Message>> subscriber) {
    subscribers_.push_back(std::move(subscriber));
  }

private:
  std::vector<std::unique_ptr<grpc::ServerWriter<Message>>> subscribers_;
};

// 实现订阅者服务
class SubscriberImpl final : public Subscriber::Service {
public:
  // 实现 SubscribeForMessages 方法
  grpc::Status SubscribeForMessages(grpc::ServerContext* context, const Empty* request, grpc::ServerWriter<Message>* writer) override {
    // 将订阅者的写接口保存起来，以便发布者发送消息时使用
    publisher_->AddSubscriber(std::unique_ptr<grpc::ServerWriter<Message>>(writer));
    return grpc::Status::OK;
  }

  // 设置发布者的方法
  void SetPublisher(PublisherImpl* publisher) {
    publisher_ = publisher;
  }

private:
  PublisherImpl* publisher_;
};

int main() {
  // 创建 gRPC 服务器
  grpc::ServerBuilder builder;
  std::string server_address('0.0.0.0:50051');
  PublisherImpl publisher;
  SubscriberImpl subscriber;
  subscriber.SetPublisher(&publisher);

  // 注册发布者服务
  builder.RegisterService(&publisher);
  // 注册订阅者服务
  builder.RegisterService(&subscriber);

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

  // 等待服务器停止
  server->Wait();

  return 0;
}

这个示例程序定义了一个发布者服务和一个订阅者服务，发布者可以使用 PublishMessage 方法发布消息，订阅者可以使用 SubscribeForMessages 方法订阅消息。当发布者发布消息时，消息会被广播给所有订阅者。

在 main 函数中，我们创建了一个 gRPC 服务器，并注册了发布者服务和订阅者服务。然后启动服务器并等待服务器停止。

你可以根据需要修改和扩展这个示例程序来满足你的具体需求。