golang如何实现gRPC四种通信模式_golang gRPC四种通信模式实现方法-Golang-PHP中文网

gRPC四种通信模式由.proto文件中stream关键字决定：一元（无stream）、服务端流（返回值带stream）、客户端流（参数带stream）、双向流（参数和返回值均带stream）；大小写敏感，必须小写stream，且需配对定义对应message类型。

golang如何实现grpc四种通信模式_golang grpc四种通信模式实现方法

gRPC 的四种通信模式不是靠“选配置”切换的，而是由 .proto 文件里方法声明中的 stream 关键字决定的。写错一个 stream，生成的 Go 接口类型就完全不一样，客户端和服务端代码会编译不过或运行时报 UNIMPLEMENTED。

怎么在 .proto 里正确声明四种模式

.proto 文件是唯一源头，所有模式差异都体现在 service 方法签名上：

一元（Unary）：不带 stream，参数和返回值都是单个 message
服务端流（Server Streaming）：返回值带 stream，如 rpc StreamLogs(LogRequest) returns (stream LogResponse);
客户端流（Client Streaming）：参数带 stream，如 rpc Upload(stream Chunk) returns (UploadResult);
双向流（Bidirectional Streaming）：参数和返回值都带 stream，如 rpc Chat(stream Message) returns (stream Message);

常见错误：

把 stream 写成 Stream（大小写敏感，必须小写）
忘记为流式方法配对定义对应的 message 类型（比如只写了 stream Foo，但没定义 message Foo）
在 Unary 方法里误加 stream，导致生成的 Server 接口变成 XXX_YYYServer 类型，而你却按 context.Context + *Req 实现，编译直接报错

生成代码时漏掉 --go-grpc_out 就等于白干

protoc 命令必须同时指定 --go_out 和 --go-grpc_out，否则：

只用 --go_out：只生成 .pb.go（数据结构），没有 XXXClient、XXXServer 接口，调用 pb.NewXXXClient(conn) 会报 undefined
只用 --go-grpc_out：不生成消息结构，go build 会提示找不到 pb.XXXRequest 等类型

正确命令示例：

protoc --go_out=. --go-grpc_out=. --go-grpc_opt=paths=source_relative streaming.proto

注意：

protoc-gen-go 和 protoc-gen-go-grpc 插件都要 go install 过，且版本需匹配（2026 年推荐用 @latest，避免 v1/v2 混用）
如果 .proto 在子目录，--go_opt=paths=source_relative 能让生成文件路径与 proto 路径一致，不然 import 路径容易出错

服务端实现流式方法时 goroutine 和 context.Done() 是关键

流式方法的 Server 参数类型不是 context.Context，而是类似 StreamService_ServerStreamServer，它自带 Send()、Recv() 和 Context()。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

必须注意：

服务端流（Server Streaming）不能在主线程里阻塞循环发送——要起 goroutine，否则会卡住整个 RPC 处理协程
客户端流（Client Streaming）必须显式循环调用 Recv()，直到返回 io.EOF 或 error；不检查 err == io.EOF 就继续读，会 panic
所有流式方法都该监听 stream.Context().Done()，客户端断连或超时时及时退出循环，避免 goroutine 泄漏
Send() 失败（如网络中断）应直接 return error，gRPC 框架会自动关闭流；不要忽略 err 后继续 send

示例片段（服务端流）：

func (s *server) ServerStream(req *pb.Request, stream pb.StreamService_ServerStreamServer) error {
    // 启动 goroutine 避免阻塞
    go func() {
        defer stream.Context().Done() // 不是必须，但可辅助清理
        for i := 0; i <hr><h3>客户端调用流式方法后，Recv()/Send() 必须成对、及时处理</h3><p>客户端拿到的 stream 对象（如 <code>StreamService_ClientStreamClient</code>）不是“发完就完”，而是需要主动驱动：</p>

服务端流：调用 stream.Recv() 循环读，每次读一个响应；收到 io.EOF 表示服务端结束，不是错误
客户端流：先用 stream.Send() 发多个请求，再调用 stream.CloseAndRecv() 等最终响应；不调 CloseAndRecv()，服务端 recv 循环不会退出
双向流：可并发 go routine 分别处理 Send() 和 Recv()，但要注意 channel 关闭时机和 context 控制