RestTemplate连接池

  • Post author:
  • Post category:其他


1.HTTP长连接、短连接

HTTP协议的长连接和短连接,实质上是TCP协议的长连接和短连接。在HTTP/1.0中默认使用短连接。也就是说,客户端和服务器每进行一次HTTP操作,就建立一次连接,任务结束就中断连接。

HTTP/1.1起,默认使用长连接,用以保持连接特性。使用长连接的HTTP协议,会在响应头加入这行代码:Connection:keep-alive.在使用长连接的情况下,客户端和服务器之间用于传输HTTP数据的TCP连接不会关闭,客户端再次访问这个服务器时,会继续使用这一条已经建立的连接。Keep-Alive不会永久保持连接,它有一个保持时间,可以在不同的服务器软件(如Apache)中设定这个时间。实现长连接需要客户端和服务端都支持长连接。

2. RestTemplate 构造函数

  • RestTemplate() //无参
  • RestTemplate(List> messageConverters) //messageConverters转换实现类
  • RestTemplate(ClientHttpRequestFactory requestFactory) //客户端连接工厂

著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

3.ClientHttpRequestFactory实现

  • SimpleClientHttpRequestFactory(封装URLConnection) //默认的超时时间设置为-1,若出现服务器宕机的情况,该连接将永远不会被释放。
  • HttpComponentsClientHttpRequestFactory (封装HttpClient)
  • OkHttp3ClientHttpRequestFactory (封装OKHttp)

4.RestTemplate连接线程池实现

RestTemplate连接线程池,需要使用其他的 HTTP 库(默认使用的是 JDK 自己的),比如 HttpComponents、Netty、OkHttp。

@Configuration
public class RestTemplateConfig {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(httpRequestFactory());
    }

    @Bean
    public ClientHttpRequestFactory httpRequestFactory() {
        return new HttpComponentsClientHttpRequestFactory(httpClient());
    }

    @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(400);
 
        //路由是对maxTotal的细分
        connectionManager.setDefaultMaxPerRoute(100);
        RequestConfig requestConfig = RequestConfig.custom()
                .setSocketTimeout(30000)  //返回数据的超时时间
                .setConnectTimeout(10000) //连接上服务器的超时时间
                .setConnectionRequestTimeout(1000) //从连接池中获取连接的超时时间
                .build();
        return HttpClientBuilder.create()
                .setDefaultRequestConfig(requestConfig)
                .setConnectionManager(connectionManager)
                .build();
    }
}



版权声明:本文为myli92原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。