Go项目gRPC流式通信实现：Go微服务流式接口与数据传输 - 第1节
1.1 gRPC 简介
gRPC 是 Google 开源的高性能远程过程调用（RPC）框架，基于 HTTP/2 协议传输，默认使用 Protocol Buffers（protobuf）作为接口定义语言（IDL）与序列化工具。它支持双向流、流控、头部压缩等特性，特别适合微服务间的高效通信。
核心特性：
- HTTP/2 多路复用：单一连接可并发处理多个请求/响应，减少连接开销。
- 四种通信模式：一元（Unary）、服务端流、客户端流、双向流。
- 强类型接口：通过 .proto 文件定义服务与消息，生成多语言客户端/服务端桩代码。
- 内置认证与负载均衡：支持 SSL/TLS、Token 认证及透明负载均衡。
1.2 Protocol Buffers 基础
Protocol Buffers（protobuf）是语言中立、平台中立的序列化结构数据格式，比 JSON/XML 更小、更快。通过 .proto 文件定义消息结构，再编译成各语言代码。
1.2.1 消息定义示例
syntax = "proto3";
package user.v1;
message UserRequest {
string user_id = 1;
int32 page_size = 2;
}
message UserResponse {
string user_id = 1;
string name = 2;
string email = 3;
int32 age = 4;
}
service UserService {
rpc GetUser(UserRequest) returns (UserResponse);
rpc ListUsers(UserRequest) returns (stream UserResponse);
}
字段编号规则：1~15 号字段占 1 字节，16~2047 号字段占 2 字节。高频字段应分配小编号以节省空间。
1.2.2 编译与代码生成
使用 protoc 编译器将 .proto 文件生成 Go 代码：
protoc --go_out=. --go-grpc_out=. user/v1/user.proto生成的文件包含：
user.pb.go：消息结构体、序列化/反序列化方法。user_grpc.pb.go：客户端桩代码、服务端注册接口。
1.3 gRPC 与 REST 对比
| 对比维度 | gRPC | REST |
|---|---|---|
| 传输协议 | HTTP/2 | HTTP/1.1 或 HTTP/2 |
| 数据格式 | Protocol Buffers（二进制） | JSON / XML（文本） |
| 接口定义 | .proto 文件（强类型） | OpenAPI / 手动文档（弱类型） |
| 通信模式 | 一元、服务端流、客户端流、双向流 | 请求-响应（支持 SSE 流） |
| 浏览器支持 | 需 gRPC-Web 代理 | 原生支持 |
| 序列化性能 | 高（二进制，零拷贝） | 中（文本解析开销） |
| 适用场景 | 微服务内部通信、实时流、IoT | 公开 API、Web 前端、简单 CRUD |
选型建议：若微服务间需要高频调用、流式推送或低延迟通信，优先选择 gRPC；若面向浏览器或第三方开发者，REST 更通用。
1.4 gRPC 应用场景
gRPC 在微服务架构中主要解决以下四类问题：
- 微服务间同步调用：替代 REST，降低延迟与带宽消耗。
- 实时数据推送：服务端流模式推送日志、监控指标、股票行情。
- 大文件/大数据分块传输：客户端流或双向流实现断点续传、批量处理。
- 多语言异构系统集成：protobuf 生成多种语言桩代码，消除跨语言序列化差异。