# 示例 10:流式 RPC 本示例演示 gRPC 的三种流式通信模式:服务端流、客户端流和双向流。 ## Proto 定义 `stream.proto` 定义了三个 RPC 方法,演示每种流式模式。 `go_package` 使用完整的模块路径: ```protobuf option go_package = "example.com/demo/pb"; ``` ## 生成命令 首先,在输出目录中初始化 `go.mod`: ```bash mkdir -p output && cd output && go mod init example.com/demo && cd .. ``` 然后生成代码: ```bash goctl rpc protoc stream.proto \ --go_out=output \ --go-grpc_out=output \ --zrpc_out=output \ --go_opt=module=example.com/demo \ --go-grpc_opt=module=example.com/demo \ --module=example.com/demo \ -I . ``` 生成的目录结构: ``` output/ ├── etc │ └── streamsvc.yaml ├── go.mod ├── internal │ ├── config │ │ └── config.go │ ├── logic │ │ ├── bidistreamlogic.go │ │ ├── clientstreamlogic.go │ │ └── serverstreamlogic.go │ ├── server │ │ └── streamserviceserver.go │ └── svc │ └── servicecontext.go ├── pb │ ├── stream.pb.go │ └── stream_grpc.pb.go ├── streamservice │ └── streamservice.go └── streamsvc.go ``` ## 要点说明 - 支持三种流式模式:服务端流(响应带 `stream`)、客户端流(请求带 `stream`)和双向流(两端都带 `stream`)。 - goctl 为每个流式 RPC 方法生成独立的逻辑文件。 - 流式客户端代码不会自动生成,需直接使用 gRPC 客户端。