如何从Spring Reactive的Mono<String>中提取字符串返回给客户端？

你的核心问题其实是没有遵循Reactive编程的链式思维，反而用了传统的可变外部状态来存文件名，这会导致异步流中的值传递出错，同时控制器层的代码也做了多余的操作。下面一步步帮你修正：

1. 先修复服务层的代码问题 #

原代码里用final String[] fileName = {""}来存文件名是Reactive编程的大忌——因为flatMap是异步执行的，then(Mono.just(fileName[0]))很可能在文件还没上传完成、文件名还没赋值的时候就执行了，最后返回空字符串；而且如果上传多个文件，后面的文件名会覆盖前面的，完全不符合预期。

正确的写法应该把文件名的生成、文件上传、返回文件名放在同一个Reactive链里，去掉外部可变状态：

@Override
public Mono<String> createImage(Flux<FilePart> files) {
    // 处理第一个上传的文件（前端一般只传一个，若要支持多文件可调整逻辑）
    return files.next()
            .flatMap(file -> {
                // 生成带时间戳的新文件名
                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH-mm-ss");
                String timestamp = dateFormat.format(new Date());
                String extension = FilenameUtils.getExtension(file.filename());
                String newFileName = timestamp + "." + extension;
                
                // 构建目标文件路径
                Path destPath = Paths.get(UPLOAD_ROOT, newFileName);
                
                // 执行文件传输，完成后返回新文件名
                return file.transferTo(destPath)
                        .then(Mono.just(newFileName));
            })
            // 统一处理上传异常
            .onErrorMap(IOException.class, e -> new RuntimeException("文件上传失败", e));
}

关键改进点： #

• 用files.next()获取第一个上传的文件（如果需要支持多文件，可以改为返回Flux<String>，但你的需求是返回单个文件名，所以取第一个更合理）
• 文件名的生成和返回完全在flatMap的链中，没有外部可变状态，保证异步流中的值传递是可靠的
• 用transferTo(Path)替代了手动创建文件的代码（Spring WebFlux的FilePart.transferTo已经封装了文件创建和写入逻辑，更简洁安全）

2. 简化控制器层代码 #

Spring WebFlux本身就支持直接返回Mono<String>作为响应——框架会自动订阅这个Mono，当流中的值准备好时，会把字符串作为HTTP响应体发送给客户端，不需要手动提取值。

所以控制器代码可以简化成这样：

@PostMapping(value = "/upload")
public Mono<String> createFile(@RequestPart(name = "file") Flux<FilePart> files) {
    return nasabahService.createImage(files);
}

原代码里的saveImage.flatMap(value -> Mono.just(value))完全是多余的，因为flatMap在这里只是把值重新包装了一遍，没有任何实际作用。

为什么这样就能返回文件名给客户端？ #

当客户端发送上传请求时：

1. WebFlux会订阅控制器返回的Mono<String>
2. 服务层的createImage方法开始执行，处理文件上传逻辑
3. 当文件上传完成、新文件名生成后，Mono<String>会发出这个字符串值
4. WebFlux会把这个字符串作为HTTP响应的内容，返回给前端

整个过程完全是异步非阻塞的，符合Spring Reactive的设计理念。

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