转载

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

我又回来更新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. 项目&系列博文

博文

  • 【WEB系列】RestTemplate之文件上传
  • 【WEB系列】AsyncRestTemplate之异步非阻塞网络请求介绍篇
  • 【WEB系列】RestTemplate之非200状态码信息捕获
  • 【WEB系列】RestTemplate之Basic Auth授权
  • 【WEB系列】RestTemplate之代理访问
  • 【WEB系列】RestTemplate之超时设置
  • 【WEB系列】RestTemplate之中文乱码问题fix
  • 【WEB系列】RestTemplate之自定义请求头
  • 【WEB系列】RestTemplate基础用法小结

源码

  • 工程: https://github.com/liuyueyi/spring-boot-demo
  • 源码: https://github.com/liuyueyi/spring-boot-demo/tree/master/spring-boot/221-web-resttemplate

1. 一灰灰Blog

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

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

  • 一灰灰Blog个人博客 https://blog.hhui.top
  • 一灰灰Blog-Spring专题博客 http://spring.hhui.top

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

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


很遗憾的说,推酷将在这个月底关闭。人生海海,几度秋凉,感谢那些有你的时光。

原文  http://spring.hhui.top/spring-blog/2020/07/23/200723-SpringBoot系列RestTemplate之连接池配置/
正文到此结束
Loading...