1 通过 Flux 对象创建响应式流
- 基于各种工厂模式的静态创建方法
- 编程的方式动态创建 Flux
相对而言，静态方法在使用上都比较简单，但不如动态方法来得灵活。我们来一起看一下。
2 通过静态方法创建 Flux
Reactor 中静态创建 Flux 的方法常见的包括 just()、range()、interval() 以及各种以 from- 为前缀的方法组等。因为 Flux 可以代表 0 个数据，所以也有一些专门用于创建空序列的工具方法。
2.1 just() 方法
我已经在上一讲为你演示过 just() 方法，它可以指定序列中包含的全部元素，创建出来的 Flux 序列在发布这些元素之后会自动结束。一般情况下，在已知元素数量和内容时，使用 just() 方法是创建 Flux 的最简单直接的做法。
示例：
Flux.just("Hello", "World").subscribe(System.out::println);
Hello World
这里我们对 Flux 执行了用于订阅的 subscribe() 方法，并通过使用 Lambda 表达式调用了 System.out.println() 方法，这意味着将结果打印到系统控制台。关于 subscribe() 方法以及对响应式流的订阅过程，我会在本讲后续内容中进一步说明。
fromXXX() 方法组
如果我们已经有了一个数组、一个 Iterable 对象或 Stream 对象，那么就可以通过 Flux 提供的 fromXXX() 方法组来从这些对象中自动创建 Flux，包括 fromArray()、fromIterable() 和 fromStream() 方法。
示例：
Flux.fromArray(new Integer[] {1, 2, 3}) .subscribe(System.out::println);
执行结果
1 2 3
range() 方法
如果你快速生成一个整数数据流，那么可以采用 range() 方法，该方法允许我们指定目标整数数据流的起始元素以以及所包含的个数，序列中的所有对象类型都是 Integer，这在创建连续的年份信息或序号信息等场景下非常有用。使用 range() 方法创建 Flux 对象的示例代码如下所示。
Flux.range(2020, 5).subscribe(System.out::println);
显然，这段代码会在控制台中打印出 5 行记录，从 2020 开始，到 2024 结束。
interval() 方法
在 Reactor 框架中，interval() 方法可以用来生成从 0 开始递增的 Long 对象的数据序列。通过 interval() 所具备的一组重载方法，我们可以分别指定这个数据序列中第一个元素发布之前的延迟时间，以及每个元素之间的时间间隔。interval() 方法相对复杂，我们先附上它的弹珠图，如下所示。
使用 interval() 方法创建 Flux 示意图（来自 Reactor 官网）
可以看到，上图中每个元素发布时相当于添加了一个定时器的效果。使用 interval() 方法的示例代码如下所示。
Flux.interval(Duration.ofSeconds(2), Duration.ofMillis(200)).subscribe(System.out::println);
这段代码的执行效果相当于在等待 2 秒钟之后，生成一个从 0 开始逐一递增的无界数据序列，每 200 毫秒推送一次数据。
empty()、error() 和 never()
根据上一讲介绍的 Reactor 异步序列的语义，我们可以分别使用 empty()、error() 和 never() 这三个方法类创建一些特殊的数据序列。其中，如果你希望创建一个只包含结束消息的空序列，那么可以使用 empty() 方法，使用示例如下所示。显然，这时候控制台应该没有任何的输出结果。
Flux.empty().subscribe(System.out::println);
然后，通过 error() 方法可以创建一个只包含错误消息的序列。如果你不希望所创建的序列不发出任何类似的消息通知，也可以使用 never() 方法实现这一目标。当然，这几个方法都比较少用，通常只用于调试和测试。
小结
不难看出，静态创建 Flux 的方法简单直接，一般用于生成那些事先已经定义好的数据序列。
而如果：
- 数据序列事先无法确定
- 或生成过程中包含复杂的业务逻辑
就需要用到动态创建方法。
