Reactor中的onErrorContinue 和 onErrorResume
前言
这似乎是 Reactor 的热门搜索之一，至少当我在谷歌中输入 onErrorContinue 时，onErrorResume 会在它旁边弹出。让我把我的测试代码和我的一些解释粘贴在下面。
1 基础功能
这是一个简单的函数，将 5 个连续的数字分别乘以 2，然后相加，当 i==2 时抛出一个异常:
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.map(i -> i == 2 ? i / 0 : i)
.map(i -> i * 2)
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}显然，输出如下：
input=1
input=2
Exception in thread "main" java.lang.ArithmeticException: / by zero
2 只有 onErrorResume ()
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.map(i -> i == 2 ? i / 0 : i)
.map(i -> i * 2)
.onErrorResume(err -> {
log.info("onErrorResume");
return Flux.empty();
})
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}输出如下：
input=1
input=2
17:40:47.828 [main] INFO com.example.demo.config.TestRunner - onErrorResume
sum=2
正如官方文档描述（onErrorResume）的那样，onErrorResume 用返回内容替换 Flux，因此在 2 之后的数据不会被处理。唯一值得一提的是，onErrorResume() 不必马上在错误之后捕获异常。在 onErrorContinue() 的官网文档中（onErrorContinue），只有 onErrorContinue() 强调了了 upstream 关键词，但显然，它还有其他含义。
3 只有 onErrorContinue()
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.map(i -> i == 2 ? i / 0 : i)
.map(i -> i * 2)
.onErrorContinue((err, i) -> {log.info("onErrorContinue={}", i);})
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}输出：
input=1
input=2
17:43:10.656 [main] INFO com.example.demo.config.TestRunner - onErrorContinue=2
input=3
input=4
input=5
sum=26
显然，onErrorContinue 会丢弃错误数据 2, 然后继续数字 3 直到 5。
4 onErrorResume() 然后 onErrorContinue()
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.map(i -> i == 2 ? i / 0 : i)
.map(i -> i * 2)
.onErrorResume(err -> {
log.info("onErrorResume");
return Flux.empty();
})
.onErrorContinue((err, i) -> {log.info("onErrorContinue={}", i);})
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}输出和上面一样：
input=1
input=2
17:47:05.789 [main] INFO com.example.demo.config.TestRunner - onErrorContinue=2
input=3
input=4
input=5
sum=26
这样的结果，你想到了吗？onErrorContinue() 会在 onErrorResume() 得到错误之前处理这个错误。当两个错误处理函数在同一个函数中的时候很明显，但是当你的函数中只有 onErrorResume()，而一些调用者实际上有 onErrorContinue() 时，你的 onErrorResume() 没有被调用的原因可能就不那么明显了。
5 使用 onErrorResume() 模拟 onErrorContinue()
有些博客建议我们完全不用 onErrorContinue()，且在所有场景中仅用 onErrorResume()。但是上述示例已经展示了它们会产生不同的结果。那我们怎么实现呢？
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.flatMap(i -> Mono.just(i)
.map(j -> j == 2 ? j / 0 : j)
.map(j -> j * 2)
.onErrorResume(err -> {
System.out.println("onErrorResume");
return Mono.empty();
})
)
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}因此，本质上是将可能在 flatMap 或 concatMap 中抛出错误的操作包装起来，并在其上使用 onErrorResume()。这样，它会产生相同的结果:
input=1
input=2
onErrorResume
input=3
input=4
input=5
sum=26
6 使用 onErrorResume() 和下游的 onErrorContinue() 模拟 onErrorContinue()
有时候，onErrorContinue() 放在调用程序中，您无法控制它。但你仍然需要 onErrorResume()。你该怎么办?
public static void main(String... args) {
Flux.range(1,5)
.doOnNext(i -> System.out.println("input=" + i))
.flatMap(i -> Mono.just(i)
.map(j -> j == 2 ? j / 0 : j)
.map(j -> j * 2)
.onErrorResume(err -> {
System.out.println("onErrorResume");
return Mono.empty();
})
.onErrorStop()
)
.onErrorContinue((err, i) -> {log.info("onErrorContinue={}", i);})
.reduce((i,j) -> i+j)
.doOnNext(i -> System.out.println("sum=" + i))
.block();
}秘诀是在 onErrorResume() 代码块的末尾添加 onErrorStop() ——这会阻塞 onErrorContinue()，这样它就不会在 onErrorResume() 之前占用错误。尝试删除 onErrorStop()，你会看到 onErrorContinue() 在 onErrorResume 之前弹出。
到此这篇关于Reactor中的onErrorContinue 和 onErrorResume的文章就介绍到这了,更多相关Reactor onErrorContinue 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了ElasticSearch自定义注解增删改方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-04-04
这篇文章主要介绍了log4j如何根据变量动态生成文件名方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-12-12
这篇文章主要介绍了springboot开启Bean数据校验功能,通过启用Bean属性校验导入JSR303与Hibernate校验框架坐标,使用@Validated注解启用校验功能,需要的朋友可以参考下2023-10-10
这篇文章主要介绍了Java String的intern方法使用场景示例，帮助大家更好的理解和使用Java，感兴趣的朋友可以了解下2020-11-11
这篇文章主要为大家详细介绍了用java WebSocket做一个聊天室，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2016-10-10
Spring中@RestControllerAdvice注解的使用详解
这篇文章主要介绍了Spring中@RestControllerAdvice注解的使用详解,@RestControllerAdvice是一个组合注解,由@ControllerAdvice、@ResponseBody组成,而@ControllerAdvice继承了@Component,需要的朋友可以参考下2024-01-01
这篇文章主要介绍了Java算法之数组冒泡排序代码实例讲解，文中用代码举例讲解的很清晰，有感兴趣的同学可以研究下2021-03-03
读万卷书不如行万里路，只学书上的理论是远远不够的，只有在实战中才能获得能力的提升，本篇文章手把手带你用java+SSM+mysql+maven+tomcat实现一个文创商城系统,大家可以在过程中查缺补漏，提升水平2021-11-11
这篇文章主要给大家介绍了关于Java中利用gson解析Json 的相关资料，文中给出了详细的示例代码供大家参考学习，相信对大家具有一定的参考学习价值，需要的朋友们下面来一起看看吧。2017-05-05
jinfo是JDK提供的一个可以实时查看Java虚拟机各种配置参数和系统属性的命令行工具，本文给大家介绍下Java中的jinfo命令使用，感兴趣的朋友一起看看吧2022-03-03
最新评论