答案：Go语言通过gRPC实现服务端流式处理，客户端发起请求后，服务端持续返回多条数据，适用于日志推送、实时更新等场景；首先在.proto文件中定义包含stream关键字的接口方法rpc GetStreamData(Request) returns (stream Response)，然后使用protoc生成Go代码，接着在服务端实现Send()方法循环发送数据并添加延迟模拟实时性，客户端则通过Recv()循环接收直至io.EOF表示流结束，关键在于正确处理流的开启、传输与终止，确保高效稳定的数据传输。
在Go语言中使用gRPC实现服务端流式处理，是一种高效传输大量连续数据的方案。当客户端发起一次请求，服务端可以持续返回多个消息，适用于日志推送、实时数据更新等场景。下面介绍如何通过Golang结合gRPC完成服务端流的实际开发。
定义服务接口
首先，在.proto文件中定义支持服务端流的服务方法。使用stream关键字标明响应为流式数据。
示例proto文件：
syntax = "proto3";package example;
立即学习“go语言免费学习笔记（深入）”；
service DataService { rpc GetStreamData (Request) returns (stream Response); }
message Request { string query = 1; }
message Response { string data = 1; int64 timestamp = 2; }
上述定义表示，客户端发送一个Request，服务端将返回一系列Response消息。
生成gRPC代码
使用protoc和gRPC插件生成Go代码：
protoc --go_out=. --go-grpc_out=. proto/data.proto
这会生成data.pb.go和data_grpc.pb.go两个文件，包含服务接口和数据结构定义。
实现服务端逻辑
在Go中实现服务端流的核心是使用方法中生成的Send()函数逐条发送数据。
示例服务实现：
package mainimport ( "context" "log" "net"
"google.golang.org/grpc" pb "your-module/proto")
type server struct { pb.UnimplementedDataServiceServer }
func (s server) GetStreamData(req pb.Request, stream pb.DataService_GetStreamDataServer) error { for i := 0; i
// 发送一条数据到客户端 if err := stream.Send(response); err != nil { return err } // 模拟延迟 time.Sleep(500 * time.Millisecond) } return nil}
func main() { lis, err := net.Listen("tcp", ":50051") if err != nil { log.Fatalf("failed to listen: %v", err) }
s := grpc.NewServer() pb.RegisterDataServiceServer(s, &server{}) log.Println("gRPC server running on :50051") if err := s.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err) }}
关键点：
- 方法参数包含stream pb.DataService_GetStreamDataServer
- 调用stream.Send()向客户端推送每条数据
- 返回error结束流或通知异常
编写客户端接收流
客户端通过循环调用Recv()读取服务端发来的每一条消息。
conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
client := pb.NewDataServiceClient(conn)
req := &pb.Request{Query: "test"}
stream, err := client.GetStreamData(context.Background(), req)
if err != nil {
log.Fatalf("could not request: %v", err)
}
for {
resp, err := stream.Recv()
if err == io.EOF {
break // 流结束
}
if err != nil {
log.Fatalf("receive error: %v", err)
}
fmt.Printf("Received: %s at %d\n", resp.GetData(), resp.GetTimestamp())
}
注意处理io.EOF表示服务端已关闭流。
基本上就这些。服务端流适合从服务器持续输出数据的场景，实现简单且性能良好。关键是理解Send和Recv的异步模式，避免阻塞主流程。不复杂但容易忽略细节。
