上传大文件Spring WebFlow

Question

我想将文件上载到minio文件容器
较小的文件按预期使用此代码：

private Mono<Boolean> saveFileToMinio(FilePart filePart) {
    log.info("About to save database to minio container...");
    Mono<Boolean> result = Mono.from(
            filePart.content().flatMap(dataBuffer -> {
                        var bytes = dataBuffer.asByteBuffer().array();
                        dataBuffer.read(bytes);
                        DataBufferUtils.release(dataBuffer);
                        return Flux.just(bytes);
                    })
                    .flatMap(databaseFileService::write)
                    .then(Mono.just(true))
                    .onErrorMap(throwable -> {
                        log.error(throwable.getMessage(), throwable);
                        return throwable;
                    }));
    log.info("Successfully saved database to minio container...");
    return result;
}

我需要为要上传的minio服务提供一个byte[]。
较小的文件按预期工作（将存储到容器中）。但是较大的文件（在我的测试中为12 MB）不起作用。

我得到了这个例外：
java.lang.IndexOutOfBoundsException： readPotion0和长度1024应该小于WritePotion808

Answer 1

我尝试了一个建议，即数据缓冲区（DataBufferUtils）。从另一个SO帖子加入。这有点奇怪，但我认为以下代码可以做到这一点：

private Mono<Boolean> saveFileToMinio(FilePart filePart) {

    var result = DataBufferUtils.join(filePart.content()).map(dataBuffer -> {
                var bytes = dataBuffer.asByteBuffer().array();
                dataBuffer.read(bytes);
                DataBufferUtils.release(dataBuffer);
                return bytes;
            }).map(databaseFileService::write).then(Mono.just(true))
            .onErrorMap(throwable -> {
                log.error(throwable.getMessage(), throwable);
                return throwable;
            });
    log.info("Successfully saved database to minio container...");
    return result;
}

尤其是这一行似乎很有用：DataBufferUtils.join

我不知道为什么，但这似乎奏效了。

编辑：
查找上述静态连接将参数maxByteCount设置为-1。也许另一个（不适用于较大文件的函数）设置了一些限制。但我不知道。