Java httpClient连接池支持多线程高并发的实现

 import org.apache.http.HttpEntity; import org.apache.http.HttpEntityEnclosingRequest; import org.apache.http.HttpRequest; import org.apache.http.NoHttpResponseException; import org.apache.http.client.HttpRequestRetryHandler; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.conn.ConnectTimeoutException; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.protocol.HttpContext; import org.apache.http.util.EntityUtils; import java.io.IOException; import java.io.InterruptedIOException; import java.net.UnknownHostException; import java.util.HashMap; import java.util.Map; public class WebTools { public static String KEY_STATUS_CODE = "statusCode"; public static String KEY_CONTENT = "content"; private final static PoolingHttpClientConnectionManager poolConnManager = new PoolingHttpClientConnectionManager();  //连接池管理器 private final static HttpRequestRetryHandler httpRequestRetryHandler = new HttpRequestRetryHandler() {  //retry handler public boolean retryRequest(IOException exception, int executionCount, HttpContext context) { if (executionCount >= 5) { return false; } if (exception instanceof NoHttpResponseException) { return true; } if (exception instanceof InterruptedIOException) { return false; } if (exception instanceof UnknownHostException) { return false; } if (exception instanceof ConnectTimeoutException) { return false; } HttpClientContext clientContext = HttpClientContext .adapt(context); HttpRequest request = clientContext.getRequest(); if (!(request instanceof HttpEntityEnclosingRequest)) { return true; } return false; } }; static {   //类加载的时候 设置最大连接数 和 每个路由的最大连接数 poolConnManager.setMaxTotal(2000); poolConnManager.setDefaultMaxPerRoute(1000); } /** * ########################### core code####################### * @return */ private static CloseableHttpClient getCloseableHttpClient() { CloseableHttpClient httpClient = HttpClients.custom() .setConnectionManager(poolConnManager) .setRetryHandler(httpRequestRetryHandler) .build(); return httpClient; } /** * buildResultMap * * @param response * @param entity * @return * @throws IOException */ private static Map buildResultMap(CloseableHttpResponse response, HttpEntity entity) throws IOException { Map result; result = new HashMap<>(2); result.put(KEY_STATUS_CODE, response.getStatusLine().getStatusCode());  //status code if (entity != null) { result.put(KEY_CONTENT, EntityUtils.toString(entity, "UTF-8")); //message content } return result; } /** * send json by post method * * @param url * @param message * @return * @throws Exception */ public static Map postJson(String url, String message) { Map result = null; CloseableHttpClient httpClient = getCloseableHttpClient(); HttpPost httpPost = new HttpPost(url); CloseableHttpResponse response = null; try { httpPost.setHeader("Accept", "application/json;charset=UTF-8"); httpPost.setHeader("Content-Type", "application/json"); StringEntity stringEntity = new StringEntity(message); stringEntity.setContentType("application/json;charset=UTF-8"); httpPost.setEntity(stringEntity); response = httpClient.execute(httpPost); HttpEntity entity = response.getEntity(); result = buildResultMap(response, entity); } catch (Exception e) { e.printStackTrace(); } finally { if (response != null) { try { EntityUtils.consume(response.getEntity()); response.close(); } catch (IOException e) { e.printStackTrace(); } } } return result; } }