webflux的mono和flux的用法

WebFlux是Spring框架的一部分，它提供了一种响应式编程的方式来构建基于非阻塞I/O的应用程序。在WebFlux中，我们可以使用两种主要的数据类型：Mono和Flux。

1. Mono：
Mono是一种包含零个或一个元素的响应式流。它类似于Java 8中的Optional，但具有更多的操作符和功能。下面是一些使用Mono的示例：

Mono<String> mono = Mono.just("Hello"); // 创建一个包含单个元素的Mono
mono.subscribe(System.out::println); // 订阅并打印元素

Mono<Integer> emptyMono = Mono.empty(); // 创建一个空的Mono
emptyMono.subscribe(System.out::println); // 不会输出任何内容

Mono<String> errorMono = Mono.error(new RuntimeException("Error")); // 创建一个包含错误的Mono
errorMono.subscribe(System.out::println, Throwable::printStackTrace); // 打印错误信息

2. Flux：
Flux是一种包含零个或多个元素的响应式流。它类似于Java 8中的Stream，但具有更多的操作符和功能。下面是一些使用Flux的示例：

Flux<String> flux = Flux.just("Hello", "World"); // 创建一个包含多个元素的Flux
flux.subscribe(System.out::println); // 订阅并打印元素

Flux<Integer> emptyFlux = Flux.empty(); // 创建一个空的Flux
emptyFlux.subscribe(System.out::println); // 不会输出任何内容

Flux<String> errorFlux = Flux.error(new RuntimeException("Error")); // 创建一个包含错误的Flux
errorFlux.subscribe(System.out::println, Throwable::printStackTrace); // 打印错误信息

通过使用Mono和Flux，我们可以在WebFlux中处理异步和非阻塞的操作，例如处理HTTP请求和响应。