如何将WebFlux WebClient DataBuffer下载与更多操作结合起来

Question

我正在尝试根据先前Web请求的结果下载一个文件（或多个文件）。下载文件后，我需要将之前的Mono结果（hossierandobj）和文件发送到另一个系统。到目前为止，我一直在使用平面地图和Monos。但是当读取大文件时，我无法在文件下载期间使用Mono，因为缓冲区太小。

简化后的代码如下所示：

var filePath = Paths.get("test.pdf");
this.dmsService.search()
    .flatMap(result -> {
        var dossier = result.getObjects().get(0).getProperties();
        var objectId = dossier.getReferencedObjectId();
        return Mono.zip(this.dmsService.getById(objectId), Mono.just(dossier));
    })
    .flatMap(tuple -> {
        var obj = tuple.getT1();
        var dossier = tuple.getT2();

        var media = this.dmsService.getDocument(objectId);
        var writeMono = DataBufferUtils.write(media, filePath);
        return Mono.zip(Mono.just(obj), Mono.just(dossier), writeMono);
    })
    .flatMap(tuple -> {
        var obj = tuple.getT1();
        var dossier = tuple.getT2();
        var objectId = dossier.getReferencedObjectId();
    
        var zip = zipService.createZip(objectId, obj, dossier);
        return zipService.uploadZip(Flux.just(zip));
    })
    .flatMap(newWorkItemId -> {
        return updateMetadata(newWorkItemId);
    })
    .subscribe(() -> {
        finishItem();
    });

DMS服务。search（），此。DMS服务。getById（objectId），zipService。uploadZip（）all返回特定类型的Mono<代码>DMS服务。getDocument（objectId）返回由于支持大文件而产生的流量。如果我简单地使用一个文件，使用DataBuffer Mono可以处理小文件。复制：

    ...
    var contentMono = this.dmsService.getDocument(objectId);
    return contentMono;
})
.flatMap(content -> {
    Files.copy(content.asInputStream(), Path.of("test.pdf"));
    ...
}

我尝试过不同的方法，但总是遇到问题。

基于https://www.amitph.com/spring-webclient-large-file-download/#Downloading_a_Large_File_with_WebClient

DataBufferUtils.write(dataBuffer, destination).share().block();

当我尝试此操作时，. block（）之后的任何内容都不会执行。没有下载。

如果没有. share（），我得到一个异常，我可能不会使用block：java.lang.IllegalStateException： block（）/block First（）/block Last（）是阻塞的，线程reactor-超文本传输协议-nio-5不支持

由于数据缓冲区。write返回一个Mono。我的下一个假设是，我可以不调用block，而是调用Mono。zip（）这与我的其他值一起，但这也从未返回。

var media = this.dmsService.getDocument(objectId);
var writeMono = DataBufferUtils.write(media, filePath);
return Mono.zip(Mono.just(obj), Mono.just(dossier), writeMono);

对于如何实现这一点的任何投入都非常感谢。

Answer 1

我终于明白了，如果我使用一个可由techannel写的，返回一个通量

var media = this.dmsService.getDocument(objectId);
var file = Files.createTempFile(objectId, ".tmp");
WritableByteChannel filechannel = Files.newByteChannel(file, StandardOpenOption.WRITE);
var writeMono = DataBufferUtils.write(media, filechannel)
    .map(DataBufferUtils::release)
    .then(Mono.just(file));
return Mono.zip(Mono.just(obj), Mono.just(dossier), writeMono);