看到一个测评文章，并发在300的时候webMVC 和 webFlux的处理能力不相上下， 当并发达到3000的时候, webFlux明显优于webMVC, 有图有真相， 我信了. webMVC 是 one-request-one thread 堵塞模式, flux是非阻塞模式， 是spring家族系列产品发展的两个方向.
参考文档:
https://www.cnblogs.com/holddie/p/spring-webflux-er.html
Java的Stream流详细讲解_java stream_Mr Tang的博客-CSDN博客
Reactor是Spring WebFlux的首选响应式编程库。
Java 8 中的 Stream 是对集合（Collection）对象功能的增强. 流不是数据结构，本身不存储数据.
Java 8 中首次出现的 java.util.stream 是一个函数式语言+多核时代综合影响的产物。
从返回值可以看出，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 Mono<Long> 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)));
}虽然记录的有点跳跃，不适合新手去学习。但核心的概念和知识点都在了。 我一直在想一个问题，如果一个程序员还需要被别人教的话，趁早转行吧。在信息大爆炸的时代，没有自主学习能力，特别是跟计算机打交道，说明入错行了。
