Spring Boot Webflux环境下如何将FilePart转换为byte[]数组

Spring Webflux 采用异步非阻塞的响应式编程模型，无法直接同步获取文件字节数组，需通过响应式流操作符处理，常用两种实现方式如下：

方式1：使用 Spring 自带的 DataBufferUtils 聚合数据流 #

无需引入额外依赖，性能最优，代码示例：

@PostMapping("/files")
@ResponseStatus(HttpStatus.OK)
public Mono<List<UserFilesResponse>> uploadFile(@RequestPart("file") FilePart file) {
    // 聚合所有文件数据流为单个DataBuffer
    return DataBufferUtils.join(file.content())
            .map(dataBuffer -> {
                // 读取字节数组
                byte[] fileBytes = new byte[dataBuffer.readableByteCount()];
                dataBuffer.read(fileBytes);
                // 释放堆外内存，避免泄漏
                DataBufferUtils.release(dataBuffer);
                // 此处替换为你自己的业务逻辑，处理fileBytes后返回对应结果
                return yourBusinessHandleMethod(fileBytes);
            });
}

注意事项：

• 必须手动调用DataBufferUtils.release(dataBuffer)释放资源，否则会引发堆外内存泄漏
• 控制器方法返回值需改为Mono<>类型，符合Webflux响应式规范，不可直接返回普通List

方式2：转换为 InputStream 再读取字节数组 #

适合需要复用InputStream的业务场景，代码示例：

@PostMapping("/files")
@ResponseStatus(HttpStatus.OK)
public Mono<List<UserFilesResponse>> uploadFile(@RequestPart("file") FilePart file) {
    return file.content()
            // 合并数据流为SequenceInputStream
            .reduce(InputStream.nullInputStream(), (is, buffer) ->
                    new SequenceInputStream(is, buffer.asInputStream()),
                    SequenceInputStream::new)
            .map(inputStream -> {
                // 读取InputStream为byte数组，可使用commons-io的IOUtils，也可自行实现读取逻辑
                byte[] fileBytes = IOUtils.toByteArray(inputStream);
                inputStream.close();
                // 此处替换为你自己的业务逻辑
                return yourBusinessHandleMethod(fileBytes);
            });
}

注意事项：

• 若使用IOUtils.toByteArray需引入commons-io依赖，也可自行编写流读取逻辑避免额外依赖
• 使用完InputStream需手动关闭，避免资源泄漏

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