文章/答案/技术大牛

发布

社区首页 >问答首页 >使用Spring Webclient和AsynchronousFileChannel下载文件，文件为空

问使用Spring Webclient和AsynchronousFileChannel下载文件，文件为空
EN

Stack Overflow用户

提问于 2021-04-27 22:32:44

回答 1查看 143关注 0票数 0

我想通过网址下载几张照片，使用Webflux和AsynchronousFileChannel，所有的文件都是创建的，但为空。

下面是我的代码：

public void downloadFilesFromUrl() throws IOException {
    List<Photo> notDownloadedFiles = //get photos with name and URL;
    for (Photo photo : notDownloadedFiles) {
        Path path = Paths.get(pathToFiles + File.separator + photo.getPhotoName());
        WebClient client = WebClient.builder().baseUrl(photo.getLoadSource()).build();
        Flux<DataBuffer> dataBufferFlux = client
                .get().accept(MediaType.APPLICATION_OCTET_STREAM)
                .retrieve()
                .bodyToFlux(DataBuffer.class);
        saveFileOnComputer(path, dataBufferFlux);
    }
}

private void saveFileOnComputer(Path path, Flux<DataBuffer> dataBufferFlux) throws IOException {
    AsynchronousFileChannel asynchronousFileChannel = AsynchronousFileChannel.open(path, CREATE, WRITE);
    DataBufferUtils.write(dataBufferFlux, asynchronousFileChannel)
            .doOnNext(DataBufferUtils.releaseConsumer())
            .doAfterTerminate(() -> {
                try {
                    asynchronousFileChannel.close();
                } catch (IOException ignored) { }
            }).then();
}

如果我尝试使用

DataBufferUtils.write(dataBufferFlux, path, StandardOpenOption.CREATE).block();

而不是调用saveFileOnServer(..)方法，一切都很好。但我想确切地使用AsynchronousFileChannel。

java

spring

spring-boot

spring-webflux

spring-webclient

回答 1

Stack Overflow用户

发布于 2021-04-28 01:57:39

好吧，我想我把它修好了。

private void saveFileOnServer(Path path, Flux<DataBuffer> dataBufferFlux) throws IOException {
    AsynchronousFileChannel asynchronousFileChannel = AsynchronousFileChannel.open(path, CREATE, WRITE);
    DataBufferUtils.write(dataBufferFlux, asynchronousFileChannel).subscribe();
}

官方documentation说：“请注意，直到订阅了返回的Flux，写入过程才会开始”。

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/67285154

复制

相似问题

问使用Spring Webclient和AsynchronousFileChannel下载文件，文件为空
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Spring Webclient和AsynchronousFileChannel下载文件，文件为空EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Spring Webclient和AsynchronousFileChannel下载文件，文件为空
EN