Golang中四种gRPC模式

在Golang中，gRPC支持以下四种模式：

1. 简单模式(Simple RPC): 这是最基本的gRPC模式，客户端向服务器发送一个请求，并且期望从服务器接收一个响应。

// 服务器端
type MyService struct{}
 
func (s *MyService) UnaryRPC(ctx context.Context, req *MyRequest) (*MyResponse, error) {
    // 处理请求
    return &MyResponse{}, nil
}
 
// 客户端
func CallUnaryRPC(c MyServiceClient, req *MyRequest) (*MyResponse, error) {
    return c.UnaryRPC(context.Background(), req)
}

2. 服务端流模式(Server-side streaming RPC): 客户端向服务器发送请求，并获取一系列响应消息。

// 服务器端
func (s *MyService) ServerStreamingRPC(req *MyRequest, stream MyService_ServerStreamingRPCServer) error {
    // 处理请求
    for {
        // 发送多个响应
        if err := stream.Send(&MyResponse{}); err != nil {
            return err
        }
    }
}
 
// 客户端
func CallServerStreamingRPC(c MyServiceClient, req *MyRequest) (MyService_ServerStreamingRPCClient, error) {
    return c.ServerStreamingRPC(req)
}

3. 客户端流模式(Client-side streaming RPC): 客户端通过一系列请求消息向服务器发送请求，并期望从服务器获得一个响应。

// 服务器端
func (s *MyService) ClientStreamingRPC(stream MyService_ClientStreamingRPCServer) error {
    // 处理请求流
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            break
        }
        if err != nil {
            return err
        }
        // 处理请求
    }
    return stream.SendAndClose(&MyResponse{})
}
 
// 客户端
func CallClientStreamingRPC(c MyServiceClient) (MyService_ClientStreamingRPCClient, error) {
    return c.ClientStreamingRPC(context.Background())
}

4. 双向流模式(Bidirectional streaming RPC): 客户端和服务器通过一个双向的请求-响应流进行通信。

// 服务器端
func (s *MyService) BidirectionalStreamingRPC(stream MyService_BidirectionalStreamingRPCServer) error {
    // 处理请求流
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            break
        }
        if err != nil {
            return err
        }
        // 处理请求
 
        // 发送响应
        if err := stream.Send(&MyResponse{}); err != nil {
            return err
        }
    }
    return nil
}
 
// 客户端
func CallBidirectionalStreamingRPC(c MyServiceClient) (MyService_BidirectionalStreamingRPCClient, error) {
    return c.BidirectionalStreamingRPC(context.Background())
}

在这些模式中，你需要定义一个服务和一个与服务相对应的proto文件，然后使用protoc编译器生成gRPC客户端和服务端的stub代码。在你的gRPC服务中实现服务方法，并在客户端代码中调用这些方法。