1.概述
在本教程中将了解Reactor Core库的Flux和Mono之间的区别。
2.什么是Mono？
Mono是一种特殊类型的Publisher。Mono对象表示单个或空值。这意味着它最多只能为onNext() 请求发出一个值，然后以onComplete()信号终止。如果失败，它只会发出一个onError()信号。
看一个带有完成信号的Mono示例：
代码语言：javascript复制@Test
public void givenMonoPublisher_whenSubscribeThenReturnSingleValue() {
Mono<String> helloMono = Mono.just("Hello");
StepVerifier.create(helloMono)
.expectNext("Hello")
.expectComplete()
.verify();
}
在这里可以看到，当helloMono被订阅时，它只发出一个值，然后发送完成信号。
3.什么是Flux？
Flux是一个标准的Publisher，代表 0 到 N 个异步序列值。这意味着它可以发出 0 到多个值，对于onNext()请求可能是无限值，然后以完成或错误信号终止。
让我们看一个带有完成信号的Flux示例：
代码语言：javascript复制@Test
public void givenFluxPublisher_whenSubscribedThenReturnMultipleValues() {
Flux<String> stringFlux = Flux.just("Hello", "Baeldung");
StepVerifier.create(stringFlux)
.expectNext("Hello")
.expectNext("Baeldung")
.expectComplete()
.verify();
}
现在，看一个带有错误信号的Flux示例：
代码语言：javascript复制@Test
public void givenFluxPublisher_whenSubscribeThenReturnMultipleValuesWithError() {
Flux<String> stringFlux = Flux.just("Hello", "Baeldung", "Error")
.map(str -> {
if (str.equals("Error"))
throw new RuntimeException("Throwing Error");
return str;
});
StepVerifier.create(stringFlux)
.expectNext("Hello")
.expectNext("Baeldung")
.expectError()
.verify();
}
在这里可以看到，在从 Flux 获取两个值后，我们得到了一个错误。
4.Mono Vs Flux
Mono和Flux都是Publisher接口的实现。简单来说，我们可以说，当我们在做计算或向数据库或外部服务发出请求，并期望最多一个结果时，我们应该使用Mono。
当期望从我们的计算、数据库或外部服务调用中获得多个结果时，应该使用Flux。
Mono有点类似于 Java 中的Optional类，因为它包含 0 或 1 个值；而Flux与List更相似，因为它可以有 N 个值。
5.结论
在本文中了解了Mono和Flux之间的区别。
与往常一样，示例的完整源代码可在 GitHub 上获得。
代码语言：javascript复制https://github.com/eugenp/tutorials/tree/master/reactor-coreblog.smart-tools.cn/2022/10/31/java-reactor-flux-vs-mono
