grpc服务端主动推送数据到客户端

在gRPC中，服务端主动推送数据到客户端需要使用流式RPC。流式RPC允许服务端和客户端之间建立一个持久化连接，从而允许它们在连接上相互发送多个消息。

下面是一个简单的示例，展示了如何在gRPC中使用流式RPC实现服务端主动推送数据到客户端：

// 定义服务
service MyService {
    // 定义一个客户端服务器流式RPC方法
    rpc ServerStreamMethod(MyRequest) returns (stream MyResponse) {}
}

// 实现服务
class MyServiceImpl : public MyService::Service {
public:
    // 实现客户端服务器流式RPC方法
    Status ServerStreamMethod(ServerContext* context, const MyRequest* request, ServerWriter<MyResponse>* writer) override {
        // 循环发送数据到客户端
        while (true) {
            MyResponse response;
            // 发送数据
            writer->Write(response);
        }
        // 返回OK状态
        return Status::OK;
    }
};

// 启动服务
void RunServer() {
    std::string server_address("0.0.0.0:50051");
    MyServiceImpl service;

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

    std::unique_ptr<Server> server(builder.BuildAndStart());
    std::cout << "Server listening on " << server_address << std::endl;

    server->Wait();
}

在这个示例中，`MyService`定义了一个名为`ServerStreamMethod`的客户端服务器流式RPC方法。服务端实现了这个方法，并在其中循环发送数据到客户端。客户端可以通过接收服务端发送的多个消息来接收数据。

需要注意的是，在使用流式RPC时，必须使用`stream`关键字来定义参数类型。例如，`stream MyResponse`表示一个可以接收多个`MyResponse`消息的流。在服务端实现中，需要使用`ServerWriter`来发送消息。在客户端实现中，需要使用`ClientReader`来接收消息。

希望这个示例能够帮助你理解如何在gRPC中实现服务端主动推送数据到客户端。