通过Spring WebClient流式上传大型文件

Question

我也有这里提到的同样的问题。

然后我想把它作为一个上传体流到另一个服务endpoint。

该解决方案的生成方式如下：bodytype=org.springframework.web.reactive.function.bodyinserters不支持内容类型'application/octet-stream'的错误：

public String uploadFile(String fileId, String fileName) {
        InputStream fileInputStream = minioClient.getObject(bucketName, fileId);

        return webClient.post()
                .uri(properties.getUrl())
                .contentType(APPLICATION_OCTET_STREAM)
                .headers(httpHeaders -> {
                    httpHeaders.set(FILE_NAME, fileName);
                })
                .bodyValue(BodyInserters.fromResource(fileInputStream)
                .retrieve()
                .bodyToFlux(String.class)
                .blockFirst();
    }




Answer 1

您可以尝试使用databufferutils.readInputStream(..)(javadoc)创建flux 。然后使用适当的bodyinserters.fromDataBuffers(..)(javadoc)传递到.bodyvalue()。这不应该正确地将整个文件加载到内存中，而是缓冲并逐块发送它。

我不确定这是否适用于application/octet-stream作为内容类型，因为我无法测试它。