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

SpringBootWEB系列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


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