func callWithRetry(client *rpc.Client, serviceMethod string, args interface{}, reply interface{}, timeout time.Duration, maxRetries int) error {
    var err error
    for i := 0; i <= maxRetries; i++ {
        ctx, cancel := context.WithTimeout(context.Background(), timeout)
        defer cancel()
<pre class='brush:php;toolbar:false;'>    done := make(chan error, 1)
    go func() {
        err = client.Call(serviceMethod, args, reply)
        done <- err
    }()

    select {
    case <-ctx.Done():
        err = ctx.Err()
    case err = <-done:
        if err == nil {
            return nil // 成功则退出
        }
    }

    // 失败则等待后重试（可加入指数退避）
    if i < maxRetries {
        time.Sleep(100 * time.Millisecond)
    }
}
return err

}

conn, err := grpc.Dial("localhost:50051",
    grpc.WithInsecure(),
    grpc.WithUnaryInterceptor(
        retry.UnaryClientInterceptor(
            retry.WithMax(3),
            retry.WithBackoff(retry.BackoffExponential(100*time.Millisecond)),
        ),
    ),
)
if err != nil { ... }
<p>// 调用时设置超时
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
defer cancel()</p><p>var response pb.Response
err = grpc.Invoke(ctx, "/Service/Method", &request, &response, conn)</p>

operation := func() error {
    ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
    defer cancel()
<pre class='brush:php;toolbar:false;'>err := client.Call("Service.Method", args, reply)
return err

}

err := backoff.Retry(operation, backoff.WithMaxRetries(backoff.NewExponentialBackOff(), 3)) if err != nil { log.Fatal("RPC failed after retries:", err) }