WebFlux学习时常见的问题

た入场券 2021-08-27 17:00 514阅读 0赞

前言

> 只有光头才能变强。
> 
> **文本已收录至我的GitHub精选文章，欢迎Star**：https://github.com/ZhongFuCheng3y/3y

回顾一下上篇我对WebFlux的入门，如果没读过的同学建议读一下再来看本篇文章，上一篇文章花了我很多的心血~~

*  [外行人都能看懂的WebFlux，错过了血亏][WebFlux]

开局再来一张图，内容全靠编：

![format_png][]

这篇主要写写我初学时对WebFlux的一些疑问，不知道大家在看上一篇文章的时候有没有相应的问题呢？

这次学WebFlux主要的动力是公司组内分享，写了一个PPT，有需要的同学在我的公众号（**Java3y**)下回复“**PPT**”即可获取。

## 一、本来就能实现异步非阻塞，为啥要用WebFlux? ##

相信有过相关了解的同学都知道，`Servlet 3.1`就已经支持异步非阻塞了。

我们可以以**自维护线程池的方式实现异步**

*  说白了就是Tomcat的线程处理请求，然后把这个请求分发到自维护的线程处理，Tomcat的请求线程返回

@WebServlet(value = "/nonBlockingThreadPoolAsync", asyncSupported = true) public class NonBlockingAsyncHelloServlet extends HttpServlet {     private static ThreadPoolExecutor executor = new ThreadPoolExecutor(100, 200, 50000L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(100));     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {         AsyncContext asyncContext = request.startAsync();         ServletInputStream inputStream = request.getInputStream();         inputStream.setReadListener(new ReadListener() {             @Override             public void onDataAvailable() throws IOException {             }             @Override             public void onAllDataRead() throws IOException {                 executor.execute(() -> {                     new LongRunningProcess().run();                     try {                         asyncContext.getResponse().getWriter().write("Hello World!");                     } catch (IOException e) {                         e.printStackTrace();                     }                     asyncContext.complete();                 });             }             @Override             public void onError(Throwable t) {                 asyncContext.complete();             }         });     } }

流程图如下：

![异步非阻塞的图][format_png 1] 异步非阻塞的图

上面的例子来源：

*  https://www.cnblogs.com/davenkin/p/async-servlet.html

简单的方式，我们还可以使用JDK 8 提供的`CompletableFuture`类，这个类可以方便的处理异步调用。

protected void doGet(HttpServletRequest request,                      HttpServletResponse response) throws ServletException, IOException {     long t1 = System.currentTimeMillis();     // 开启异步     AsyncContext asyncContext = request.startAsync();     // 执行业务代码(doSomething 指的是处理耗费时间长的方法)     CompletableFuture.runAsync(() -> doSomeThing(asyncContext,                                                  asyncContext.getRequest(), asyncContext.getResponse()));     System.out.println("async use:" + (System.currentTimeMillis() - t1)); }

要处理复杂的逻辑时，无论是回调或 CompletableFuture在**代码编写上都会比较复杂**（代码量大，不易于看懂)，而WebFlux使用的是Reactor响应式流，里边**提供了一系列的API供我们去处理逻辑**，就很方便了。

![回调地狱][format_png 2] 回调地狱

更重要的是：

*  **WebFlux使用起来可以像使用SpringMVC一样，能够大大减小学习成本**
 *  WebFlux也可以使用Functional Endpoints方式编程，总的来说还是要比`回调/CompletableFuture`要简洁和易编写。

![无缝与SpringMVC的技术使用][SpringMVC] 无缝与SpringMVC的技术使用

值得一提的是：

> 如果Web容器使用的是Tomcat，那么就是使用Reactor**桥接**的servlet async api  
> 如果Web容器是Netty，那么就是使用的Netty，天生支持Reactive
> 
> 官方的推荐是使用Netty跑WebFlux

## 二、WebFlux性能的问题 ##

我们从上篇文章中就发现，浏览器去调用处理慢的接口，无论是该接口是同步的，还是说是异步的，**返回到浏览器的时间都是一致的**。

*  同步：服务器接收到请求，一个线程会处理请求，直到该请求处理完成，返回给浏览器
 *  异步：服务器接收到请求，一个线程会处理请求，然后**指派别的线程**处理请求，请求的线程直接空闲出来。

官网也说了：

> Reactive and non-blocking generally do not make applications run faster

使用异步非阻塞的好处就是：

> The key expected benefit of reactive and non-blocking is the ability to scale with a small, fixed number of threads and less memory.That makes applications more resilient under load, because they scale in a more predictable way

好处：**只需要在程序内启动少量线程扩展，而不是水平通过集群扩展**。异步能够**规避文件IO/网络IO阻塞所带来的线程堆积**。

下面来看一下针对相同的请求量，同步阻塞和异步非阻塞的吞吐量和响应时长对比：

![吞吐量和RT对比][RT] 吞吐量和RT对比

注：

*  请求量不大时(3000左右)，同步阻塞多线程处理请求，吞吐量和响应时长都没落后。（按道理WebFlux可能还要落后一些，毕竟多做了一步处理`-->`将请求委派给另一个线程去做处理
 *  请求量大时，线程数不够用，同步阻塞(MVC)只能等待，所以吞吐量要下降，响应时长要提高(排队)。

> **Spring WebFlux在应对高并发的请求时，借助于异步IO，能够以少量而稳定的线程处理更高吞吐量的请求**，尤其是当请求处理过程如果因为业务复杂或IO阻塞等导致处理时长较长时，对比更加显著。

