文档章节

Spring WebClient vs. RestTemplate

liululee
 liululee
发布于 2019/09/04 22:05
字数 1396
阅读 102
收藏 8

1. 简介

本教程中,我们将对比 Spring 的两种 Web 客户端实现 —— RestTemplate 和 Spring 5 中全新的 Reactive 替代方案 WebClient

2. 阻塞式 vs 非阻塞式客户端

Web 应用中,对其他服务进行 HTTP 调用是一个很常见的需求。因此,我们需要一个 Web 客户端工具。

2.1. RestTemplate 阻塞式客户端

很长一段时间以来,Spring 一直提供 RestTemplate 作为 Web 客户端抽象。在底层,RestTemplate 使用了基于每个请求对应一个线程模型(thread-per-request)的 Java Servlet API。

这意味着,直到 Web 客户端收到响应之前,线程都将一直被阻塞下去。而阻塞代码带来的问题则是,每个线程都消耗了一定的内存和 CPU 周期。

让我们考虑下有很多传入请求,它们正在等待产生结果所需的一些慢服务。

等待结果的请求迟早都会堆积起来。**因此,程序将创建很多线程,这些线程将耗尽线程池或占用所有可用内存。**由于频繁的 CPU 上下文(线程)切换,我们还会遇到性能下降的问题。

2.2. WebClient 非阻塞式客户端

另一方面,WebClient 使用 Spring Reactive Framework 所提供的异步非阻塞解决方案。

RestTemplate 为每个事件(HTTP 请求)创建一个新的 线程 时,WebClient 将为每个事件创建类似于“任务”的东东。幕后,Reactive 框架将对这些 “任务” 进行排队,并仅在适当的响应可用时执行它们。

Reactive 框架使用事件驱动的体系结构。它提供了通过 Reactive Streams API 组合异步逻辑的方法。因此,与同步/阻塞方法相比,Reactive 可以使用更少的线程和系统资源来处理更多的逻辑。

WebClientSpring WebFlux 库的一部分。因此,我们还可以使用流畅的函数式 API 编写客户端代码,并将响应类型(Mono 和 Flux)作为声明来进行组合。

3. 案例对比

为了演示两种方法间的差异,我们需要使用许多并发客户端请求来运行性能测试。在一定数量的并发请求后,我们将看到阻塞方法性能的显著下降。

另一方面,无论请求数量如何,反应式/非阻塞方法都可以提供恒定的性能。

就本文而言,**让我们实现两个 REST 端点,一个使用 RestTemplate,另一个使用 WebClient。**他们的任务是调用另一个响应慢的 REST Web 服务,该服务返回一个 Tweet List。

首先,我们需要引入 Spring Boot WebFlux starter 依赖

<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-webflux</artifactid>
</dependency>

接下来,这是我们的慢服务 REST 端点:

@GetMapping("/slow-service-tweets")
private List<tweet> getAllTweets() {
    Thread.sleep(2000L); // delay
    return Arrays.asList(
      new Tweet("RestTemplate rules", "@user1"),
      new Tweet("WebClient is better", "@user2"),
      new Tweet("OK, both are useful", "@user1"));
}

3.1. 使用 RestTemplate 调用慢服务

现在,让我们来实现另一个 REST 端点,它将通过 Web 客户端调用我们的慢服务。

首先,我们来使用 RestTemplate

@GetMapping("/tweets-blocking")
public List<tweet> getTweetsBlocking() {
    log.info("Starting BLOCKING Controller!");
    final String uri = getSlowServiceUri();

    RestTemplate restTemplate = new RestTemplate();
    ResponseEntity<list<tweet>&gt; response = restTemplate.exchange(
      uri, HttpMethod.GET, null,
      new ParameterizedTypeReference<list<tweet>&gt;(){});

    List<tweet> result = response.getBody();
    result.forEach(tweet -&gt; log.info(tweet.toString()));
    log.info("Exiting BLOCKING Controller!");
    return result;
}

当我们调用这个端点时,由于 RestTemplate 的同步特性,代码将会阻塞以等待来自慢服务的响应。只有当收到响应后,才会执行此方法中的其余代码。通过日志,我们可以看到:

Starting BLOCKING Controller!
Tweet(text=RestTemplate rules, username=@user1)
Tweet(text=WebClient is better, username=@user2)
Tweet(text=OK, both are useful, username=@user1)
Exiting BLOCKING Controller!

3.2. 使用 WebClient 调用慢服务

其次,让我们使用 WebClient 来调用慢服务:

