Spring Boot Reactor非转换操作问题：图片删除逻辑未执行

嘿，我明白你现在的困境——离开Java近20年，刚上手Spring Boot和Reactor的异步惰性求值模型，确实容易踩这类“代码写了但没执行”的坑。让我帮你拆解问题根源，然后给出可行的解决方案。

问题根源：Reactor的惰性求值 + 错误的Mono包装 #

你的代码里有两个核心问题导致内部操作没执行：

1. 惰性求值：Reactor中所有Mono/Flux的操作都是惰性的——只有当这个流被订阅时，整个链式操作才会触发。你用Mono.fromRunnable包裹了imageRepository.findById的调用，但这段代码只是创建了Mono对象，并没有订阅它，所以内部的map逻辑完全没机会运行。
2. 错误的异步操作包装：你把imageRepository.delete(image)（本身返回Mono<Void>）放在了Mono.fromRunnable里，同样因为没有订阅这个内部的Mono，数据库删除操作根本不会执行。

另外，你提到想找“非转换的链式方法”——其实Reactor提供了doOnNext这类副作用操作，但更适合你的场景是用flatMap来串联异步操作，因为你需要等待删除文件和删除记录都完成后返回结果。

修正后的代码方案 #

方案1：并行执行删除操作（推荐） #

这个方案会同时执行文件删除和数据库记录删除，等待两者都完成后返回Mono<Void>，符合Reactor的异步风格：

public Mono<Void> deleteImage(String fileId) {
    return imageRepository.findById(fileId)
        // 用flatMap替换map：将找到的Image转换为删除操作的Mono
        .flatMap(image -> {
            // 包装文件删除的IO操作为Mono，处理IO异常
            Mono<Void> deleteFile = Mono.fromRunnable(() -> {
                try {
                    String filePath = image.getId() + "-" + image.getName();
                    Files.deleteIfExists(Paths.get(UPLOAD_ROOT, filePath));
                } catch (IOException e) {
                    throw new RuntimeException("Failed to delete image file", e);
                }
            });
            
            // 直接使用repository的delete方法（本身返回Mono<Void>）
            Mono<Void> deleteRecord = imageRepository.delete(image);
            
            // 并行执行两个操作，等待全部完成后返回Void
            return Mono.when(deleteFile, deleteRecord);
        })
        // 如果未找到对应ID的Image，返回空的Mono<Void>（也可根据需求抛出异常）
        .switchIfEmpty(Mono.empty());
}

方案2：串行执行删除操作（用副作用方法） #

如果你希望先删除文件，再删除数据库记录，可以用doOnNext（副作用操作，不改变流的元素）来处理文件删除，再用flatMap执行数据库删除：

public Mono<Void> deleteImage(String fileId) {
    return imageRepository.findById(fileId)
        // doOnNext是副作用操作：当Image被发射时执行文件删除
        .doOnNext(image -> {
            try {
                String filePath = image.getId() + "-" + image.getName();
                Files.deleteIfExists(Paths.get(UPLOAD_ROOT, filePath));
            } catch (IOException e) {
                throw new RuntimeException("Failed to delete image file", e);
            }
        })
        // 将Image转换为删除记录的Mono
        .flatMap(imageRepository::delete)
        // 未找到Image时返回空Mono
        .switchIfEmpty(Mono.empty());
}

关键知识点解释 #

• flatMap vs map：map是同步转换操作，只能把元素转换成另一个普通对象；而flatMap可以把元素转换成Mono/Flux，并自动订阅内部的流，合并结果——这正是你需要的异步操作串联方式。
• doOnNext的作用：它属于“副作用”操作，用于在元素流过时执行一些不改变流本身的操作（比如日志、文件操作），但不会影响流的后续元素。适合不需要等待操作完成的场景，但如果操作需要等待完成，还是用flatMap更可靠。
• 订阅触发：当这个方法返回的Mono<Void>被上层代码订阅时（比如在Controller中返回给Spring Web，Spring会自动订阅），整个删除流程才会真正执行。

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