Flux

在Reactor库中，`Flux`是一种异步执行的多个结果的数据流，它类似于Java中的`Stream`。`Flux`可以让您更轻松地处理和转换数据流，以及处理来自外部数据源的事件。

`Flux`可以使用多个方式创建，例如使用静态方法、使用`Iterable`或`Stream`、从`Mono`转换等。以下是一个使用静态方法创建`Flux`的示例：

import reactor.core.publisher.Flux;

public class FluxExample {
    public static void main(String[] args) {
        Flux.just("Hello", "World") // 创建一个包含两个字符串的Flux
            .subscribe(System.out::println); // 订阅Flux并在元素可用时打印它们
    }
}

在上面的代码中，我们使用`Flux.just`方法创建了一个包含两个字符串的`Flux`，然后使用`subscribe`方法来订阅它并在元素可用时打印它们。

`Flux`还提供了许多其他方法，可以用于创建、转换和组合`Flux`。例如，您可以使用`map`方法将`Flux`中的元素转换为另一种类型，或使用`merge`方法将多个`Flux`合并为一个。以下是一个使用`map`和`merge`的示例：

Flux<String> flux1 = Flux.just("Hello", "World");
Flux<String> flux2 = Flux.just("Reactor", "Flux");

Flux<String> result = Flux.merge(flux1.map(String::toUpperCase), flux2.map(String::toLowerCase));

result.subscribe(System.out::println); // 输出 "HELLO", "WORLD", "reactor", "flux"

在上面的代码中，我们首先使用`map`方法将`flux1`和`flux2`中的字符串转换为大写和小写，然后使用`merge`方法将它们合并为一个`Flux`。最后，我们订阅了`result`并打印了它。