如何让NodeJS函数等待fs.writeFile写入操作完成后再执行后续逻辑

问题根因 #

进程在文件写入完成前提前退出，核心是两个问题：

• 异步流程没有被正确等待：fs.writeFile是异步非阻塞API，原有回调写法没有把文件写入操作纳入完整的流程等待链路，进程可能在写入操作完成前就判定事件循环无待执行任务直接退出
• 原有代码缺少异常捕获、存在语法和数据处理隐患，很容易运行报错中断

可直接运行的实现代码 #

场景1：接收完所有响应后一次性写入文件 #

适配你需要分块读取响应、汇总后统一写文件的需求：

const https = require('node:https');
const fs = require('node:fs/promises');
const path = require('node:path');

// 配置参数
const targetUrl = 'https://encrypted.google.com/';
const savePath = path.resolve(__dirname, 'save.html');

async function fetchAndSave() {
  await new Promise((resolve, reject) => {
    const req = https.request(targetUrl, (res) => {
      // 处理HTTP状态码异常
      if (res.statusCode < 200 || res.statusCode >= 300) {
        return reject(new Error(`请求异常，状态码：${res.statusCode}`));
      }

      // 用Buffer数组存储数据块，避免字符串拼接损坏二进制内容
      const chunkList = [];
      res.on('data', (chunk) => {
        chunkList.push(chunk);
      });

      res.on('end', async () => {
        try {
          // 拼接所有数据块为完整内容
          const fullData = Buffer.concat(chunkList);
          // 等待文件完全写入
          await fs.writeFile(savePath, fullData);
          console.log(`数据已写入：${savePath}`);
          resolve();
        } catch (writeErr) {
          reject(writeErr);
        }
      });

      // 监听响应传输阶段的错误
      res.on('error', reject);
    });

    req.on('error', reject);
    req.end();
  });
}

// 执行流程，所有操作完成后进程才会正常退出
fetchAndSave().catch(err => {
  console.error('执行失败：', err);
  process.exitCode = 1;
});

场景2：边接收响应边写入文件（适合大文件） #

如果下载的文件体积较大，全量存在内存会占用过多资源，可以直接用流管道边接收边写入，不需要手动拼接数据块：

const https = require('node:https');
const fs = require('node:fs');
const { pipeline } = require('node:stream/promises');
const path = require('node:path');

const targetUrl = 'https://encrypted.google.com/';
const savePath = path.resolve(__dirname, 'save.html');

async function fetchAndSaveByStream() {
  await new Promise((resolve, reject) => {
    const req = https.request(targetUrl, async (res) => {
      if (res.statusCode < 200 || res.statusCode >= 300) {
        return reject(new Error(`请求异常，状态码：${res.statusCode}`));
      }
      try {
        // 管道自动处理数据流动、错误捕获、写入完成等待
        await pipeline(res, fs.createWriteStream(savePath));
        console.log(`数据已写入：${savePath}`);
        resolve();
      } catch (pipeErr) {
        reject(pipeErr);
      }
    });
    req.on('error', reject);
    req.end();
  });
}

fetchAndSaveByStream().catch(err => {
  console.error('执行失败：', err);
  process.exitCode = 1;
});

关键注意点 #

• 你原有代码里console.log("data => " path)存在语法错误，字符串拼接缺少+运算符，运行会直接抛出异常
• 不要用多层回调嵌套写异步逻辑，很容易出现流程等待遗漏，优先用Promise + async/await写法，所有异步操作都加await确保执行完成后再走后续流程
• 接收HTTP响应块时优先存储Buffer数组，最后用Buffer.concat拼接为完整内容，不要直接转字符串拼接，否则下载图片、压缩包等非文本内容时会出现数据损坏
• 除了监听request对象的错误，还要监听response对象的错误事件，否则响应传输过程中出现的网络异常无法被捕获
• 不需要手动调用process.exit()强制退出进程，只要所有异步操作都执行完成，Node.js事件循环清空待执行任务后会自动正常退出；如果在文件写入完成前手动调用process.exit()，会直接中断写入操作导致文件损坏

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