go grpc/retry使用方法:
retryOpt := []grpc_retry.CallOption{ grpc_retry.WithMax(3), // 重试几次 grpc_retry.WithPerRetryTimeout(1 * time.Second), // 超时时间 grpc_retry.WithCodes(codes.Unknown, codes.Unavailable, codes.DeadlineExceeded), // 当返回状态码为这些,也会重试 } var opt []grpc.DialOption opt = append(opt, grpc.WithInsecure()) opt = append(opt, Interceptor) opt = append(opt, grpc.WithUnaryInterceptor(grpc_retry.UnaryClientInterceptor(retryOpt...))) // 连接 conn, err := grpc.Dial(Address, opt...)
发表评论