调用方法:
public static String doGet(String url) {
try {
RequestConfig defaultRequestConfig = RequestConfig.custom()
.setSocketTimeout(200)
.setConnectTimeout(200)
.setConnectionRequestTimeout(200)
.build();
CloseableHttpClient httpclient = HttpClients.custom()
.setDefaultRequestConfig(defaultRequestConfig)
.setRetryHandler(retryHandler())
.build();
return httpGetString(url, httpclient);
} catch (IOException e) {
logger.warn("doGetTimeoutUrl:" + url, e);
return "";
}
}
/**
* 从写重试handler
* @return
*/
private static HttpRequestRetryHandler retryHandler(){
return (exception, executionCount, context) -> {
logger.warn("tryRequest: " + executionCount,exception);
if (executionCount >= 3) {
// Do not retry if over max retry count
return false;
}
if (exception instanceof InterruptedIOException) {
// Timeout
return true;
}
if (exception instanceof UnknownHostException) {
// Unknown host
return true;
}
if (exception instanceof SSLException) {
// SSL handshake exception
return true;
}
HttpClientContext clientContext = HttpClientContext.adapt(context);
HttpRequest request = clientContext.getRequest();
boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
if (idempotent) {
// Retry if the request is considered idempotent
return true;
}
return false;
};
}