grpc-go 调用模式

╰半橙微兮° 2022-12-09 01:59 195阅读 0赞

## 一元调用（同步请求） ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center]

### server ###

type SearchService struct{
        }
    
    func (s *SearchService) Search(ctx context.Context, r *pb.SearchRequest) (*pb.SearchResponse, error) {
        
        return &pb.SearchResponse{
        Response: r.GetRequest() + " Server"}, nil
    }
    
    const PORT = "9001"
    
    func main() {
        
        server := grpc.NewServer()
        pb.RegisterSearchServiceServer(server, &SearchService{
        })
    
        lis, err := net.Listen("tcp", ":"+PORT)
        ...
    
        server.Serve(lis)
    }

1.  创建grpc Server对象
2.  注册绑定SearchService的成员函数，对应的server的m成员字段
3.  Listen，监听tcp
4.  gRPC Server 开始 lis.Accept，直到 Stop 或 GracefulStop。

### client ###

func main() {
        
        conn, err := grpc.Dial(":"+PORT, grpc.WithInsecure())
        ...
        defer conn.Close()
    
        client := pb.NewSearchServiceClient(conn)
        resp, err := client.Search(context.Background(), &pb.SearchRequest{
        
            Request: "gRPC",
        })
        ...
    }

1.  创建与给定目标（服务端）的连接句柄。
2.  创建 SearchService 的客户端对象
3.  发送 RPC 请求，等待同步响应，得到回调后返回响应结果。

## 服务端流模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 1]

### server ###

func (s *StreamService) List(r *pb.StreamRequest, stream pb.StreamService_ListServer) error {
        
        for n := 0; n <= 6; n++ {
        
            stream.Send(&pb.StreamResponse{
        
                Pt: &pb.StreamPoint{
        
                    ...
                },
            })
        }
    
        return nil
    }

主要通过stream.Send来进行数据的发送。

### client ###

func printLists(client pb.StreamServiceClient, r *pb.StreamRequest) error {
        
        stream, err := client.List(context.Background(), r)
        ...
        
        for {
        
            resp, err := stream.Recv()
            if err == io.EOF {
        
                break
            }
            ...
        }
    
        return nil
    }

## 客户端流模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 2]

### server ###

func (s *StreamService) Record(stream pb.StreamService_RecordServer) error {
        
        for {
        
            r, err := stream.Recv()
            if err == io.EOF {
        
                return stream.SendAndClose(&pb.StreamResponse{
        Pt: &pb.StreamPoint{
        ...}})
            }
            ...
    
        }
    
        return nil
    }

### client ###

func printRecord(client pb.StreamServiceClient, r *pb.StreamRequest) error {
        
        stream, err := client.Record(context.Background())
        ...
        
        for n := 0; n < 6; n++ {
        
            stream.Send(r)
        }
    
        resp, err := stream.CloseAndRecv()
        ...
    
        return nil
    }

## 双向流模式 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 3]

### server ###

func (s *StreamService) Route(stream pb.StreamService_RouteServer) error {
        
        for {
        
            stream.Send(&pb.StreamResponse{
        ...})
            r, err := stream.Recv()
            if err == io.EOF {
        
                return nil
            }
            ...
        }
    
        return nil
    }

### client ###

func printRoute(client pb.StreamServiceClient, r *pb.StreamRequest) error {
        
        stream, err := client.Route(context.Background())
        ...
    
        for n := 0; n <= 6; n++ {
        
            stream.Send(r)
            resp, err := stream.Recv()
            if err == io.EOF {
        
                break
            }
            ...
        }
    
        stream.CloseSend()
    
        return nil
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/9b61e22ebb78422aab4eedbac13ba020.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/0842aa156722476db50d3b41cc095ad8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/4e10ac55dfee44ca993ffd813505036d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMyNDY4OTg_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221123/06de7ec44e50433fa95e78f598bc7d26.png