本案例近针对org.apache.http.conn.ConnectTimeoutException和java.net.SocketTimeoutException这两类异常进行重试;
直接上代码:(重点关注红色部分即可)
public class ApiClient {
/** 重试次数 */
private static final int MAX_TIMES = 3;
/**只保留了核心代码 代码比较简单;凑合着看哈
* @param queryBean 查询参数,method,host,url,etc.
* @return
*/
public ApiResponse query(QueryBean queryBean) {
ApiRequest apiRequest = new ApiRequest(...);
ApiResponse apiResponse = null;
//默认重试三次,用for循环实现;
for(int index = 0; index <= MAX_TIMES;) {
try {
//首次调用get方法,成功则break;
apiResponse = syncInvoke(apiRequest);
break;
//syncInvoke 会抛出SdkClientException;可以不用关注,该方法在末尾位置;
} catch (SdkClientException e) {
Throwable throwable = e.getCause();
//如果是ConnectTimeoutException异常
if(throwable instanceof ConnectTimeoutException){
//重试次数+1
++index;
//最后一次不打印重试log
if((MAX_TIMES + 1) != index) {
log.error("ConnectTimeoutException:...... retry time = {}", index);
}
//直接跳出本次循环,执行重试;
continue;
}
//如果是SocketTimeoutException
if(throwable instanceof SocketTimeoutException){
//重试次数+1
++index;
//最后一次不打印重试log
if((MAX_TIMES + 1) != index) {
log.error("SocketTimeoutException:...... retry time = {}", index);
}
continue;
}
//非上面写的两种异常,不重试,结束;
log.error("request error",e={}", e);
break;
}
}
return apiResponse;
}
protected final ApiResponse syncInvoke(ApiRequest apiRequest) {
try {
apiRequest = buildSDKRequest(apiRequest);
return httpClient.syncInvoke(apiRequest);
} catch (IOException e) {
throw new SdkClientException(e);
}
}
}