Spingboot Resttemplate连接池配置

Spingboot Resttemplate连接池配置

1. 为什么要整合HttpClient
   RestTemplate是Spring自带的一个调用rest服务的客户端,它提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
   RestTemplate默认是使用JDK原生的URLConnection,默认超时为-1, 也就表示是没有超时时间的,这个肯定不能满足复杂情况的使用需求, restTemplate的工厂是支持使用HttpClient和OkHttp来作为客户端实现的

2. 为什么要使用连接池
   在调用rest请求时,每次请求都需要和服务端建立连接,也就是三次握手,这是一个费时费力的工作,如果我们需要频繁对一个服务端进行调用,难道需要一直去建立连接吗?
   所以使用连接池,可以避免多次建立连接的操作,节省资源开支。

package com.jshhxx.framework.config;  import org.apache.http.client.HttpClient; import org.apache.http.client.config.RequestConfig; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.http.client.ClientHttpRequestFactory; import org.springframework.http.client.HttpComponentsClientHttpRequestFactory; import org.springframework.web.client.RestTemplate; /**  * Restemplate 连接池配置  *  * */ @Configuration public class RestTemplateConfig {     @Bean     public RestTemplate restTemplate() {         return new RestTemplate(httpRequestFactory());     }      @Bean     public ClientHttpRequestFactory httpRequestFactory() {          return new HttpComponentsClientHttpRequestFactory(httpClient());      }      /**      * http链接池      * 服务器返回数据(response)的时间，超过该时间抛出read timeout      * @return      */     @Bean     public HttpClient httpClient() {         Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()                 .register("http", PlainConnectionSocketFactory.getSocketFactory())                 .register("https", SSLConnectionSocketFactory.getSocketFactory())                 .build();         PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);         //设置整个连接池最大连接数 根据自己的场景决定         connectionManager.setMaxTotal(2000);         //路由是对maxTotal的细分         connectionManager.setDefaultMaxPerRoute(100);         RequestConfig requestConfig = RequestConfig.custom()                 .setSocketTimeout(100000) //服务器返回数据(response)的时间，超过该时间抛出read timeout                 .setConnectTimeout(50000)//连接上服务器(握手成功)的时间，超出该时间抛出connect timeout                 .setConnectionRequestTimeout(10000)//从连接池中获取连接的超时时间，超过该时间未拿到可用连接，会抛出org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection from pool                 .build();         return HttpClientBuilder.create()                 .setDefaultRequestConfig(requestConfig)                 .setConnectionManager(connectionManager)                 .build();     } }