Project Reactor：flatMap后用onErrorResume无输出问题求助

你遇到的问题核心在于**onErrorResume的作用范围是整个Flux序列**，而不是单个元素的处理流。

当第一个元素"a"在flatMap中抛出异常时，整个上游Flux会立刻终止并发出错误信号。此时onErrorResume捕获到这个全局错误后，返回了Mono.empty()——这相当于直接替换了整个出错的序列，后续的"b"元素根本没机会被处理，自然就没有任何输出了。

针对你的需求（保留正常元素的输出，跳过错误元素），有两种常用的处理方式：

1. 在flatMap内部处理单个元素的异常 #

把错误处理逻辑放到每个flatMap生成的子流上，这样单个元素的错误不会扩散到整个主序列：

Flux.just("a", "b")
    .flatMap(s -> {
        if (s.equals("a")) {
            // 单个元素出错时返回空流，不影响主序列
            return Mono.error(new RuntimeException()).onErrorResume(e -> Mono.empty());
        } else {
            return Flux.just(s + "1", s + "2");
        }
    })
    .subscribe(System.out::println);

2. 使用onErrorContinue跳过错误元素 #

如果不需要对错误做自定义返回，只是想跳过出错的元素继续处理后续内容，可以用onErrorContinue：

Flux.just("a", "b")
    .flatMap(s -> s.equals("a") ? Mono.error(new RuntimeException()) : Flux.just(s + "1", s + "2"))
    .onErrorContinue((throwable, element) -> {
        // 这里可以记录错误日志，不影响后续元素处理
        System.err.println("处理元素 [" + element + "] 时出错: " + throwable.getMessage());
    })
    .subscribe(System.out::println);

• onErrorResume：当整个序列抛出错误时，用新的流替换原序列，原序列会终止。
• onErrorContinue：跳过产生错误的单个元素，继续处理序列中剩余的元素，不会终止整个流。
• 子流内部的onErrorResume：仅处理当前子流的错误，主序列不受影响，会继续处理后续元素。

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