如何让Spring WebFlux FilePart完全异步执行，实现上传立即返回结果

未手动调用subscribe仍可执行的原理 #

Spring WebFlux 基于Reactive Streams规范实现，所有Controller返回的Mono/Flux类型响应，都会由Spring Web容器在请求处理流程中自动完成订阅操作，业务侧只需要组装异步处理的流水线即可。
你代码里的完整执行链路由Spring的订阅动作触发：订阅Mono<UploadResponse> → 消费partMono拿到FilePart对象 → 执行flatMap调用uploadFile方法 → 触发transferTo返回的Mono执行 → 执行doOnSuccess中定义的S3上传、临时文件清理逻辑，全程不需要业务代码手动调用subscribe。

另外你当前代码存在一个不符合非阻塞规范的问题：S3FileRepository.uploadFile使用的是同步阻塞的S3客户端，放在doOnSuccess中执行会阻塞Reactor的事件循环线程，会拖垮整个服务的吞吐性能。

实现立即返回的改造方案 #

你当前逻辑需要等待文件落盘、S3上传全部完成才会返回响应，所以客户端等待时间长。要实现立即返回，核心逻辑是提前构造好可确定的响应结果直接返回，将文件处理、S3上传的逻辑放到后台异步线程执行，具体改造如下：

改造步骤 #

1. 用专门的调度器执行阻塞的IO任务，避免占用Reactor事件循环线程，推荐使用Schedulers.boundedElastic()（专门处理阻塞IO任务的调度器）。
2. 改造FileService.uploadFile方法，不需要等待S3上传完成，拿到文件URL后直接构造响应返回，异步处理后续逻辑：

public Mono<UploadResponse> uploadFile(FilePart filePart) {
    // 同步执行部分：仅做参数校验、URL预生成，不执行耗时IO
    String fileName = filePart.filename();
    String fileUrl = fileRepository.getUrl(fileName);
    // 直接构造返回结果
    UploadResponse response = UploadResponse.builder()
            .fileName(fileName)
            .url(fileUrl)
            .build();
    
    // 后台异步执行耗时的文件落盘、S3上传、清理逻辑
    Mono.defer(() -> {
                try {
                    File targetFile = File.createTempFile(fileName, "");
                    return filePart.transferTo(targetFile)
                            .doOnSuccess(unused -> fileRepository.uploadFile(targetFile, fileName))
                            .doFinally(signalType -> {
                                // 无论上传成功失败都删除临时文件
                                if (targetFile.exists()) {
                                    targetFile.delete();
                                }
                            });
                } catch (Exception e) {
                    return Mono.error(e);
                }
            })
            .subscribeOn(Schedulers.boundedElastic()) // 调度到阻塞IO专用线程池执行
            .doOnError(e -> log.error("后台上传S3失败，文件名：{}", fileName, e)) // 异步错误单独处理，不要影响主流程
            .subscribe(); // 这里手动订阅触发后台任务执行
    
    // 直接返回响应，不需要等待异步任务完成
    return Mono.just(response);
}

可选优化（可靠性升级） #

如果业务对上传可靠性要求高，可以额外做以下改造：

• 提交异步任务前先把上传记录存入数据库，标记为待上传状态，后台任务执行完成后更新状态
• 加定时任务扫描超时未完成的上传记录，做重试处理
• 如果对S3上传性能要求高，可以替换为AWS官方的异步S3客户端，完全避免阻塞线程

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