详解 Webflux 中的 onErrorResume 和 onErrorReturn

JAVA herman 1187浏览
公告:“业余草”微信公众号提供免费CSDN下载服务(只下Java资源),关注业余草微信公众号,添加作者微信:xttblog,发送下载链接帮助你免费下载!
本博客日IP超过1800,PV 2600 左右,急需赞助商。
极客时间所有课程通过我的二维码购买后返现24元微信红包,请加博主新的微信号:xttblog,之前的微信号好友位已满,备注:返现
所有面试题(java、前端、数据库、springboot等)一网打尽,请关注文末小程序
视频教程免费领

webflux 并不算一门新技术,它出自 Spring,所以 Spring 中的一些特性它都有,包括 SpringMVC 中的一些注解它也可以沿用。没看过 webflux 教程的,可以参考我前面关于 webflux 教程的一些文章。本文我们来学习 webflux 中两个比较特独的方法 onErrorResume 和 onErrorReturn。

先回忆一下,我们在 SpringMVC 或者 SpringBoot 中常用的处理异常的方式有:@RestControllerAdvice、@ExceptionHandler、@ResponseStatus、HandlerExceptionResolver、@controlleradvice 等来实现。在 webflux 中这些也都可以使用,但是我不推荐这样使用,因为这样使用就破坏了 WebFlux 应有的特性!

onErrorResume

在 webflux 中,我们可以通过 onErrorResume 来处理功能基本的异常。onErrorResume 通过回掉的方式进行处理,整个 webflux 是一种链式调用。onErrorResume 的源码如下:

Mono<T> onErrorResume(Function<? super Throwable, ? extends Mono<? extends T>> fallback);

下面我们来演示一下 onErrorResume 的用法。新建项目之类的,我就不说了,不懂的看前面的文章!我们直接上核心代码。

@Configuration
public class XttblogRouter {
    @Autowired
    private XttblogHandler handler;
    @Bean
    public RouterFunction<ServerResponse> xttblog() {
        return route(GET("/xttblog"), req -> handler.xttblog(req));
    }
}

XttblogHandler 的实现代码如下:

@Component
public class XttblogHandler {
    public Mono<ServerResponse> xttblog(ServerRequest serverRequest) {
        String param = serverRequest.queryParam("test").orElse("other");
        return toDoTest(param).flatMap(s -> ServerResponse.ok()
                .contentType(MediaType.TEXT_PLAIN).syncBody(s))
                .onErrorResume(e -> Mono.just("Error: " + e.getMessage()).
                    flatMap(s -> ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                    .syncBody(s)));
    }
    private Mono<String> toDoTest(String param) {
        String type = Optional.ofNullable(param).orElse(
                "other"
        );
        switch (type) {
            case "xttblog":
                return Mono.just("www.xttblog.com");
            case "codedq":
                return Mono.just("www.codedq.net");
            case "other":
                throw new NullPointerException("我抛出一个空异常了");
            default:
                return Mono.just(type);
        }
    }
}

然后通过 SpringBoot 启动项目,分别试试不同的参数进行访问。

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

当是 localhost:8080/xttblog?test=other 这个的时候,就会打印异常信息。并返回 500 错误信息。

onErrorReturn

参考前面的 onErrorResume,onErrorReturn 也就显的非常的简单。每当发生错误时,我们可以使用 onErrorReturn() 返回静态默认值:

public Mono<ServerResponse> test(ServerRequest serverRequest) {
    String param = serverRequest.queryParam("test").get();
    return toDoTest(param)
            .onErrorReturn("onErrorReturn .... www.xttblog.com")
            .flatMap(s -> ServerResponse.ok()
                    .contentType(MediaType.TEXT_PLAIN).syncBody(s));
}

onErrorReturn 和 onErrorResume 有什么区别吗?

从源码上开它们的区别不大,只不过 onErrorReturn 的范围更大一些而已。onErrorReturn 返回一个静态值,onErrorResume 返回一个动态值,并且可以捕获,包装和重新抛出错误,例如作为自定义业务异常等。

参考资料

业余草公众号

最后,欢迎关注我的个人微信公众号:业余草(yyucao)!可加QQ1群:135430763(2000人群已满),QQ2群:454796847(已满),QQ3群:187424846(已满)。QQ群进群密码:xttblog,想加微信群的朋友,之前的微信号好友已满,请加博主新的微信号:xttblog,备注:“xttblog”,添加博主微信拉你进群。备注错误不会同意好友申请。再次感谢您的关注!后续有精彩内容会第一时间发给您!原创文章投稿请发送至532009913@qq.com邮箱。商务合作可添加助理微信进行沟通!

本文原文出处:业余草: » 详解 Webflux 中的 onErrorResume 和 onErrorReturn