首页 > 技术文章 > 针对HttpClient 重写 HttpRequestRetryHandler针对特定异常 增加重试

tonyauto 2019-07-22 15:12 原文




调用方法:
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; }; }

 

推荐阅读