gRPC Unix套接字遇EOF后无法自动重连，求原因及调试方案

问题根源 #

1. IDLE状态无主动重连触发：gRPC客户端处于IDLE状态时不会主动发起重连，必须有新的RPC请求触发。你的waitUntilReady循环仅等待状态变更，无法触发重连动作，导致卡在IDLE状态。
2. 自定义拨号器错误包装干扰重连逻辑：拨号器中用fmt.Errorf包装了原始错误，gRPC无法识别标准连接错误类型，从而跳过重连流程。
3. 流断开后未触发新RPC请求：fooUpdater的流报错返回后，仅发送重连信号但未发起新的RPC调用，无法触发gRPC的重连机制。

修复方案 #

1. 修改waitUntilReady，主动触发重连 #

在检测到IDLE状态时，发起一个空RPC调用强制触发gRPC重连逻辑：

func waitUntilReady(ctx context.Context, conn *grpc.ClientConn, maxTimeout time.Duration) bool {
    ctx, cancel := context.WithTimeout(ctx, maxTimeout)
    defer cancel()

    currentState := conn.GetState()
    timeoutValid := true

    for currentState != connectivity.Ready && timeoutValid {
        if currentState == connectivity.Idle {
            // 发起空RPC触发重连（替换为你服务端实际的空方法，比如Ping）
            client := pb.NewFooClient(conn)
            _, _ = client.Ping(ctx, &pb.Empty{})
        }
        timeoutValid = conn.WaitForStateChange(ctx, currentState)
        currentState = conn.GetState()
    }

    return currentState == connectivity.Ready
}

2. 简化自定义拨号器的错误返回 #

直接返回原始错误，确保gRPC能识别连接错误：

grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
    d := net.Dialer{}
    return d.DialContext(ctx, "unix", addr)
}),

3. 调整goroutineOne逻辑，确保重连后重建流 #

流报错返回后，重新等待连接就绪再创建新流，避免在未就绪状态下发起请求：

func goroutineOne(ctx context.Context, dataBuffer custom.CircularBuffer, myConn *grpc.ClientConn) error {
    reconnect := make(chan struct{})

    for {
        if ready := waitUntilReady(ctx, myConn, 2*time.Minute); !ready {
            return fmt.Errorf("myConn: %w, timeout: 2m", ErrWaitReadyTimeout)
        }
        
        go func() {
            err := fooUpdater(ctx, dataBuffer, myConn)
            if err != nil {
                log.Errorf("foo updater: %v", err)
            }
            reconnect <- struct{}{}
        }()

        select {
        case <-ctx.Done():
            return nil
        case <-reconnect:
            // 清空缓冲残留数据，避免重连后发送旧数据
            for len(dataBuffer) > 0 {
                <-dataBuffer
            }
        }
    }
}

调试提示 #

• 开启gRPC调试日志：设置环境变量查看内部连接日志：

  export GRPC_GO_LOG_VERBOSITY_LEVEL=99
  export GRPC_GO_LOG_SEVERITY_LEVEL=info
  

• 实时监控连接状态：在waitUntilReady中添加状态打印，确认是否进入CONNECTING状态：

  log.Debugf("Current connection state: %v", currentState)
  

• 检查Unix套接字权限：服务端重启后，确认/var/run/foo.bar的所有者、权限是否允许客户端读写（建议设置为rw-rw-r--或对应用户组权限）。
• 验证退避参数：在调试日志中搜索backoff关键词，确认BaseDelay、MaxDelay等参数是否按配置生效。

内容的提问来源于stack exchange，提问作者gtatr