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();
        }


}

　　第四步:測試：