- DefClientTimeout调整为5秒
- DefMaxRecoverableRetryCount调整为1
This commit is contained in:
@@ -17,10 +17,9 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
DefClientTimeout = 10 * time.Second
|
DefClientTimeout = 5 * time.Second
|
||||||
DefSleepSecondWhenExceedLimit = 3 * time.Second
|
DefSleepSecondWhenExceedLimit = 3 * time.Second
|
||||||
DefRandSlice = 10
|
DefMaxRecoverableRetryCount = 1
|
||||||
DefMaxRecoverableRetryCount = 3
|
|
||||||
DefMaxExceedLimitRetryCount = 25
|
DefMaxExceedLimitRetryCount = 25
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -106,8 +105,8 @@ func AccessPlatformAPIWithRetry(client *http.Client, handleRequest func() *http.
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
baseapi.SugarLogger.Debugf("AccessPlatformAPIWithRetry:%s client.Get return err:%v", trackID, err)
|
baseapi.SugarLogger.Debugf("AccessPlatformAPIWithRetry:%s client.Get return err:%v", trackID, err)
|
||||||
err, ok := err.(net.Error)
|
err, ok := err.(net.Error)
|
||||||
|
recoverableErrorRetryCount++
|
||||||
if ok /*&& err.Timeout()*/ && recoverableErrorRetryCount <= config.MaxRecoverableRetryCount { // 只要是网络错误都重试
|
if ok /*&& err.Timeout()*/ && recoverableErrorRetryCount <= config.MaxRecoverableRetryCount { // 只要是网络错误都重试
|
||||||
recoverableErrorRetryCount++
|
|
||||||
continue
|
continue
|
||||||
} else {
|
} else {
|
||||||
baseapi.SugarLogger.Errorf("AccessPlatformAPIWithRetry:%s access api url:%v, request:%v, error:%v", trackID, request.URL, getClonedData(request.URL, savedBuf), err)
|
baseapi.SugarLogger.Errorf("AccessPlatformAPIWithRetry:%s access api url:%v, request:%v, error:%v", trackID, request.URL, getClonedData(request.URL, savedBuf), err)
|
||||||
|
|||||||
Reference in New Issue
Block a user