使用createReadStream时未捕获Promise错误的排查与解决

问题根源 #

你的processFile是async函数，但内部fs.createReadStream的error事件回调属于独立的异步上下文——回调里的throw err或Promise.reject(err)根本不会被main里的try/catch捕获。原因有两点：

1. async函数默认返回一个已resolve的空Promise（你没让它返回关联流操作的Promise），所以await processFile()会直接走完，不会等待流的事件。
2. 事件回调里抛出的错误会绕过async函数的Promise链，直接触发Node.js的全局未捕获异常处理器，这就是你最后看到错误栈的原因。

解决方案 #

方案一：将流操作包装为Promise

手动把流的生命周期包裹进Promise，让错误和成功状态能传递到async/await的链中：

const fs = require('fs');
const source = 'source.tx';

async function processFile() {
  return new Promise((resolve, reject) => {
    const fileStream = fs.createReadStream(source);

    fileStream.on('error', (err) => {
      console.log("An error occured while opening the file");
      reject(err); // 将错误传递给Promise的reject回调
    });

    // 可选：处理文件内容
    fileStream.on('data', (chunk) => {
      // 在这里处理读取到的文件块
    });

    fileStream.on('end', () => {
      resolve(); // 文件读取完成后标记Promise为resolve状态
    });
  });
}

async function main(){
  try{
    await processFile();
    console.log("文件读取完成");
  } catch(err){
    console.error("catching error:", err.message);
    return;
  }
}

main();

方案二：使用fs.promisesAPI（更推荐）

Node.js内置的fs.promises提供了Promise化的文件操作，完全适配async/await语法，无需手动处理事件：

const fs = require('fs').promises;
const source = 'source.tx';

async function processFile() {
  try {
    // 读取整个文件内容（如需流式读取可结合`fs.promises.open`）
    const content = await fs.readFile(source, 'utf8');
    console.log("文件内容:", content);
  } catch (err) {
    console.log("An error occured while opening the file");
    throw err; // 抛出错误让上层try/catch捕获
  }
}

async function main(){
  try{
    await processFile();
  } catch(err){
    console.error("catching error:", err.message);
    return;
  }
}

main();

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