手机怎么注册网站,企业营销管理系统,wordpress指定上传目录,查分网站制作看到一个测评文章#xff0c;并发在300的时候webMVC 和 webFlux的处理能力不相上下#xff0c; 当并发达到3000的时候, webFlux明显优于webMVC, 有图有真相#xff0c; 我信了. webMVC 是 one-request-one thread 堵塞模式, flux是非阻塞模式#xff0c; 是spring家族系列…看到一个测评文章并发在300的时候webMVC 和 webFlux的处理能力不相上下 当并发达到3000的时候, webFlux明显优于webMVC, 有图有真相 我信了. webMVC 是 one-request-one thread 堵塞模式, flux是非阻塞模式 是spring家族系列产品发展的两个方向.
参考文档:
https://www.cnblogs.com/holddie/p/spring-webflux-er.html
:Spring | Reactive
Reactor 3 Reference Guide
Java的Stream流详细讲解_java stream_Mr Tang的博客-CSDN博客 springboot — 响应式编程WebFlux框架解析
Reactor是Spring WebFlux的首选响应式编程库。 Java 8 中的 Stream 是对集合Collection对象功能的增强. 流不是数据结构本身不存储数据.
Java 8 中首次出现的 java.util.stream 是一个函数式语言多核时代综合影响的产物。 springboot — 响应式编程WebFlux框架解析
从返回值可以看出Mono 和 Flux 适用于两个场景即
Mono实现发布者并返回 0 或 1 个元素即单对象Flux实现发布者并返回 N 个元素即 List 列表对象
Mono本质是一个publisher 发布者, 是一个抽象类subscribe 方法是抽象的等着底层去实现订阅绑定关系.
在http请求中request请求相当于是订阅者, 底层会把request请求有组织并行的订阅publisher- mono, mono获取到数据后分发给request请求.
MonoSink 相当于成功订阅之后的订阅关系subscription. 查看mono的源码已经理解它的运转原理:
先看Java知识Reactive Stream API响应式编程 - 知乎 这篇文章,理解订阅模式.
然后是web Flux的mono的理解 mono英文意思是单声道的就是一次只能传递一个值. 要么不传值要么传递1个. 与之相对的是Flux, 传递是0...N 个值. 具体理解看下面的代码注解.
public MonoLong save(City city) {// return Mono.create(cityMonoSink - cityMonoSink.success(cityRepository.save(city)));// return Mono.create(a - a.success(cityRepository.save(city)));// monoSink 相当于订阅成功后的订阅关系, subscriber跟发布者之间的唯一通信通道. monosink.sucess 内部会触发subscriber的onNext方法// ,相当与在传数据.// Mono.create 本质上创建一个publisher,交给底层调度系统, 调度系统建立订阅关系,返回一个monoSink,// monoSink调用success方法,触发订阅者的onNext方法,广播数据.// Consumer 创建完成mono的一个回调函数,仅仅为了订阅关系subscription,也是monosink返回.// publisher 调用subscribe方法,建立publisher和subscriber之间的订阅关系,并且给一个订阅凭证.subscription.// 然后,publisher生产数据后, 给subscriber发送数据, 触发subscriber的onNext方法.return Mono.create(cityMonoSink - cityMonoSink.success(cityRepository.save(city)));} 虽然记录的有点跳跃不适合新手去学习。但核心的概念和知识点都在了。 我一直在想一个问题如果一个程序员还需要被别人教的话趁早转行吧。在信息大爆炸的时代没有自主学习能力特别是跟计算机打交道说明入错行了。