## 三、WebFlux实际应用 ##

**WebFlux需要非阻塞的业务代码**，如果阻塞，需要自己开线程池去运行。WebFlux什么场景下可以替换SpringMVC呢？

*  **想要内存和线程数较少的场景**
 *  **网络较慢或者IO会经常出现问题的场景**

> SpringMVC和WebFlux更多的是互补关系，而不是替换。阻塞的场景该SpringMVC还是SpringMVC，并不是WebFlux出来就把SpringMVC取代了。

![SpringMVC和WebFlux][SpringMVC_WebFlux] SpringMVC和WebFlux

如果想要**发挥出WebFlux的性能**，需要从Dao到Service，全部都要是Mono和Flux，目前官方的数据层Reactive框架只支持Redis，Mongo等几个，**没有JDBC**。

目前对于**关系型数据库**，Pivotal团队开源出R2DBC（Reactive Relational Database Connectivity），其GitHub地址为：

*  https://github.com/r2dbc

目前R2DBC支持三种数据源：

*  PostgreSQL
 *  H2
 *  Microsoft SQL Server

总的来说，因为WebFlux是响应式的，要想发挥出WebFlux的性能就得将代码全改成响应式的，而JDBC目前是没支持的(至少MySQL还没支持)，而响应式的程序不好调试和编写（相对于同步的程序），所以现在WebFlux的应用场景还是相对较少的。

所以，我认为在**网关层**用WebFlux比较合适（本来就是网络IO较多的场景）

现在再回来看Spring官网的图，是不是就更亲切了？

![Spring官网介绍图][Spring] Spring官网介绍图

参考资料：

*  https://blog.lovezhy.cc/2018/12/29/webflux性能问题

## 四、有必要学Functional Endpoints 编程模式吗？ ##

前面也提到了，WebFlux提供了两种模式供我们使用，一种是SpringMVC 注解的，一种是叫`Functional Endpoints`的

> Lambda-based, lightweight, and functional programming model

总的来看，就是配合Lambda和流式编程去使用WebFlux。如果你问我：有必要学吗？其实我觉得可以先放着。**我认为**现在WebFlux的应用场景还是比较少，等真正用到的时候再学也不是什么难事，反正就是学些API嘛~

**有Lambda表达式和Stream流的基础，等真正用到的时候再学也不是啥问题**~

以下是通过注解的方式来使用WebFlux的示例：

![通过注解的方式来使用WebFlux][WebFlux 1] 通过注解的方式来使用WebFlux

以下是通过`Functional Endpoints`的方式来使用WebFlux的示例：

路由分发器，相当于注解的GetMapping…

![路由分发器][format_png 3] 路由分发器

UserHandler，相当于UserController：

![UserHanler][] UserHanler

## 最后 ##

*  ~~

这次学WebFlux主要的动力是公司组内分享，写了一个PPT，有需要的同学在我的公众号（**Java3y**)下回复“**PPT**”即可获取。

**两年呕心沥血的文章****：****[「面试题」「基础」「进阶」这里全都有！][Link 1]**

![undefined][]**300多篇** **原创** **技术文章** **海量视频资源** **精美脑图** **面试题**

**长按扫码可关注获取**

**在看和分享对我非常重要！**![format_png 4][]

**创作不易，各位的支持和认可，就是我创作的最大动力，我们下篇文章见！**** 求点赞 求关注️  求分享???? 求留言????**

![format_png 5][]

点击阅读原文，关注我的GitHub

[WebFlux]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA%3D%3D&chksm=ebd74b3edca0c228fb477587c5746b7867ff465f2a2e012cf6170300f70a2050f77bc6df4256&idx=1&lang=zh_CN&mid=2247486015&scene=21&sn=c80cd5de903510567b86697d03c892ea&token=1874664226#wechat_redirect
[format_png]: /images/20210827/7f1e8ad19d9243a8a5cc877770454183.png
[format_png 1]: /images/20210827/65d7a8bf9bfb481c8f93774cc19ab185.png
[format_png 2]: /images/20210827/d9b94cf1dfea4b31852fa2b4b39fa408.png
[SpringMVC]: /images/20210827/8f9a90603ef74ee0b226fea82688dbb1.png
[RT]: /images/20210827/d3dc6fdb8db7435e8b70acc12dad5b91.png
[SpringMVC_WebFlux]: /images/20210827/01c1e65fea8f4a028612e18e548af254.png
[Spring]: /images/20210827/f40ea925f932470ca18ea78ffccbdb11.png
[WebFlux 1]: /images/20210827/1fd40e599ee349f59072a4414efc9ae5.png
[format_png 3]: /images/20210827/0258d49e6c8d40d481c373cbd9189bb2.png
[UserHanler]: /images/20210827/1524e1c135fd49f98baa59d84e74e2a6.png
[Link 1]: https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA%3D%3D&chksm=ebd7482cdca0c13a92f7a0de8ca529fb2b4c888d321ef2f3a2b57ae92069fcc8ed5efe2c05ee&idx=1&lang=zh_CN&mid=2247485741&scene=21&sn=4f26dff152eba0ea5208aaa7900cabb0&token=30801584#wechat_redirect
[undefined]: /images/20210827/e2e40c496a08458ca9c97dd3a5248e0b.png
[format_png 4]: /images/20210827/5336e03781124b1caf679b9c7b6667dd.png
[format_png 5]: /images/20210827/082679b7cb184dbc8f81093c1aa4bb90.png