什么是重试
如果服务出现了错误，主要是网络，服务器出现了短暂异常的时候，该怎么办？
我们都会人工或者自动的重新连接服务试试，看服务是否恢复可用了。
这种重新进行连接服务的一种方式就是重试。如果是在微服务里，应该属于微服务治理的范畴。
重试是处理网络服务出现暂时不可用的一种方法。
怎么进行重试
第一：你要能知道网络出现了错误。
怎么才能知道网络出现了错误呢？
一种是你主动探测网络是否可用，比如说健康检查；一种是根据定义的错误码来进行重试。比如http的一些错误码。
第二：根据上面的探测或者错误码决定是否重试。
因为不是所有的错误都要进行重试，我们要根据具体情况来做决定是否重试。
第三：重试的策略
就是怎么进行重试。
在gRPC的这份设计中，主要有2中重试策略：
-
Retry Policy，出错时立即重试
-
Hedging Policy，定时发送并发的多个请求，根据请求的响应情况决定是否发送下一个同样的请求，还是返回（好像该策略目前未实现）
-
在Retry和Heading基础上的限流
客户端的重试策略和限流策略都是用一个配置文件配置 - service config，这个配置文件用proto定义了一些字段和格式，文件在 grpc/service_config/service_config.proto 中，它最终会解析为一个json格式，proto->json 规则文档。
一些Service Config文档例子：doc/service_config
例子
参考官方的例子把我们前面的hello word程序用retry策略改写下。
客户端
主要是要在 Dial() 建立连接的这个函数里加一个参数 grpc.WithDefaultServiceConfig() ，这个就是配置重试策略的参数。
conn, err := grpc.Dial(Address, grpc.WithInsecure(),grpc.WithDefaultServiceConfig(retryPolicy))
里面的参数 retryPolicy 是一个json的字符串，这个就是service config：
retryPolicy = `{
"methodConfig":[{
"name":[{"service": "grpc-tutorial.05retry.hello.hello"}],
"waitForReady": true,
"retryPolicy": {
"MaxAttempts": 4,
"InitialBakckoff": ".01s",
"MaxBackoff": ".01s",
"BackoffMultiplier": 1.0,
"RetryableStatusCodes": ["UNAVAILABLE"]
}
}]}`
- MaxAttempts：
最多请求次数。这里设置为4，一次原始请求，三次重试请求。
MaxAttempts必须是大于1的整数，对于大于5的值会被视为5。
- InitialBakckoff, BackoffMultiplier, MaxBackoff
这3个参数要结合看, 意思是在进行下一次重试请求前，会计算需要等待的时间，计算公式为：- 第一次重试间隔是
random(0, InitialBakckoff) - 第 n 次的重试间隔为
random(0, min( InitialBakckoff*BackoffMultiplier*(n-1) , MaxBackoff ))
- 第一次重试间隔是
InitialBakckoff 和 MaxBackoff 必须指定，并且必须具有大于0。
BackoffMultiplier 必须指定，并且大于零。
- RetryableStatusCodes
会根据这个RetryableStatusCodes来判断是否进行重试。这里设置为UNAVAILABLE，会根据这个状态来进行重试。
retryableStatusCodes 必须制定为状态码的数据，不能为空，并且没有状态码必须是有效的 gPRC 状态码，可以是整数形式，并且不区分大小写 ([14], [“UNAVAILABLE”], [“unavailable”)
服务端
在服务端我要制造重试的情况出来，主要是 failRequest() 这个函数，改写一下程序：
type failServer struct {
pb.UnimplementedHelloServer
mu sync.Mutex
reqNum uint
reqMax uint
}
func (f *failServer) failRequest() error {
f.mu.Lock()
defer f.mu.Unlock()
f.reqNum++
if (f.reqMax > 0) && (f.reqNum % f.reqMax == 0) {
return nil
}
return status.Errorf(codes.Unavailable, "failRequest: failing it")
}
然后在main函数初始化一下这个failServer struct：
failService := &failServer{
reqNum: 0,
reqMax: 4,
}
完整的例子在：这里github
运行看看：
先运行服务端：go run server/main.go
在运行客户端：GRPC_GO_RETRY=on go run client/main.go
注意：
运行客户端一定要在环境变量里加上 GRPC_GO_RETRY=on
可是报错了：
sayhello err: rpc error: code = Unavailable desc = failRequest: failing it
exit status 1
而且服务端也只打印了一条信息：
request failed num: 1