在 reactor 编程中，当链式操作发生异常需基于上游已获取的数据（如 fileinfo）执行补偿逻辑时，直接传递 mono 实例会导致重复订阅或空值问题；正确做法是利用 flatmap 将数据解包为普通对象，在错误处理时直接使用该对象。
在 reactor 编程中，当链式操作发生异常需基于上游已获取的数据（如 fileinfo）执行补偿逻辑时，直接传递 mono 实例会导致重复订阅或空值问题；正确做法是利用 flatmap 将数据解包为普通对象，在错误处理时直接使用该对象。
在响应式编程中，Mono 是一次性、不可重放的数据流容器。你当前代码中将 fileInfoMono 作为参数传入 onErrorResume，并在 handleAndReturnEmpty 内再次订阅它：
private Mono<FileInfo> handleAndReturnEmpty(Throwable cause, Mono<FileInfo> fileInfoMono) {
return fileInfoMono
.doOnNext(info -> logError(cause.getMessage()))
.flatMap(errorService::handleUnexpectedError)
.flatMap(info -> Mono.empty());
}这存在两个关键问题：
- 重复订阅风险：fileInfoMono 可能已被消费或已处于完成/错误状态，再次订阅将触发新执行（如重新调用 getFileInfo()），违背“复用”本意；
- 语义错位：onErrorResume 的上下文已丢失原始 FileInfo 值，而你真正需要的是 发生错误时所持有的那个 FileInfo 实例，而非一个待订阅的新流。
✅ 正确解法：提前解包，延迟错误处理
通过 flatMap 将 Mono
return getFileInfo(fileName, fileLocation)
.flatMap(fileInfo -> fileReader.read(fileInfo)
.doOnNext(this::log)
.flatMap(this::processFile)
.onErrorResume(throwable -> handleAndReturnEmpty(throwable, fileInfo));对应地，handleAndReturnEmpty 方法签名和实现应改为接收具体对象：
private Mono<Void> handleAndReturnEmpty(Throwable cause, FileInfo fileInfo) {
return Mono.fromRunnable(() -> logError("Processing failed for " + fileInfo.getName() + ": " + cause.getMessage()))
.then(errorService.handleUnexpectedError(fileInfo)) // 假设返回 Mono<Void>
.then(Mono.empty()); // 或根据业务返回 Mono.just(fileInfo) 等
}? 关键优势：
- ✅ fileInfo 是稳定、不可变的值，无订阅副作用；
- ✅ 错误处理逻辑可安全调用 fileInfo.getLocation()、fileInfo.getName() 等方法，精准定位并移动文件至 error 文件夹；
- ✅ 符合响应式编程“数据驱动”原则——错误恢复依赖于上下文数据，而非流本身。
⚠️ 注意事项：
- 避免在 onErrorResume 中直接使用上游 Mono；始终优先考虑 flatMap 提前捕获值；
- 若 handleUnexpectedError 是阻塞操作（如文件系统移动），请用 publishOn(Schedulers.boundedElastic()) 切换线程；
- Mono.empty() 表示“成功忽略”，若需返回默认值，请改用 Mono.just(defaultValue)。
总结：Reactor 中没有“复用 Mono”的需求，只有“复用其发出的值”的需求。flatMap 是连接声明式流与命令式逻辑的桥梁，也是安全访问上游数据的黄金路径。
