异常场景下能否复用Mono？当前代码无输出问题咨询

核心问题 #

1. 嵌套流导致无输出：原代码用map包装内部的Mono流，最终返回Mono<Mono<...>>嵌套结构，这种流若未被正确展开订阅，不会触发任何执行逻辑，自然无输出。
2. 重复订阅副作用：错误处理时复用fileInfoMono会触发二次订阅，导致getFileInfo被重复执行，不仅冗余，还可能获取到不一致的文件信息。
3. 错误处理逻辑缺陷：handleAndReturnEmpty存在语法错误（参数列表未闭合），且用doOnNext处理异步操作（logError/handleUnexpectedError），doOnNext不会等待异步任务完成，导致错误处理逻辑未生效。

修正后的代码 #

主方法修正

Mono<FileInfo> fileInfoMono = getFileInfo(fileName, filelocation);

return fileInfoMono.flatMap(info -> 
    fileReader.read(info)
        .doOnNext(this::log)
        .flatMap(this::processFile)
        .onErrorResume(throwable -> handleAndReturnEmpty(throwable, info))
);

错误处理方法修正

private Mono<Void> handleAndReturnEmpty(Throwable cause, FileInfo info) {
    // 同步日志直接调用
    logError(cause.getMessage());
    // 执行错误处理逻辑，返回空Mono终止流
    return errorService.handleUnexpectedError(info)
        .then(Mono.empty());
}

关键说明 #

• 替换map为flatMap：flatMap会自动展开内部的Mono流，保证整个调用链是线性的Mono<...>，订阅时能正常执行所有步骤。
• 直接传递FileInfo实例：错误处理时使用已经获取到的info对象，避免重复执行getFileInfo的副作用，同时直接拿到异常处理所需的文件路径。
• 修正异步操作处理：如果logError是异步方法（返回Mono），需改用flatMap衔接；同步方法直接调用即可。用then(Mono.empty())确保流正常终止，符合返回类型要求。

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