gRPC++ 实现多发布者多订阅者数据传输

要实现多个发布者和多个订阅者之间的数据传输，可以使用 gRPC 框架提供的流式 RPC 功能。流式 RPC 允许客户端和服务器之间建立持久的双向通信通道，这样就可以实现多个发布者和多个订阅者之间的数据传输。

首先，需要定义一个 gRPC 服务，其中包含两个方法：一个是发布者方法，用于发布数据；另一个是订阅者方法，用于接收数据。

在服务定义文件中，可以使用 protobuf 语言定义服务和消息的结构。例如，可以定义一个名为'Data' 的消息，其中包含需要传输的数据：

syntax = "proto3";

message Data {
    string message = 1;
}

然后，在服务定义文件中定义一个名为'DataStreaming' 的服务，其中包含两个方法：'Publish' 和 'Subscribe'：

service DataStreaming {
    rpc Publish(Data) returns (stream Data) {}
    rpc Subscribe(Data) returns (stream Data) {}
}

接下来，可以使用 gRPC 的代码生成工具生成相应的服务和消息的代码。使用 grpc_cpp_plugin 插件生成 C++ 代码：

protoc -I=<proto 文件目录> --cpp_out=<生成的代码目录> --grpc_out=<生成的代码目录> --plugin=protoc-gen-grpc=`which grpc_cpp_plugin` <proto 文件>

生成的代码中会包含服务接口和消息结构的定义。可以使用这些代码来实现发布者和订阅者的逻辑。

在发布者的代码中，可以创建一个 gRPC 的客户端，连接到服务器，并调用 'Publish' 方法来发送数据。例如：

Data data;
data.set_message("Hello, subscribers!");

DataStreaming::Stub stub(grpc::CreateChannel("<服务器地址>:<端口>", grpc::InsecureChannelCredentials()));
grpc::ClientContext context;
std::unique_ptr<grpc::ClientWriter<Data>> writer(stub.Publish(&context, &data));

在订阅者的代码中，可以创建一个 gRPC 的服务端，监听客户端的连接，并接收数据。例如：

class DataStreamingServiceImpl final : public DataStreaming::Service {
public:
    grpc::Status Publish(grpc::ServerContext* context, const Data* request, grpc::ServerWriter<Data>* writer) override {
        // 处理发布者发送的数据
        // 可以将数据发送给所有订阅者
        // ...

        return grpc::Status::OK;
    }

    grpc::Status Subscribe(grpc::ServerContext* context, const Data* request, grpc::ServerReaderWriter<Data, Data>* stream) override {
        // 处理订阅者的请求
        // 可以将数据发送给订阅者
        // ...

        return grpc::Status::OK;
    }
};

void RunServer() {
    std::string server_address("<服务器地址>:<端口>");
    DataStreamingServiceImpl service;

    grpc::ServerBuilder builder;
    builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
    builder.RegisterService(&service);

    std::unique_ptr<grpc::Server> server(builder.BuildAndStart());
    server->Wait();
}

这样，就可以实现多个发布者和多个订阅者之间的数据传输。发布者可以通过调用 'Publish' 方法将数据发送给服务器，服务器可以将数据发送给所有订阅者。订阅者可以通过调用 'Subscribe' 方法接收服务器发送的数据。