连接管理与 Keepalive 心跳机制

gRPC 基于 HTTP/2 长连接进行通信。在云原生网络、跨机房专线或容器网络中，基础设施中的防火墙、NAT 网关和云负载均衡器（如 AWS NLB/ALB、LVS）通常会静默切断处于空闲状态的 TCP 连接（不发送任何 FIN 或 RST 包）。

如果不开启主动心跳探测，客户端会认为该连接仍然处于可用状态，当下一次请求发出时，由于数据包被中间网络节点丢弃，请求将陷入长达数分钟的 TCP 重传阻塞中。

---

1. gRPC 连接状态机（Connectivity States）

gRPC 客户端内部维护着一个标准的状态机来管理连接的生命周期：

stateDiagram-v2
    [*] --> IDLE: 创建通道 Channel
    IDLE --> CONNECTING: 触发首个 RPC 调用
    CONNECTING --> READY: TCP 握手 + TLS 协商成功
    READY --> IDLE: 长期无请求空闲回退
    READY --> TRANSIENT_FAILURE: 发生网络中断/服务重启
    CONNECTING --> TRANSIENT_FAILURE: 连接握手失败
    TRANSIENT_FAILURE --> CONNECTING: 指数退避重试建连
    READY --> SHUTDOWN: 显式调用 Close()
    IDLE --> SHUTDOWN: 关闭通道
    SHUTDOWN --> [*]

• IDLE（空闲）：未建立物理连接，不占用底层 socket。
• CONNECTING（正在建连）：正在进行 DNS 解析、TCP 握手及 TLS 协商。
• READY（就绪）：连接成功，可以随时承载 RPC 数据流。
• TRANSIENT_FAILURE（暂时失效）：出现网络抖动或服务端断开，客户端将触发指数退避机制（Exponential Backoff）自动重新建连。
• SHUTDOWN（已终止）：通道已被显式关闭，不可再使用。

---

2. Keepalive 运行原理与 HTTP/2 PING 帧

gRPC 的 Keepalive 心跳基于 HTTP/2 协议原生的 PING 帧（长度固定为 8 字节 Payload）：

sequenceDiagram
    autonumber
    participant Client as 客户端
    participant Server as 服务端

    Note over Client: 空闲达到 ClientParameters.Time
    Client->>Server: HTTP/2 PING Frame (携带 8 字节随机 Payload)
    Note over Server: 收到 PING，必须立即应答
    Server-->>Client: HTTP/2 PING Frame (ACK 标志置位，回显相同 Payload)
    Note over Client: 在 Timeout 时间内成功收到 ACK，判定连接健康

    Note over Client: 若网络中断，Timeout 内未收到 ACK
    Client->>Client: 立即判定连接不可用，状态转为 TRANSIENT_FAILURE 并触发重连

---

3. 服务端防攻击策略与 ENHANCE_YOUR_CALM 异常

如果成千上万的客户端频繁向服务端轰炸 PING 帧，会严重消耗服务端的 CPU 资源。因此服务端引入了严格的 强制策略（Enforcement Policy）：

[!WARNING] 常见故障：ENHANCE_YOUR_CALM 错误 如果客户端发送 PING 的频率超过了服务端设定的 MinTime 阈值，服务端会认为遭受了心跳洪泛攻击（Ping Flood），会立即返回一个 HTTP/2 GOAWAY 帧，错误码为 ENHANCE_YOUR_CALM (0xb) 并强制掐断连接！

---

4. 生产推荐配置示例

服务端配置（Go 语言）

package main

import (
    "time"
    "google.golang.org/grpc"
    "google.golang.org/grpc/keepalive"
)

func newServerWithKeepalive() *grpc.Server {
    // 1. 服务端强制策略
    ep := keepalive.EnforcementPolicy{
        MinTime:             5 * time.Second, // 允许客户端发送 PING 的最小间隔
        PermitWithoutStream: true,            // 允许在没有活跃 RPC 流时接收 PING
    }

    // 2. 服务端主动探活参数
    sp := keepalive.ServerParameters{
        MaxConnectionIdle:     15 * time.Minute, // 连接空闲超过 15 分钟则发送 GOAWAY 关闭
        MaxConnectionAge:      30 * time.Minute, // 连接存活超过 30 分钟则优雅关闭（促使客户端重新负载均衡）
        MaxConnectionAgeGrace: 5 * time.Second,  // 关闭前的优雅退出宽限期
        Time:                  1 * time.Minute,  // 连接无任何数据交互 1 分钟后主动发 PING
        Timeout:               5 * time.Second,  // 等待 PING ACK 超过 5 秒则判定连接断开
    }

    return grpc.NewServer(
        grpc.KeepaliveEnforcementPolicy(ep),
        grpc.KeepaliveParams(sp),
    )
}

客户端配置（Go 语言）

func newClientConn(target string) (*grpc.ClientConn, error) {
    kacp := keepalive.ClientParameters{
        Time:                10 * time.Second, // 无活动 10 秒后发送 PING 心跳
        Timeout:             3 * time.Second,  // 等待 PING ACK 3 秒未响应则重置连接
        PermitWithoutStream: true,             // 空闲没有活跃 RPC 时依然发送 PING
    }

    return grpc.Dial(
        target,
        grpc.WithTransportCredentials(insecure.NewCredentials()),
        grpc.WithKeepaliveParams(kacp),
    )
}

[!TIP] 黄金法则：客户端配置的 Time（如 10s）必须大于服务端配置的 EnforcementPolicy.MinTime（如 5s），否则客户端必定会触发 ENHANCE_YOUR_CALM 导致连接异常断开！