البث من الخادم والعميل

أنواع البث في gRPC

البث من الخادم في .proto

service EventService {
    rpc ListEvents (ListEventsRequest) returns (stream Event);
}

تنفيذ البث من الخادم

func (s *server) ListEvents(req *pb.ListEventsRequest, stream pb.EventService_ListEventsServer) error {
    for _, event := range s.events {
        if err := stream.Send(event); err != nil { return err }
    }
    return nil
}

استقبال العميل لبث الخادم

stream, err := client.ListEvents(ctx, &pb.ListEventsRequest{})
for {
    event, err := stream.Recv()
    if err == io.EOF { break }
    if err != nil { log.Fatal(err) }
    fmt.Println(event)
}

البث من العميل في .proto

service UploadService {
    rpc Upload (stream Chunk) returns (UploadResponse);
}

تنفيذ البث من العميل

stream, _ := client.Upload(ctx)
for _, chunk := range chunks {
    stream.Send(chunk)
}
resp, err := stream.CloseAndRecv()

استقبال الخادم لبث العميل

func (s *server) Upload(stream pb.UploadService_UploadServer) error {
    for {
        chunk, err := stream.Recv()
        if err == io.EOF {
            return stream.SendAndClose(&pb.UploadResponse{Received: total})
        }
        if err != nil { return err }
        total += len(chunk.Data)
    }
}

البث ثنائي الاتجاه

service ChatService {
    rpc Chat (stream Message) returns (stream Message);
}

تنفيذ الخادم للبث ثنائي الاتجاه

func (s *server) Chat(stream pb.ChatService_ChatServer) error {
    for {
        msg, err := stream.Recv()
        if err == io.EOF { return nil }
        if err != nil { return err }
        stream.Send(&pb.Message{Text: "echo: " + msg.Text})
    }
}

التحكم في التدفق

إلغاء السياق

اختبار سريع

مراجعة: البث في gRPC