Go Academy · Aula

Streaming de servidor e cliente

Streaming bidirecional e controle de fluxo

Streaming de servidor e cliente é uma aula grátis de Go Academy no CoddyKit. Esta é a aula 3 de 4. Você pode ler a aula completa abaixo gratuitamente — depois pratica ao vivo no navegador com um editor de código integrado e um tutor de IA 24/7. Faz parte do caminho de aprendizado de Go Academy, e seu progresso é sincronizado entre a web e o app CoddyKit. O curso de Go Academy inclui 4 aulas no total.

Tipos de transmissão gRPC

O gRPC oferece três modos de transmissão além do unário: transmissão do servidor (o servidor envia várias mensagens), transmissão do cliente (o cliente envia várias mensagens) e transmissão bidirecional (ambos transmitem).

Transmissão do servidor em .proto

Use a palavra-chave stream antes do tipo de resposta:

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

Implementação da transmissão do servidor

O servidor envia várias mensagens chamando stream.Send() e retorna nil quando termina:

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
}

Cliente recebendo uma transmissão do servidor

O cliente chama Recv() em um loop até io.EOF:

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)
}

Transmissão do cliente em .proto

Use stream antes do tipo de solicitação:

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

Implementação da transmissão do cliente

O cliente envia várias mensagens e depois fecha a transmissão com CloseAndRecv:

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

Servidor recebendo uma transmissão do cliente

Chame stream.Recv() em um loop até io.EOF e depois retorne a resposta final:

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)
    }
}

Transmissão bidirecional

O cliente e o servidor podem enviar e receber de forma independente. Declare stream nos dois lados do .proto.

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

Implementação do servidor bidirecional

O servidor recebe em uma goroutine e envia de forma independente:

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})
    }
}

Controle de fluxo

O gRPC usa o controle de fluxo do HTTP/2 para evitar que remetentes rápidos sobrecarreguem receptores lentos. As chamadas a Recv() aplicam naturalmente contrapressão — o envio é bloqueado quando o receptor não está lendo.

Cancelamento do contexto

Passe um contexto com prazo ou cancelamento a todas as chamadas de transmissão. A transmissão é cancelada quando o contexto é concluído, fazendo com que Recv/Send retornem um erro.

Verificação rápida

Como um servidor de RPC com transmissão do servidor sinaliza que terminou de enviar?

Recapitulação: transmissão gRPC

Pontos principais:

Transmissão do servidor: palavra-chave stream na resposta; o servidor chama Send()
Transmissão do cliente: palavra-chave stream na solicitação; o cliente chama Send() e depois CloseAndRecv()
Bidirecional: stream nos dois lados; goroutines independentes para Send e Recv
O cancelamento do contexto se aplica a todas as chamadas de transmissão

Perguntas Frequentes

A aula “Streaming de servidor e cliente” é grátis?

Sim — o texto completo de “Streaming de servidor e cliente” é grátis para ler aqui na web. Para praticá-la interativamente (um editor de código integrado e um tutor de IA 24/7) e desbloquear o restante do curso de Go Academy, atualize para CoddyKit PRO. O curso de Go Academy inclui 4 aulas no total.

O que vou aprender em “Streaming de servidor e cliente”?

Streaming bidirecional e controle de fluxo Você pratica Go Academy com código prático que executa diretamente no navegador, e um tutor de IA 24/7 responde suas dúvidas enquanto trabalha na aula.

Preciso ter experiência prévia para começar Go Academy?

Nenhuma experiência prévia é necessária. Go Academy no CoddyKit é estruturado para alunos iniciantes até avançados, então você pode começar aqui ou desde o início e aprender no seu ritmo. Esta é a aula 3 de 4.

Quanto tempo leva a aula “Streaming de servidor e cliente”?

A maioria das aulas CoddyKit leva cerca de 5–10 minutos. Cada uma é compacta e interativa, então você faz progresso constante e retoma exatamente de onde parou entre web e app.

Posso escrever e executar código nesta aula de Go Academy?

Sim. Cada aula de Go Academy inclui um editor de código integrado, então você escreve e executa código real direto no navegador e recebe feedback de IA instantaneamente — nenhuma configuração local necessária.

Todas as aulas deste curso

← Voltar para Go Academy