是满足Reactive规范框架
Reactor有两个核心类, Mono和Flux,这两个类实现接口Publisher,提供丰富的操作符,Flux对象实现发布者,返回N个元素,Mono对象实现发布者,返回...1或者0个元素
Flux和Mono都是数据流的发布者,使用Flux和Mono都可以发出三种数据信号,"元素值","错误信号","完成信号",错误信号和完成信号都代表终止信号,终止信号用于告诉订阅者数据流结束了...,错误信号终止数据流同时把错误信息传递给订阅者
代码演示Flux和Mono
引入依赖
io.projectreactor
<artifactId..., 不能共存的
如果没有发送任何元素值,而是直接发送错误或者完成信号,表示是空数据流
如果没有错误信号,没有完成信号,表示是无限数据流
真的,去看一下Java8吧,不然真看不懂
订阅数据流
调用just...或者其他方法只是声明数据流,数据流并没有发出,只有在进行订阅之后才会触发数据流,不订阅什么都不会发生
// 订阅数据流
flux.subscribe(x -> System.out.print(x +