在第3步使用Reactor创建Publisher以发布Flux

创建Flux

前文已对Mono进行了介绍，其中Mono用于表示0~1的序列，而Flux则用于描述包含0~N个元素的序列。可以认为，Mono是Flux的一种简化形式，Flux具备更广泛的适用性，能够表达数据流的概念。

由于Flux与Mono均用于表示连续的序列，因此在创建方式上存在一定的差异。以下列举了Flux的一些常见创建方法：

• just()：可用于定义序列中所有包含的具体元素。
• range()：适用于生成一系列连续数值。
• empty()：用于构建一个不包含任何内容的空序列。
• error(Throwable error)：可生成仅包含错误信息的序列。
• fromIterable()：通过迭代器构造如列表、集合等结构。
• fromStream()：基于流对象进行创建。
• fromArray(T[])：利用数组如String[]、Integer[]等构建序列。
• merge()：将两个Flux对象进行合并后生成新的Flux对象。
• interval()：按照设定的时间间隔依次生成递增数字，起始值为1。

以下为使用上述方法创建Flux的具体示例：

    @Test
    public void flux () throws InterruptedException {