【WEB系列】RestTemplate之连接池配置

文章目录
  1. I. 项目搭建
    1. 1. pom依赖
  2. II. 使用姿势
    1. 1. 连接池配置
    2. 2. OkHttp方式
  3. II. 其他
    1. 0. 项目&系列博文
    2. 1. 一灰灰Blog

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

I. 项目搭建

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

1. pom依赖

核心pom依赖如下

1
2
3
4
5
6
7
8
9
<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这个包进行连接池配置时,可以分为三步

初始化连接池管理类

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

HttpClient构造器

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

RestTemplate RequestFactory创建

1
2
3
4
5
6
7
8
HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();
requestFactory.setHttpClient(httpClientBuilder.build());
// 连接超时时间/毫秒
requestFactory.setConnectTimeout(3000);
// 读写超时时间/毫秒
requestFactory.setReadTimeout(3000);
// 请求超时时间/毫秒
requestFactory.setConnectionRequestTimeout(5000);

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

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

2. OkHttp方式

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

首先依然是引入依赖

1
2
3
4
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>

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

初始化连接池

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

创建OkHttpClient

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

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

RestTemplate RequestFactory创建

1
ClientHttpRequestFactory factory = new OkHttp3ClientHttpRequestFactory(okHttpClient);

最后就是创建RestTemplate

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

II. 其他

0. 项目&系列博文

博文

源码

1. 一灰灰Blog

尽信书则不如,以上内容,纯属一家之言,因个人能力有限,难免有疏漏和错误之处,如发现bug或者有更好的建议,欢迎批评指正,不吝感激

下面一灰灰的个人博客,记录所有学习和工作中的博文,欢迎大家前去逛逛

一灰灰blog


打赏 如果觉得我的文章对您有帮助,请随意打赏。
分享到