Spring Reactive中处理Mono.just运行时异常的方法咨询

你的问题根源在于**Mono.just()会同步执行传入的代码**，当student.read()抛出异常时，这个异常是在创建Mono实例的阶段就直接抛出了，根本没有进入Reactive流的执行环节，所以后续的doOnError、onErrorReturn这些错误处理操作符根本无法捕获到异常。

重构后的代码 #

private Mono<Boolean> isMatching(DocumentContext student) {
    return Mono.fromCallable(() -> student.read("$.studentId", String.class))
            .doOnError(error -> log.error("读取studentId失败: {}", error.getMessage()))
            .onErrorReturn("")
            .map(studentId -> "S101".equals(studentId));
}

关键改动说明 #

• 用Mono.fromCallable()替代Mono.just()：fromCallable会把同步的可能抛异常的操作包装到Reactive流中，当流被订阅时才执行这个操作，此时抛出的异常会被Reactive的错误处理机制捕获。
• 移除switchIfEmpty：原代码中student.read()找不到路径时是抛异常，不是返回空值或空Mono，所以switchIfEmpty在这里没有作用，可以直接去掉。
• 错误处理逻辑生效：现在doOnError会在读取失败时记录日志，onErrorReturn会返回空字符串，最后map里的比较会因为空字符串不等于"S101"而返回false，完全符合你的需求。

基础概念补充 #

Reactive流的错误处理只针对流执行阶段的异常，也就是订阅后异步执行的代码抛出的异常。如果在创建Mono/Flux时就同步抛出异常，属于流创建阶段的错误，无法被流的错误操作符捕获，必须用fromCallable、defer这类延迟执行的操作符把代码包装进去，才能让异常进入流的错误处理链路。

内容的提问来源于stack exchange，提问作者Mohammed Idris