如何实现Node stream错误恢复，保证方法始终返回可用流？

结论 #

可以实现该需求，核心思路是通过中转流屏蔽底层流的切换逻辑，对外始终返回统一的流实例，捕获读流的错误后自动切换到新建缩略图的流即可。

实现方案 #

Stream的错误处理和Promise不同，它是通过事件触发报错，无法直接用try/catch捕获，因此我们可以借助PassThrough中转流实现无缝切换：

const { PassThrough } = require('stream');
const { pipeline } = require('stream/promises'); // Node.js 15+ 可直接引入，低版本可以用util.promisify包装原生pipeline

function getThumbnail(id, width, height) {
  // 对外返回的统一中转流，调用方拿到的始终是该实例
  const output = new PassThrough();

  // 先尝试读取缓存缩略图
  const readStream = readThumbnail(id, width, height);
  readStream.on('error', async (err) => {
    // 判断是否是缩略图不存在的报错，比如本地文件场景下ENOENT错误码
    if (err.code === 'ENOENT') {
      try {
        // 触发创建缩略图逻辑，拿到生成的流
        const createStream = await createThumbnail(id, width, height);
        // 将创建流的数据导入中转流
        await pipeline(createStream, output);
      } catch (createErr) {
        // 创建也失败的话，将错误透传给中转流，调用方可自行监听处理
        output.destroy(createErr);
      }
      return;
    }
    // 其他非预期错误直接透传
    output.destroy(err);
  });

  // 读流正常的场景直接将数据导入中转流
  pipeline(readStream, output).catch(() => {});

  return output;
}

注意事项 #

• 所有流实例都必须绑定error事件监听，否则Node.js会抛出未捕获异常直接终止进程
• 使用pipeline做流拼接，它会自动处理流销毁、错误传递逻辑，避免手动用pipe可能引发的内存泄漏问题
• 你可以根据业务需求扩展降级逻辑，比如创建缩略图也失败时，自动导入默认占位图的流，保证调用方永远拿到可用的数据流

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