httpclient 使用

连接池配置

private static final int MAX_CONN_TOTAL = 500;
private static final int MAX_CONN_PER_ROUTE = 50;
private static final int TIMEOUT = 4000;
private static CloseableHttpClient client;

static {
    Builder builder = RequestConfig.custom();
    builder.setSocketTimeout(TIMEOUT).setConnectTimeout(TIMEOUT).setConnectionRequestTimeout(TIMEOUT);
    /*
         * 4.3以上版本推荐使用HttpClientBuilder来创建client
         *
         * <pre>
         * 1、HttpClientBuilder.setRetryHandler(HttpRequestRetryHandler retryHandler);请求重试处理。
         * 2、HttpClientBuilder.setRedirectStrategy(RedirectStrategy redirectStrategy);设置重定向。
         * 3、httpClientBuilder.setDefaultCookieStore(BasicCookieStore cookieStore);设置cookie store
         * 4、HttpClientBuilder.setProxy(HttpHost proxy);设置代理服务器。
         * 5、HttpClientBuilder.setDefaultRequestConfig(RequestConfig config);在此亦可设置RequestConfig。
         * 6、HttpClientBuilder.setUserAgetn(String userAgent);设置用户代理。
         * </pre>
         */
    HttpClientBuilder clientBuilder = HttpClients.custom();

    // 配置 SSL、TLS
    // httpClientBuilder.setSSLSocketFactory(sslSocketFactory);

    // builder.setExpectContinueEnabled(true).setStaleConnectionCheckEnabled(true)
    // .setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM,
    // AuthSchemes.DIGEST))
    // .setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC));
    builder.setCookieSpec(CookieSpecs.IGNORE_COOKIES);

    RequestConfig defaultRequestConfig = builder.build();
    clientBuilder.setDefaultRequestConfig(defaultRequestConfig);
    // 主要连接池配置代码
    // 默认是：20
    clientBuilder.setMaxConnTotal(MAX_CONN_TOTAL);
    // 默认是：2
    clientBuilder.setMaxConnPerRoute(MAX_CONN_PER_ROUTE);

    // SSL
    try {
        // TLS
        SSLContext sc = SSLContext.getInstance("SSL");
        MyX509TrustManager trustManager = new MyX509TrustManager();
        sc.init(null, new TrustManager[]{trustManager}, new java.security.SecureRandom());
        // 设置协议http和https对应的处理socket链接工厂的对象
        Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
            .register("http", PlainConnectionSocketFactory.INSTANCE)
            .register("https", new SSLConnectionSocketFactory(sc)).build();
        PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(registry);
        // 主要连接池配置代码
        // 默认是：20
        // connManager.setMaxTotal(MAX_CONN_TOTAL);
        // 默认是：2
        // connManager.setDefaultMaxPerRoute(MAX_CONN_PER_ROUTE);
        clientBuilder.setConnectionManager(connManager);
    } catch (Exception e) {
        e.printStackTrace();
    }
    client = clientBuilder.build();
}