reactor.core.publisher.mono 使用举例

Reactor是一个基于响应式编程模型的Java库，它提供了一些用于构建响应式应用程序的工具。其中一个重要的组件是`Mono`，它表示一个异步执行的单个结果。以下是一个使用`Mono`的简单示例：

import reactor.core.publisher.Mono;

public class MonoExample {
    public static void main(String[] args) {
        Mono.just("Hello World") // 创建一个包含单个字符串的Mono
            .subscribe(System.out::println); // 订阅Mono并在结果可用时打印它
    }
}

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

`Mono`还提供了许多其他方法，可以用于创建、转换和组合`Mono`。例如，您可以使用`map`方法将`Mono`中的结果转换为另一种类型，或使用`zipWith`方法将两个`Mono`的结果组合在一起。以下是一个使用`map`和`zipWith`的示例：

Mono<String> mono1 = Mono.just("Hello");
Mono<String> mono2 = Mono.just("World");

Mono<String> result = mono1
        .map(s -> s + " Mono")
        .zipWith(mono2.map(s -> s + " Mono"))
        .map(tuple -> tuple.getT1() + " " + tuple.getT2());

result.subscribe(System.out::println); // 输出 "Hello Mono World Mono"

在上面的代码中，我们首先使用`map`方法将`mono1`中的字符串转换为"Hello Mono"，然后使用`zipWith`方法将其与另一个`Mono`中的字符串组合在一起，并使用`map`方法将结果字符串连接起来。最后，我们订阅了`result`并打印了它。