10.连接池配置

一灰灰blog约 1043 字大约 3 分钟

我又回来更新RestTemplate了，前面更完之后忽然发现还漏了两个常用的场景，连接池的配置以及错误重试，这就迅速的把这个补上；本篇主要介绍RestTemplate如何设置连接池

I. 项目搭建

本项目基于SpringBoot 2.2.1.RELEASE + maven 3.5.3 + idea进行开发

1. pom依赖

核心pom依赖如下

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
</dependency>

请注意，我们这里引入的依赖，多了一个httpclient，在下面的连接池配置中，主要借助它的连接池管理来创建HttpClient对象

II. 使用姿势

1. 连接池配置

一般来讲，借助httpcomponents这个包进行连接池配置时，可以分为三步

初始化连接池管理类

// 连接池管理
PoolingHttpClientConnectionManager poolingConnectionManager = new PoolingHttpClientConnectionManager();
// 连接池最大连接数
poolingConnectionManager.setMaxTotal(1000);
// 每个主机的并发
poolingConnectionManager.setDefaultMaxPerRoute(100);
// 可用空闲连接过期时间
poolingConnectionManager.setValidateAfterInactivity(10_000);

HttpClient构造器

HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
httpClientBuilder.setConnectionManager(poolingConnectionManager);

RestTemplate RequestFactory创建

HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();
requestFactory.setHttpClient(httpClientBuilder.build());
// 连接超时时间/毫秒
requestFactory.setConnectTimeout(3000); 
// 读写超时时间/毫秒
requestFactory.setReadTimeout(3000);
// 请求超时时间/毫秒
requestFactory.setConnectionRequestTimeout(5000);

到这里基本上就是前面的初始化RestTemplate的环节了

// 创建restemplate对象，并制定 RequestFactory
RestTemplate restTemplate = new RestTemplate();
restTemplate.setRequestFactory(requestFactory);

2. OkHttp方式

对于RestTemplate的HttpClient执行库，除了上面的httpcomponents之外，还有一个OkHttp目前也是大受欢迎，如果我们使用OkHttp，那么可以怎么设置呢?

首先依然是引入依赖

<dependency>
    <groupId>com.squareup.okhttp3</groupId>
    <artifactId>okhttp</artifactId>
</dependency>

其次和上面三步骤差不多的设置

初始化连接池

// 设置连接池参数，最大空闲连接数200，空闲连接存活时间10s
ConnectionPool connectionPool = new ConnectionPool(200, 10, TimeUnit.SECONDS);

创建OkHttpClient

注意这里和上面是有区别的，前面是构建HttpClient构造器，而这里直接生成了一个OkHttpClient，内置连接池

OkHttpClient okHttpClient =
      new OkHttpClient.Builder().retryOnConnectionFailure(false).connectionPool(connectionPool)
              .connectTimeout(3, TimeUnit.SECONDS).readTimeout(3, TimeUnit.SECONDS)
              .writeTimeout(3, TimeUnit.SECONDS).build();

RestTemplate RequestFactory创建

ClientHttpRequestFactory factory = new OkHttp3ClientHttpRequestFactory(okHttpClient);

最后就是创建RestTemplate了

RestTemplate restTemplate = new RestTemplate();
restTemplate.setRequestFactory(factory);

II. 其他

0. 项目&系列博文

博文

源码

10.连接池配置

# I. 项目搭建

# 1. pom依赖

# II. 使用姿势

# 1. 连接池配置

# 2. OkHttp方式

# II. 其他

# 0. 项目&系列博文