参考：
https://www.cnblogs.com/yjmyzz/p/reactor-tutorial-1.html
https://blog.csdn.net/qq_28089993/article/details/89461814
https://blog.csdn.net/weweeeeeeee/article/details/82885449
使用场景： 异步 消息文件的发射器 有push与pull两种模型。
push模型：所谓 Push 模型，即当 Producer 发出的消息到达后，服务端马上将这条消息投递给 Consumer
pull模型：而 Pull 则是服务端收到这条消息后什么也不做，只是等着 Consumer 主动到自己这里来读，即 Consumer 这里有一个“拉取”的动作
generate() 方法：同步产生方法
create() 方法：异步产生消息
filter() 方法：过滤消息
【Flux 理解学习】next() 方法：插入消息
subscribe() 方法：消费消息
map() 方法：转换映射类型
例子：
Flux.create(
(FluxSink sink) -> {
//doSomething(k, sink);
sink.complete();
}
)
.subscribe(e -> {
System.out.println(e.toString());
});
特别的如果 create 后没有消费 Subscribe() 就不会执行create里面的内容。如果没有.subscribe() 则create里面的内容不会执行。
ints.subscribe(i -> System.out.println(i),
error -> System.err.println("Error " + error),
() -> {System.out.println("Done");
})error 错误状态时执行
（）-> complete状态时执行
推荐阅读
- Java|Java基础——数组
- 人工智能|干货！人体姿态估计与运动预测
- java简介|Java是什么（Java能用来干什么？）
- Java|规范的打印日志
- Linux|109 个实用 shell 脚本
- 程序员|【高级Java架构师系统学习】毕业一年萌新的Java大厂面经，最新整理
- Spring注解驱动第十讲--@Autowired使用
- SqlServer|sql server的UPDLOCK、HOLDLOCK试验
- jvm|【JVM】JVM08(java内存模型解析[JMM])
- 技术|为参加2021年蓝桥杯Java软件开发大学B组细心整理常见基础知识、搜索和常用算法解析例题（持续更新...)