Springboot2.0中webflux到底优秀在哪里

Spring-boot-webflux中所说的反应堆式编程reactor到底优秀在哪里？

小编的Springboot2.0的课程已经快全部写完了。总结来看，对于有基础的同学学习难度不是很大,一周内就能上手。但是在小编看来编程如果说只会用,而不了解其编程模型和这样设计的好处，其实对于开发人员来说，并没有多大的收获！所以为了让感兴趣的同学对2.0编程模型反应式编程和Mono，Flux有一个清醒的认识，减少后面的学习难度。小编我总结了这篇文章。文章概念性东西比较多,希望大家有所收获!

目录

1. 什么是反应式编程(Reactive)？
2. 反应式的编程模型的好处是什么？
3. 代码如何去实现反应式编程?
4. Mono和Flux常用API
5. Mono和Flux在Webflux中的用处？

1.什么是反应式编程(Reactive)？

Reactive小编理解下来就是基于事件驱动(事件模式或者说订阅者模式)，类似于Netty异步事件编程模型，对不同的事件做不同的处理。所有信息都通过一个编程模型处理，就像水在管道里面运动一样（这里把事件比作水流）

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-32amJqA3-1658487304887)(http://p1.pstatp.com/large/pgc-image/15295886539700aa006d39e)]

所有的信息都封装成一个Channel,这个channel就像在管道中流动一样,被管道中的这些处理器所处理。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-BR6BEw8h-1658487304887)(http://p9.pstatp.com/large/pgc-image/152958865408618227db359)]

比如大名鼎鼎的React 前端框架配合redux 流模型，将服务器返回的信息包装成action数据流，然后根据action去映射到页面上，页面随着action的改变而改变。页面和数据就相当于这管道中的东西，被一层一层的梳理，展示。

2. 反应式的编程模型的好处是什么？

为了给各位看官充分证明其好处，我们先来分析下传统的模式有哪些不足！

作为Java web开发人员，我们写的最多的代码都是放在web容器中tomcat中运行的，Tomcat就是基于Servelt运行的,我们回顾下Servlet的知识,可能我们最熟悉的就是HttpServletRequest，和HttpServletResponse

当你脑子中有Servlet的概念就好理解了。

• Servlet3.0之前 线程会一直阻塞，只有当业务处理完成并返回后时结束 Servlet线程。
• 3.0规范其中一个新特性是异步处理支持,即是在接收到请求之后，Servlet 线程可以将耗时的操作委派给另一个线程来完成，在不生成响应的情况下返回至容器

这样说可能大家还不太容易理解，我们来举一个例子(这点引用小编之前写的文章)SpringBoot2.0之WebFlux解析及实战

eg： 我们假设,设置tomcat最大线程为200,遇到200个非常耗时的请求

1. 那么当有200个线程同时并发在处理,那么当来201个请求的时候,就已经处理不了，因为所有的线程都阻塞了。这是3.0之前的处理情况

2. 而3.0之后异步处理是怎样处理呢？学过Netty通信框架的同学会比较容易理解一点，Servlet3.0类似于Netty一样就一个boss线程池和work线程池，boss线程只负责接收请求,work线程只负责处理逻辑。那么servlet3.0规范中，这200个线程只负责接收请求，然后每个线程将收到的请求，转发到work线程去处理。因为这200个线程只负责接收请求，并不负责处理逻辑，故不会被阻塞，而影响通信，就算处理非常耗时，也只是对work线程形成阻塞，所以当再来请求，同样可以处理,其主要应用场景是针对业务处理较耗时的情况可以减少服务器资源的占用，并且提高并发处理速度。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-VTUo2Lfc-1658487304888)(http://p3.pstatp.com/large/pgc-image/15295886541071568ccdf41)]

3.代码如何去实现反应式编程?

前面说了反应式编程可以理解为事件模式或者是订阅者模式,我们如何去实现事件模式？

小编在这里引入两个框架或许各位看官就理解了

• 1. RxJava

下图是RxJava小编写的例子,大概描述下,事件源即使onNext方法的入参，将信息发送,消费者就是

subscribe方法，里面会对事件源做处理，onCompleted: 完成 onError:错误

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-hrleR7UV-1658487304888)(http://p3.pstatp.com/large/pgc-image/15295886541429eb153b22f)]

• 2. Guava的EventBus实现

怎么样订阅者模式,或者是观察者模式是不是很好理解

但是我们还是觉得这种方法,太复杂了,比如我们为了扩展性,就创建了这么多类. 那么我们怎么更简单呢? 接下来介绍EventBus使用,只要掌握一个注解@Subscribe就可以了.

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kNjjYNoV-1658487304888)(http://p1.pstatp.com/large/pgc-image/15295886540479b0de2ec3d)]

4.Mono和Flux常用API

Mone和Flux都是数据反应式编程的核心组件，开发人员就是多利用其编写出高效率的代码

Reactor是JVM的完全非阻塞反应式编程基础，具有高效的需求管理（以管理“背压”的形式）。它直接与Java 8功能的API，特别是整合CompletableFuture，Stream和 Duration。它提供了可组合的异步序列API Flux（用于[N]元素）和Mono（用于[0 | 1]元素），广泛地实现了Reactive Extensions规范。这段的重点是和Java8结合利用lambda表达式简洁的优点。

Flux 相当于一个 RxJava Observable 观察者

观察者可以把生产者的消息Publisher,推送给消费者subscribe

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-hxneyytm-1658487304889)(http://p3.pstatp.com/large/pgc-image/152958865448653993e03ba)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-9juxd7RN-1658487304889)(http://p3.pstatp.com/large/pgc-image/15295886543052ff14b164e)]
我们可以把Mono理解为一个结果它对应的数据是 1，其实可以理解为对结果的一个包装

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-U0Ng98Gc-1658487304889)(http://p1.pstatp.com/large/pgc-image/1529588654479e1bec671ff)]

5.Mono和Flux在Webflux中的用处？

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ZQaPq7dM-1658487304890)(http://p1.pstatp.com/large/pgc-image/1529588654490f10058b09f)]
更令小编感到热血沸腾的是SpringBoot2.0后可以用Netty作为web容器,我们构建一个web项目更简单了,小编曾羡慕过Node.js构建web项目的便捷，只需要10行左右代码,就能构建出一个web项目或者更短。如今我们利用SpringBoot2.0也可以了5行。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-8XGdhWEU-1658487304890)(http://p1.pstatp.com/large/pgc-image/1529588956279e701cb71f3)]

好了这篇文章就到这里了,相信你对springboot2的webflux和reactive都有一个大概的认识了，下一步学习Springboot2其他webflux组件就相对比较简单了，喜欢的童鞋点击下关注,小编会持续为你推送最新的技术文章。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-lKrJhmsa-1658487304890)(http://p3.pstatp.com/large/pgc-image/15295890048306802465c9c)]

Flux参考地址

以上是小编的理解，可能也不是全对，欢迎指出问题批评，技术交流,思想碰撞的火花，才能促进进步，最后小编希望和各位看官一起共同进步。

文章来源: springlearn.blog.csdn.net，作者：西魏陶渊明，版权归原作者所有，如需转载，请联系作者。

原文链接：springlearn.blog.csdn.net/article/details/81075766