Spring WebClient下载和上传文件

Question

我需要创建一个从APIendpoint下载文件并将其上传到另一个APIendpoint的进程。该文件的最大大小为100MB，但我们将有许多进程并行运行。我试图用Spring WebClient实现它，而不需要将文件存储在内存中。当前代码将文件存储在内存中，因为使用大文件的测试会抛出OutofMemoryError。

public Mono<SyncStatusType> copy(Strin path1, String path2) {
    
    return this.download(path1)
        .collectList()
        .flatMap(dataBuffers -> 
            this.upload(path2, Mono.just(dataBuffers).flatMapMany(Flux::fromIterable)))
        .map(item -> SyncStatusType.SUCCESSFUL);
}

private Flux<DataBuffer> download(String path) {

    return this.getWebClient()
        .get()
        .uri(uriBuilder -> uriBuilder
            .path(path)
            .build())
        .retrieve()
        .bodyToFlux(DataBuffer.class);

}

private Mono<CustomFileDto> upload(String path, Flux<DataBuffer> dataBuffer) {
        
    return this.getWebClient()
        .put()
        .uri(uriBuilder -> uriBuilder
            .path(path)
            .build())
        .contentType(MediaType.APPLICATION_JSON)
        .body(BodyInserters.fromDataBuffers(dataBuffer))
        .retrieve()
        .bodyToMono(CustomFileDto.class)
    }

Answer 1

我有一个Spring WebFlux多部分示例，上传/下载文件并将它们存储在Mongo GridFS中，请检查我的GitHub上的完整代码。

测试代码演示了WebFlux客户机的交互。