在Project Reactor中使用ExchangeFunction下载后无法正确保存文件

我来帮你排查这个文件下载后无法保存的问题！从你给出的代码片段来看，核心问题大概率出在响应体的处理逻辑缺失上——你只构建了请求对象，但没完成响应流的订阅和文件写入的关键步骤，这也是Reactor异步非阻塞模型中最容易踩的坑。

常见问题分析 #

1. 未触发异步流执行：Reactor是基于订阅驱动的，如果你只构建了请求但没有订阅（或通过flatMap/then等操作触发流的执行），整个下载流程根本不会启动。
2. 字节流处理不当：直接将响应体转成File需要正确处理异步字节流的写入，手动操作IO流很容易导致资源泄漏或文件写入不完整。
3. 异常与资源未处理：异步场景下，网络错误、文件IO错误需要被捕获，同时要确保文件资源被正确释放，避免文件损坏。

修正后的完整代码 #

import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpMethod;
import org.springframework.web.reactive.function.client.ClientRequest;
import org.springframework.web.reactive.function.client.ExchangeFunction;
import org.springframework.web.reactive.function.client.ExchangeFunctions;
import reactor.core.publisher.Mono;
import java.io.File;
import java.net.URI;
import java.nio.file.Path;
import java.nio.file.StandardOpenOption;

class HttpImageClientDownloader implements ImageClientDownloader {
    private final ExchangeFunction exchangeFunction;

    HttpImageClientDownloader() {
        this.exchangeFunction = ExchangeFunctions.create(new ReactorClientHttpConnector());
    }

    @Override
    public Mono<File> downloadImage(String url, Path destination) {
        ClientRequest clientRequest = ClientRequest.create(HttpMethod.GET, URI.create(url)).build();

        return exchangeFunction.exchange(clientRequest)
                // 先校验响应状态码是否成功
                .flatMap(clientResponse -> {
                    if (clientResponse.statusCode().is2xxSuccessful()) {
                        return clientResponse.bodyToFlux(DataBuffer.class);
                    } else {
                        return Mono.error(new RuntimeException("下载失败，状态码：" + clientResponse.statusCode()));
                    }
                })
                // 使用Reactor官方工具类写入文件，自动处理资源释放
                .flatMap(dataBuffer -> DataBufferUtils.write(dataBuffer, destination, StandardOpenOption.CREATE_NEW))
                // 等待所有写入操作完成后，返回目标文件对象
                .then(Mono.just(destination.toFile()))
                // 统一包装异常，便于上层处理
                .onErrorMap(e -> new RuntimeException("下载并保存图片失败", e));
    }
}

关键步骤说明 #

• exchange(clientRequest)：触发HTTP请求并获取响应，这是启动异步流的核心操作。
• bodyToFlux(DataBuffer.class)：将响应体转换为DataBuffer的Flux流，这是Reactor中处理二进制数据的标准方式。
• DataBufferUtils.write(...)：使用Reactor提供的工具类处理文件写入，它会自动管理缓冲区和文件资源的释放，避免手动操作IO流的风险。
• then(Mono.just(...))：确保只有当所有字节都写入文件后，才返回目标File对象，避免返回不完整的文件。
• onErrorMap：将底层的网络、IO异常包装成业务异常，方便上层统一处理错误场景。

额外注意事项 #

• 确保目标路径的父目录存在，可以在方法开头添加Files.createDirectories(destination.getParent())（记得捕获IOException）。
• 如果允许覆盖已存在的文件，可以将StandardOpenOption.CREATE_NEW改为StandardOpenOption.CREATE。
• 不要手动创建FileOutputStream来写入数据，异步场景下手动管理流极易导致资源泄漏。

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