服务器流与客户端流
双向流与背压
服务器流与客户端流 是 CoddyKit 上的免费 Go Academy 课时。 这是第 3 节课，共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Go Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。
gRPC 流式传输类型
除了单请求单响应之外，gRPC 还支持三种流式传输模式：服务端流式传输（服务器发送多个消息）、客户端流式传输（客户端发送多个消息）以及双向流式传输（双方都进行流式传输）。
在 .proto 中定义服务端流式传输
在响应类型前使用 stream 关键字：
service EventService {
rpc ListEvents (ListEventsRequest) returns (stream Event);
}实现服务端流式传输
服务器通过调用 stream.Send() 发送多个消息，完成后返回 nil：
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
}客户端接收服务端流
客户端循环调用 Recv()，直到 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)
}在 .proto 中定义客户端流式传输
在请求类型前使用 stream：
service UploadService {
rpc Upload (stream Chunk) returns (UploadResponse);
}实现客户端流式传输
客户端发送多个消息，然后使用 CloseAndRecv 关闭流：
stream, _ := client.Upload(ctx)
for _, chunk := range chunks {
stream.Send(chunk)
}
resp, err := stream.CloseAndRecv()服务器接收客户端流
循环调用 stream.Recv()，直到 io.EOF，然后返回最终响应：
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)
}
}双向流式传输
客户端和服务器都可以独立地发送和接收。在 .proto 中，双方都使用 stream 声明。
service ChatService {
rpc Chat (stream Message) returns (stream Message);
}实现双向流式服务器
服务器在一个 goroutine 中接收，并独立发送：
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 使用 HTTP/2 流量控制，防止快速发送方压垮慢速接收方。调用 Recv() 会自然地产生反压——当接收方没有读取时，发送操作会阻塞。
上下文取消
为所有流式调用传递带有截止时间或取消信号的上下文。当上下文结束时，流会被取消，从而使 Recv/Send 返回错误。
快速检查
服务端流式 RPC 服务器如何表示自己已完成发送？
回顾：gRPC 流式传输
要点：
- 服务端流：在响应上使用 stream 关键字；服务器调用 Send()
- 客户端流：在请求上使用 stream 关键字；客户端调用 Send()，然后调用 CloseAndRecv()
- 双向流：双方都使用 stream；Send 和 Recv 在独立的 goroutine 中运行
- 上下文取消适用于所有流式调用
常见问题解答
「服务器流与客户端流」课时是免费的吗？
是的 — 「服务器流与客户端流」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Go Academy 课程的其余内容，请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。
「服务器流与客户端流」这节课中我会学到什么？
双向流与背压 你通过在浏览器中直接运行的动手代码来练习 Go Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Go Academy 需要有经验吗？
无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。 这是第 3 节课，共 4 节。
「服务器流与客户端流」课时需要多长时间？
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。
我能在这节 Go Academy 课中编写并运行代码吗？
能。每节 Go Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。