1. 概述
在响应式编程中，我们可以通过多种方式创建 Mono 或 Flux 类型的发布者。在这里，我们将了解如何使用 defer 方法来延迟 Mono 发布者的执行。
2. 什么是 Mono.defer 方法？
我们可以创建一个冷发布者，它可以使用 Mono 的 defer 方法最多生成一个值。我们看一下方法签名：
public static <T> Mono<T> defer(Supplier<? extends Mono<? extends T>> supplier)
在这里， defer 接受 Mono 发布者的 供应商 ，并在下游订阅时延迟返回该 Mono 。
但问题是，什么是冷发布者或懒发布者？让我们来看看。
仅当消费者订阅冷发布者时，执行线程才会评估冷发布者。 而热门出版商在订阅前都会热切评价。 我们有 Mono.just() 方法，它提供了 Mono 类型的热门发布者。
3. 它是如何运作的？
让我们探讨一个具有 Mono 类型的 供应商的 示例用例：
private Mono<String> sampleMsg(String str) {
log.debug("Call to Retrieve Sample Message!! --> {} at: {}", str, System.currentTimeMillis());
return Mono.just(str);
}
在这里，该方法返回一个热门的 Mono 发布者。让我们热切地订阅这个：
public void whenUsingMonoJust_thenEagerEvaluation() throws InterruptedException {
Mono<String> msg = sampleMsg("Eager Publisher");
log.debug("Intermediate Test Message....");
StepVerifier.create(msg)
.expectNext("Eager Publisher")
.verifyComplete();
Thread.sleep(5000);
StepVerifier.create(msg)
.expectNext("Eager Publisher")
.verifyComplete();
}
执行时，我们可以在日志中看到以下内容：
20:44:30.250 [main] DEBUG com.baeldung.mono.MonoUnitTest - Call to Retrieve Sample Message!! --> Eager Publisher at: 1622819670247
20:44:30.365 [main] DEBUG reactor.util.Loggers$LoggerFactory - Using Slf4j logging framework
20:44:30.365 [main] DEBUG com.baeldung.mono.MonoUnitTest - Intermediate Test Message....
在这里，我们可以注意到：
- 根据指令顺序， 主 线程急切地执行方法 sampleMsg 。
- 在使用 StepVerifier 的 两个订阅上， 主 线程使用相同的 sampleMsg 输出。因此，没有新的评价。
让我们看看 Mono.defer() 如何将其转换为冷（惰性）发布者：
public void whenUsingMonoDefer_thenLazyEvaluation() throws InterruptedException {
Mono<String> deferMsg = Mono.defer(() -> sampleMsg("Lazy Publisher"));
log.debug("Intermediate Test Message....");
StepVerifier.create(deferMsg)
.expectNext("Lazy Publisher")
.verifyComplete();
Thread.sleep(5000);
StepVerifier.create(deferMsg)
.expectNext("Lazy Publisher")
.verifyComplete();
}
执行该方法后，我们可以在控制台看到以下日志：
20:01:05.149 [main] DEBUG com.baeldung.mono.MonoUnitTest - Intermediate Test Message....
20:01:05.187 [main] DEBUG com.baeldung.mono.MonoUnitTest - Call to Retrieve Sample Message!! --> Lazy Publisher at: 1622817065187
20:01:10.197 [main] DEBUG com.baeldung.mono.MonoUnitTest - Call to Retrieve Sample Message!! --> Lazy Publisher at: 1622817070197
在这里，我们可以从日志序列中注意到几点：
- StepVerifier 在每个订阅上执行方法 sampleMsg ，而不是在我们定义它时执行。
- 延迟5秒后，订阅方法 sampleMsg的 第二个消费者再次执行它。
这就是 defer 方法如何从热发布者变成冷发布者。
4. Mono.defer 的用例？
让我们看一下可以使用 Mono.defer() 方法的可能用例：
- 当我们必须有条件地订阅发布者时
- 当每个订阅的执行可能产生不同的结果时
- deferContextual 可用于发布者当前基于上下文的评估
4.1.使用示例
让我们看一下使用条件 Mono.defer() 方法的一个示例：
public void whenEmptyList_thenMonoDeferExecuted() {
Mono<List<String>> emptyList = Mono.defer(() -> monoOfEmptyList());
//Empty list, hence Mono publisher in switchIfEmpty executed after condition evaluation
Flux<String> emptyListElements = emptyList.flatMapIterable(l -> l)
.switchIfEmpty(Mono.defer(() -> sampleMsg("EmptyList")))
.log();
StepVerifier.create(emptyListElements)
.expectNext("EmptyList")
.verifyComplete();
}
这里， MonopublishersampleMsg 的 提供者 被放置在 switchIfEmpty 方法中进行条件执行。因此， sampleMsg 仅在延迟订阅时执行。
现在，让我们看一下非空列表的相同代码：
public void whenNonEmptyList_thenMonoDeferNotExecuted() {
Mono<List<String>> nonEmptyist = Mono.defer(() -> monoOfList());
//Non empty list, hence Mono publisher in switchIfEmpty won't evaluated.
Flux<String> listElements = nonEmptyist.flatMapIterable(l -> l)
.switchIfEmpty(Mono.defer(() -> sampleMsg("NonEmptyList")))
.log();
StepVerifier.create(listElements)
.expectNext("one", "two", "three", "four")
.verifyComplete();
}
这里， sampleMsg 没有被执行，因为它没有被订阅。
5. 结论
在本文中，我们讨论了 Mono.defer() 方法和热/冷发布者。另外，我们如何将热发布者转变为冷发布者。最后，我们还讨论了它与示例用例的配合。
与往常一样，代码示例可以在 GitHub 上找到。