springboot 学习之路 24 （集成httpclient连接池技术）

springboot 集成Httpclient连接池外调webservice接口:

　　httpclient : https://www.yiibai.com/httpclient/httpclient-overview.html

集成步骤：

　　第一步：下载pom文件：

　　　　

　　第二步：修改配置文件：

　　　　

　　第三步：配置类：

　　　　

package com.xf.station.config;

import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.PropertySource;
import org.springframework.stereotype.Component;

import java.io.IOException;

/**
 * @author : huhy on 2018/10/22.
 * @Project_name:springboot_self_gitlab
 * @LOCAL:com.huhy.demo.httpclient
 * @description:{todo}
 */
@Component
@PropertySource(value = {"classpath:config/httpclient.properties"},encoding = "UTF-8",ignoreResourceNotFound = true)
public class HttpClientConfig {

        @Value("${http.maxTotal}")
        private Integer maxTotal;

        @Value("${http.defaultMaxPerRoute}")
        private Integer defaultMaxPerRoute;

        @Value("${http.connectTimeout}")
        private Integer connectTimeout;

        @Value("${http.connectionRequestTimeout}")
        private Integer connectionRequestTimeout;

        @Value("${http.socketTimeout}")
        private Integer socketTimeout;

        @Value("${http.staleConnectionCheckEnabled}")
        private boolean staleConnectionCheckEnabled;

        /**
         * 首先实例化一个连接池管理器，设置最大连接数、并发连接数
         * @return
         */
        @Bean(name = "httpClientConnectionManager")
        public PoolingHttpClientConnectionManager getHttpClientConnectionManager(){
            PoolingHttpClientConnectionManager httpClientConnectionManager = new PoolingHttpClientConnectionManager();
            //最大连接数
            httpClientConnectionManager.setMaxTotal(maxTotal);
            //并发数
            httpClientConnectionManager.setDefaultMaxPerRoute(defaultMaxPerRoute);
            return httpClientConnectionManager;
        }

        /**
         * 实例化连接池，设置连接池管理器。
         * 这里需要以参数形式注入上面实例化的连接池管理器
         * @param httpClientConnectionManager
         * @return
         */
        @Bean(name = "httpClientBuilder")
        public HttpClientBuilder getHttpClientBuilder(@Qualifier("httpClientConnectionManager")PoolingHttpClientConnectionManager httpClientConnectionManager){

            //HttpClientBuilder中的构造方法被protected修饰，所以这里不能直接使用new来实例化一个HttpClientBuilder，可以使用HttpClientBuilder提供的静态方法create()来获取HttpClientBuilder对象
            HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();

            httpClientBuilder.setConnectionManager(httpClientConnectionManager);

            return httpClientBuilder;
        }

        /**
         * 注入连接池，用于获取httpClient
         * @param httpClientBuilder
         * @return
         */
        @Bean
        public CloseableHttpClient getCloseableHttpClient(@Qualifier("httpClientBuilder") HttpClientBuilder httpClientBuilder){
            return httpClientBuilder.build();
        }

        /**
         * Builder是RequestConfig的一个内部类
         * 通过RequestConfig的custom方法来获取到一个Builder对象
         * 设置builder的连接信息
         * 这里还可以设置proxy，cookieSpec等属性。有需要的话可以在此设置
         * @return
         */
        @Bean(name = "builder")
        public RequestConfig.Builder getBuilder(){
            RequestConfig.Builder builder = RequestConfig.custom();
            return builder.setConnectTimeout(connectTimeout)
                    .setConnectionRequestTimeout(connectionRequestTimeout)
                    .setSocketTimeout(socketTimeout);
        }

        /**
         * 使用builder构建一个RequestConfig对象
         * @param builder
         * @return
         */
        @Bean
        public RequestConfig getRequestConfig(@Qualifier("builder") RequestConfig.Builder builder){
            return builder.build();
        }


}

　　第四步:测试：