webflux 异步执行

WebFlux 是 Spring Framework 5 中引入的响应式编程框架，其核心是基于 Reactor 的响应式流处理库。

在 WebFlux 中，异步执行可以通过 Flux 和 Mono 来实现。Flux 和 Mono 都是 Reactor 中的类，用于处理异步数据流。

1. Flux：用于表示异步数据流，可以包含多个元素。

Flux.just("a", "b", "c")
    .map(value -> {
        // 对每个元素的处理逻辑
        return value.toUpperCase();
    })
    .subscribe(value -> {
        // 对每个元素的处理逻辑
    });

2. Mono：用于表示一个异步操作的结果，只有一个元素。

Mono.just("hello")
    .map(value -> {
        // 对元素的处理逻辑
        return value.toUpperCase();
    })
    .subscribe(value -> {
        // 对处理结果的处理逻辑
    });

可以通过组合 Flux 和 Mono 来实现更复杂的异步操作，例如：

Flux.just("a", "b", "c")
    .flatMap(value -> {
        // 对每个元素的处理逻辑，返回一个 Mono
        return Mono.just(value.toUpperCase());
    })
    .subscribe(value -> {
        // 对处理结果的处理逻辑
    });

以上是 WebFlux 中实现异步执行的几种方式，开发者可以根据实际需求来选择使用哪种方式。