首页 > 解决方案 > 如何在不等待提取结束的情况下将响应写入流?

问题描述

我需要获取音频文件并写入目录。我担心我必须等待提取结束才能下载所有文件,然后写入/保存到文件。是否可以获取音频文件并同时写入文件。我只是认为它可能像“管道”。从服务中获取块,不要等待获取过程结束,只需将刚刚下载的块写入文件。那可能吗?如果是的话,你能给我举个例子吗?

这是我的代码:


const fetchAndWriteFiles = async (url, path) => {
  const res = await fetch(url)

  const fileStream = fs.createWriteStream(path)
  await new Promise((resolve, reject) => {
    res.body.pipe(fileStream)
    res.body.on('error', err => {
      reject(err)
    })
    fileStream.on('finish', function () {
      resolve()
    })
  })
}

标签: javascriptnode.jsstreamfetchnode-fetch

解决方案


await fetch()不下载整个文件(如果它很大)。它读取文件的第一个块(在我在调试器中查看的示例中,第一个块的长度为 16384 字节),从中提取标头,然后将第一个块的其余部分留在等待读出的流中.

执行此操作后,将读取文件的后续部分,.pipe()并清空现有流。文件的其余部分将以块的形式读取并以块的形式写入磁盘。要对此进行测试,您必须使用一个足够大的文件,以便读取/写入它需要多个块。

而且,事实上,当我在下载更大的响应时检测事物时,我会看到await fetch()完成后发生的多次读取和写入。

因此,您的代码似乎已经在做您似乎感兴趣的事情。如果您正在下载的页面很小(适合一个缓冲区),您将看不到多次读取/写入,因为整个响应可能一口气读完,但是对于较大的响应,它肯定会分块进行。块的大小也可能取决于数据从源到达的速度。


推荐阅读