响应式编程中异常不传播的旁路操作算子咨询

针对你遇到的旁路操作异常影响主数据流的问题，Reactor提供了两种简洁的处理方式，无需手动编写try-catch或onErrorResume：

1. Reactor 3.5+ 版本：使用 tap 算子 #

Reactor 3.5引入的tap算子专门用于执行不影响主数据流的副作用操作，它会自动捕获副作用中的异常并忽略，不会将错误传播到下游。

修改后的代码：

fun test1(): Mono<ResponseFromTest2> {
        return test2()
            .flatMap { responseFromTest2 ->
               // do some operation
               Mono.just(responseFromTest2) 
             }
            .tap {
                publishMetrics()
            }
    }

tap的设计目标就是处理这类旁路逻辑，完全符合你的需求——即使publishMetrics()抛出异常，原Mono的响应仍会正常向下游传递。

2. Reactor 3.5以下版本：用 flatMap 包装旁路操作 #

如果你的项目还在使用旧版本Reactor，可以通过flatMap将旁路操作包装为一个不影响主流程的子流：

fun test1(): Mono<ResponseFromTest2> {
        return test2()
            .flatMap { responseFromTest2 ->
               // do some operation
               Mono.just(responseFromTest2) 
             }
            .flatMap { response ->
                // 执行旁路操作，忽略所有异常
                Mono.fromRunnable { publishMetrics() }
                    .onErrorResume { Mono.empty() }
                    // 始终返回原响应，保证主数据流不受影响
                    .thenReturn(response)
            }
    }

这里通过Mono.fromRunnable包装publishMetrics()，并用onErrorResume静默处理异常，最后通过thenReturn将原响应传递下去，同样实现了旁路异常不干扰主流程的效果。

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