WebFlux端点上传文件至Minio仅完成4KB，请求排查原因

我来帮你捋捋这个问题——之前我也遇到过类似的情况，WebFlux上传文件到Minio只传4KB，大多和数据流截断或者Multipart配置限制有关，咱们一步步拆解：

最常见的原因：WebFlux默认Multipart内存限制 #

WebFlux默认的Multipart解析器有个maxInMemorySize参数，默认值就是4KB！这意味着如果你的文件超过这个大小，Part的内容只会被读取前4KB，剩下的直接被截断了。

解决方案：调整Multipart内存限制 #

你可以通过两种方式修改：

1. 配置文件方式（application.yml/application.properties）：

spring:
  codec:
    max-in-memory-size: 10MB # 根据你的文件大小调整，比如10MB、100MB

2. Java配置类方式：

@Configuration
public class WebFluxMultipartConfig implements WebFluxConfigurer {
    @Override
    public void configureHttpMessageCodecs(ServerCodecConfigurer configurer) {
        MultipartHttpMessageReader multipartReader = new MultipartHttpMessageReader();
        // 设置内存缓存上限为10MB，超过的部分会写到磁盘临时文件
        multipartReader.setMaxInMemorySize(10 * 1024 * 1024);
        configurer.defaultCodecs().multipartReader(multipartReader);
    }
}

第二个可能：数据流没有被完全消费 #

WebFlux是响应式编程，如果你的代码没有完整订阅Part的数据流，就会导致Minio只收到部分数据。比如你可能只读取了Part的前几个DataBuffer就终止了处理。

正确的Part处理示例 #

这里给你一个标准的流式上传代码，确保完整读取Part内容：

public Mono<ServerResponse> uploadFile(ServerRequest request) {
    log.info("Uploading file...");
    log.info("Content Type: {}", request.headers().contentType().orElse(MediaType.TEXT_PLAIN));

    String bucketName = "your-target-bucket"; // 替换成你的Minio桶名

    return request.body(BodyExtractors.toMultipartData())
            .flatMap(multipartData -> {
                // 获取上传的文件Part（假设前端字段名是"file"）
                Part filePart = multipartData.toSingleValueMap().get("file");
                if (filePart == null) {
                    return ServerResponse.badRequest().bodyValue("No file part provided");
                }

                String fileName = filePart.filename();
                MediaType contentType = filePart.headers().getContentType();

                // 注意：大文件不要用DataBufferUtils.join，会占内存！建议直接流式上传
                return DataBufferUtils.join(filePart.content())
                        .flatMap(dataBuffer -> {
                            byte[] fileBytes = new byte[dataBuffer.readableByteCount()];
                            dataBuffer.read(fileBytes);
                            DataBufferUtils.release(dataBuffer); // 一定要释放缓冲区

                            // 调用Minio客户端上传完整字节数组
                            return Mono.fromCallable(() -> minioClient.putObject(
                                    PutObjectArgs.builder()
                                            .bucket(bucketName)
                                            .object(fileName)
                                            .stream(new ByteArrayInputStream(fileBytes), fileBytes.length, -1)
                                            .contentType(contentType != null ? contentType.toString() : MediaType.APPLICATION_OCTET_STREAM_VALUE)
                                            .build()
                            )).then(ServerResponse.ok().bodyValue("File uploaded successfully: " + fileName));
                        });
            })
            .onErrorResume(ex -> {
                log.error("Upload failed", ex);
                return ServerResponse.internalServerError().bodyValue("Upload failed: " + ex.getMessage());
            });
}

如果是处理大文件，推荐用流式上传，避免把整个文件加载到内存：

// 替代DataBufferUtils.join的流式处理方式
return Flux.from(filePart.content())
        .map(dataBuffer -> {
            ByteBuffer byteBuffer = dataBuffer.asByteBuffer();
            byte[] bytes = new byte[byteBuffer.remaining()];
            byteBuffer.get(bytes);
            DataBufferUtils.release(dataBuffer);
            return bytes;
        })
        .collectList()
        .map(byteList -> {
            // 合并字节列表成完整数组（大文件还是建议直接用流传递）
            int totalSize = byteList.stream().mapToInt(bytes -> bytes.length).sum();
            ByteArrayOutputStream baos = new ByteArrayOutputStream(totalSize);
            byteList.forEach(bytes -> {
                try {
                    baos.write(bytes);
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            });
            return baos.toByteArray();
        })
        .flatMap(fileBytes -> {
            // 后续Minio上传逻辑同上
        });

第三个排查点：Minio客户端配置 #

检查你的Minio客户端是否正确初始化，有没有设置超时时间或者数据流限制。另外，确保使用的是最新版本的Minio Java SDK，旧版本可能存在流式上传的bug。

排查步骤总结 #

1. 先检查WebFlux的maxInMemorySize配置，确认是不是默认4KB导致的截断；
2. 查看你的Part处理代码，确保完整读取了所有的DataBuffer；
3. 测试小文件（小于4KB）是否能正常上传，验证是不是大文件才触发的问题；
4. 查看Minio和WebFlux的日志，有没有数据流被提前关闭的警告信息。

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