@GetMapping(value = "/tweets-non-blocking", 
            produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<tweet> getTweetsNonBlocking() {
    log.info("Starting NON-BLOCKING Controller!");
    Flux<tweet> tweetFlux = WebClient.create()
      .get()
      .uri(getSlowServiceUri())
      .retrieve()
      .bodyToFlux(Tweet.class);

    tweetFlux.subscribe(tweet -&gt; log.info(tweet.toString()));
    log.info("Exiting NON-BLOCKING Controller!");
    return tweetFlux;
}

本例中,WebClient 返回一个 Flux 生产者后完成方法的执行。一旦结果可用,发布者将开始向其订阅者发送 tweets。注意,调用 /tweets-non-blocking 这个端点的客户端(本例中的 Web 浏览器)也将订阅返回的 Flux 对象。

让我们来观察这次的日志:

Starting NON-BLOCKING Controller!
Exiting NON-BLOCKING Controller!
Tweet(text=RestTemplate rules, username=@user1)
Tweet(text=WebClient is better, username=@user2)
Tweet(text=OK, both are useful, username=@user1)

注意,此端点的方法在收到响应之前就已完成。

4. 结论

本文中,我们探讨了在 Spring 中使用 Web 客户端的两种不同方式。

RestTemplate 使用 Java Servlet API,因此是同步和阻塞的。相反,WebClient 是异步的,在等待响应返回时不会阻塞正在执行的线程。只有当程序就绪时,才会产生通知。

RestTemplate 仍将会被使用。但在某些情况下,与阻塞方法相比,非阻塞方法使用的系统资源要少得多。因此,在这些情况下,WebClient 不失为是更好的选择。

文中提到的所有代码片段,均可在 GitHub 上找到。

> 原文:<https: www.baeldung.com spring-webclient-resttemplate> > > 作者:Drazen Nikolic > > 译者:万想


送福利啦~ 近期将之前已翻译文章,整理成了PDF。 ​ 在公众号后台回复:002即可领取哦~ ​ 后续也会不断更新PDF的内容,敬请期待!

img</https:></tweet></tweet></tweet></list<tweet></list<tweet></tweet></tweet>

© 著作权归作者所有

liululee
粉丝 130
博文 80
码字总数 117498
作品 0
杭州
程序员
私信 提问
Spring Cloud Alibaba基础教程:支持的几种服务消费方式(RestTemplate、WebClient、Feign)

通过《Spring Cloud Alibaba基础教程:使用Nacos实现服务注册与发现》一文的学习,我们已经学会如何使用Nacos来实现服务的注册与发现,同时也介绍如何通过LoadBalancerClient接口来获取某个服...

程序猿DD
2019/01/27
495
0
Spring Cloud Alibaba基础教程:支持的几种服务消费方式

通过《Spring Cloud Alibaba基础教程:使用Nacos实现服务注册与发现》一文的学习,我们已经学会如何使用Nacos来实现服务的注册与发现,同时也介绍如何通过LoadBalancerClient接口来获取某个服...

程序猿DD
2019/09/29
0
0
SpringCloud alibaba微服务之NACOS多环境配置整合

前言 伴随着spring cloud alibaba 登上主板以后,我就去了解下感觉还是蛮不错的。说实话第一次看见Nacos好长一段时间连读法都不知道...(/nɑ:kəʊs/)。按照官方的话说Nacos是:一个更易于...

攻城狮-飞牛
2019/10/14
48
0
Spring Vault 2.2 M1 发布

Spring Vault 2.2 M1 发布了,主要更新如下: 通过使用实例身份证书支持基于 PCF 的身份验证 Kotlin 扩展 RestTemplate 和 WebClient 的构建器,用于自定义拦截器、过滤器函数和默认标头 Va...

xplanet
2019/09/16
1.6K
0
聊聊spring cloud的AsyncLoadBalancerAutoConfiguration

序 本文主要研究一下AsyncLoadBalancerAutoConfiguration AsyncLoadBalancerAutoConfiguration spring-cloud-commons-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/client/loadba......

go4it
2018/07/17
80
0

没有更多内容

加载失败,请刷新页面

加载更多

将数组元素从一个数组位置移动到另一数组位置

我很难弄清楚如何移动数组元素。 例如,给出以下内容: var arr = [ 'a', 'b', 'c', 'd', 'e']; 我为什么能写入移动功能'd'之前, 'b' ? 或'a'后'c' ? 移动之后,应更新其余元素的索引。 ......

javail
50分钟前
52
0
金蝶EAS DEP 服务端 脚本

1、服务端执行SQL //服务端更新单据状态var imp = JavaImporter(); imp.importPackage(Packages.com.kingdee.eas.scm.im.inv); imp.importPackage(Packages.com.kingdee.eas.srt.comm......

路过饭堂门口
今天
66
0
Hive之导出文件按逗号分隔到本地文件

如下所示,默认导出的是用\t分隔的,需要使用管道符进行转换,经常使用到,记录下. List-1 hive -e "SELECT * from student" | sed 's/\t/,/g' > /tmp/student.csv...

克虏伯
今天
59
0
转置/解压缩功能(zip的反转)?

我有一个2项元组的列表,我想将它们转换为2个列表,其中第一个包含每个元组中的第一个项目,第二个列表包含第二个项目。 例如: original = [('a', 1), ('b', 2), ('c', 3), ('d', 4)]# an......

技术盛宴
今天
99
0
小猪o2o系统v14.0升级v14.1攻略含小猪CMS微店铺和智慧店铺及小程序百项升级

首先我们要注意升级前的以下几个内容: 即 对环境的要求 网站需求PHP7.1 MYSQL5.1以上 Sw解密组件 解密组件在swoole-loader内 解压缩网站包 修改Conf/db.php内数据库文件 替换数据库内xxx.com...

my_gode
今天
131
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部