📚 课程目录第2章 gRPC基础回顾

2. gRPC基础回顾：gRPC通信模型、HTTP/2多路复用、长连接生命周期管理

2.1 gRPC通信模型

gRPC 是 Google 开源的高性能远程过程调用（RPC）框架，基于 HTTP/2 协议传输，默认使用 Protocol Buffers（protobuf）作为接口定义语言（IDL）和序列化工具。其核心通信模型围绕“服务定义 → 桩代码生成 → 双向流式调用”展开。

通信模式	描述	典型场景
Unary RPC	客户端发送一个请求，服务端返回一个响应	传统请求-响应，如查询用户信息
Server Streaming RPC	客户端发送一个请求，服务端返回多个消息流	日志推送、事件订阅
Client Streaming RPC	客户端发送多个消息流，服务端返回一个响应	批量上传、文件分片写入
Bidirectional Streaming RPC	双方独立发送和接收消息流，无严格顺序约束	实时聊天、协同编辑、长连接心跳

关键理解： 在长连接保持与 GC 停顿场景中，Bidirectional Streaming 是最敏感的通信模式——GC 停顿会导致流式写入阻塞、Ping 超时甚至连接断开。

2.2 HTTP/2 多路复用与长连接基础

gRPC 长连接的核心能力来自 HTTP/2 的 多路复用（Multiplexing） 机制。与 HTTP/1.1 的串行请求-响应不同，HTTP/2 允许在单一 TCP 连接上并发多个双向流（Stream），每个流独立传输帧（Frame）。

  HTTP/2 帧结构关键字段：
  Stream ID：标识帧所属的流，客户端发起的流 ID 为奇数，服务端为偶数。
Type：HEADERS（头部）、DATA（数据）、PING（心跳）、GOAWAY（优雅关闭）、RST_STREAM（重置流）等。
Flags：如 END_STREAM 标记流结束。
Payload：实际数据或控制信息。

2.3 长连接生命周期管理

gRPC 长连接的生命周期从 TCP 握手 + HTTP/2 协商 开始，到 GOAWAY 帧 + 连接关闭 结束。中间经历流创建、数据传输、空闲保活、健康检测等阶段。

2.3.1 连接建立阶段

TCP 三次握手：客户端与服务端建立底层 TCP 连接。
TLS 握手（可选）：若启用 gRPC TLS，在此阶段完成证书交换与加密协商。
HTTP/2 连接前奏（Preface）：客户端发送 PRI * HTTP/2.0 前奏，服务端回复 SETTINGS 帧。
SETTINGS 帧交换：双方协商流控窗口、并发流上限等参数。
gRPC 服务发现：客户端通过 Name Resolver 获取目标地址，发起第一个 RPC 调用。

2.3.2 连接保持阶段

机制	作用	默认行为
HTTP/2 PING 帧	测量 RTT，检测连接是否存活	gRPC-Go 默认每 2 小时发送一次 PING（可配置）
Keepalive（gRPC 层）	应用层心跳，防止 NAT 超时断开	默认 10 秒间隔，超时 5 秒
流控（Flow Control）	基于窗口的流量控制，防止接收方过载	初始窗口 64KB，动态调整
空闲连接超时	无活动流时自动关闭连接	gRPC-Go 默认 5 分钟

GC 停顿风险点： 当 JVM 发生 Full GC（尤其是 CMS 或 G1 的并发标记阶段）时，应用线程可能停顿数百毫秒甚至数秒。在此期间：
• gRPC Keepalive 无法发送 PING 帧 → 服务端判定连接超时 → 触发 RST_STREAM 或 GOAWAY。
• 流式写入缓冲区堆积 → 流控窗口耗尽 → 写入阻塞 → 业务超时。

2.3.3 连接迁移与关闭阶段

gRPC 长连接迁移通常由以下事件触发：

GOAWAY 帧：服务端主动通知客户端即将关闭连接，客户端应停止创建新流，并在现有流完成后迁移。
负载均衡策略：如 round_robin 或 pick_first 在子连接断开时自动切换。
健康检查失败：gRPC Health Checking 返回 NOT_SERVING → 客户端剔除该连接。
GC 停顿导致的超时：客户端 Keepalive 超时 → 主动关闭连接 → 触发重连。

2.4 关键代码片段：gRPC Keepalive 配置

以下 Java 示例展示如何配置 gRPC 客户端 Keepalive 参数，以平衡长连接保持与 GC 停顿容忍度：

// gRPC Java 客户端 Keepalive 配置示例
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 9090)
    .keepAliveTime(10, TimeUnit.SECONDS)          // 每 10 秒发送 PING
    .keepAliveTimeout(5, TimeUnit.SECONDS)        // PING 超时 5 秒
    .keepAliveWithoutCalls(true)                  // 无活跃流时也发送 PING
    .idleTimeout(30, TimeUnit.MINUTES)            // 空闲 30 分钟后关闭连接
    .maxInboundMessageSize(4 * 1024 * 1024)       // 4MB 消息限制
    .build();

调优建议： 在 GC 停顿敏感场景下，适当增大 keepAliveTimeout（如 10 秒）可避免因短暂停顿导致的误判连接断开。同时配合 retryPolicy 实现自动重连。