go grpc/retry使用方法

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...)


最后编辑于:2022/02/28作者: 牛逼PHP

发表评论