fs.createWriteStream流已创建但无写入内容的问题求助

你的代码核心问题在于resolve时机过早，以及没有正确处理文件流的异步写入逻辑：

1. 当前代码在https.request的响应回调里直接调用resolve(archive)，这时候文件流还没完成数据写入，Promise提前结束，但后续的写入操作无法得到保障，甚至可能因为上下文问题被中断。
2. 手动调用file.write(chunk)时没有处理异步写入的返回值，也没监听文件流的finish或error事件，既无法确认写入完成，也没法捕获写入环节的错误。

修复后的代码 #

用流的pipe方法是最简洁可靠的方案，它会自动处理数据传输、背压和流的结束逻辑：

const download = async (archive) => {
  return new Promise((resolve, reject) => {
    const opts = { method: 'GET' };
    const req = https.request(url, opts, (res) => {
      const file = fs.createWriteStream(`path/to/${archive}`);

      // 用pipe自动完成数据从响应流到文件流的传输
      res.pipe(file);

      // 文件流写入完成后再resolve Promise
      file.on('finish', () => {
        resolve(archive);
      });

      // 捕获文件流的写入错误
      file.on('error', (err) => {
        reject(err);
      });
    });

    // 捕获请求环节的错误
    req.on('error', (error) => {
      reject(error);
    });

    req.end();
  });
};

如果坚持手动处理data事件，需要补充背压处理和完整的事件监听：

const download = async (archive) => {
  return new Promise((resolve, reject) => {
    const opts = { method: 'GET' };
    const req = https.request(url, opts, (res) => {
      const file = fs.createWriteStream(`path/to/${archive}`);

      res.on('data', (chunk) => {
        // 若write返回false，说明缓冲区已满，暂停响应流读取
        if (!file.write(chunk)) {
          res.pause();
        }
      })
      .on('end', () => {
        file.end();
      })
      .on('error', (err) => {
        reject(err);
        file.destroy();
      });

      // 缓冲区清空后恢复响应流读取
      file.on('drain', () => {
        res.resume();
      });

      // 所有数据写入完成后resolve
      file.on('finish', () => {
        resolve(archive);
      });

      // 捕获文件流错误
      file.on('error', (err) => {
        reject(err);
        res.destroy();
      });
    });

    req.on('error', (error) => {
      reject(error);
    });

    req.end();
  });
};

关键注意事项 #

• 必须在文件流的finish事件触发后再resolve Promise，确保所有数据都写入磁盘。
• 务必监听所有流的error事件，否则错误会被静默吞掉，难以排查问题。
• pipe是Node.js处理流传输的推荐方式，内置了背压处理，比手动处理data事件更稳定。

这不是Node.js版本更新导致的问题，是代码本身的逻辑缺陷——之前可能因为数据量小、时机巧合偶然能工作，但本质上不符合流的异步处理规范。

内容的提问来源于stack exchange，提问作者punkish