Node.js Readable流简化构造时construct方法未调用原因排查

你的construct()方法从未被调用，核心原因是Node.js版本不兼容：

• 流简化构造模式下的construct配置项，是在Node.js 15.0.0版本才正式加入的稳定API，在14.x及更早的版本中，流内部不会识别传入的construct配置，既不会把它挂载为流实例的_construct()方法，也不会在流初始化阶段调用它。这就是你写在construct里的日志、属性赋值逻辑完全不执行的根本原因，后续read方法读取this._max自然得到undefined。
• 你看到的带callback参数的construct写法是符合API约定的，但如果运行环境版本不满足要求，就算完全照着示例写，construct方法也不会被触发。

升级到支持construct配置的Node版本（16.x、18.x、20.x及以上，均为官方维护的LTS版本）后，编写construct方法必须遵守回调约定，否则会出现流初始化后卡住、不执行后续read/write逻辑的问题：

注意：不要定义无参的普通construct函数，这种写法下你拿不到内部传入的callback参数，无法通知流初始化完成，会导致流永久卡住。

两种合法写法如下：

• 回调形式：方法接收一个callback参数，所有初始化逻辑（无论同步/异步）执行完成后必须调用callback()通知流初始化结束，如果初始化过程出错，就把Error对象作为参数传入callback

const { Readable } = require('stream');
const counter = new Readable({
  construct(callback) {
    this._max = 10;
    this._index = 1;
    console.log('construct初始化完成');
    // 必须调用，否则流会一直停留在初始化状态
    callback();
  },
  read() {
    const i = this._index++;
    if (i > this._max) {
      this.push(null);
    } else {
      this.push(String(i));
    }
  }
});

• 异步函数形式：不需要手动传入callback，函数返回的Promise状态变为fulfilled后，流会自动进入可运行状态，适合包含数据库连接、文件读取等异步初始化逻辑的场景

const { Readable } = require('stream');
const counter = new Readable({
  async construct() {
    // 可以直接使用await编写异步初始化逻辑
    this._max = 10;
    this._index = 1;
    console.log('construct异步初始化完成');
  },
  read() {
    const i = this._index++;
    if (i > this._max) {
      this.push(null);
    } else {
      this.push(String(i));
    }
  }
});

如果暂时无法升级Node版本，可以直接把初始化逻辑挪到创建流的代码外层，不需要依赖construct配置，运行效果和类继承版本完全一致：

const { Readable } = require('stream');
// 外层直接初始化状态
const max = 10;
let index = 1;
const counter = new Readable({
  read() {
    const i = index++;
    if (i > max) {
      this.push(null);
    } else {
      this.push(String(i));
    }
  }
});

// 后续事件监听逻辑不变
counter.on('readable', function() {
  let data;
  while ((data = this.read()) !== null) {
    console.log(String(data));
  }
});
counter.on('close', () => console.log('close'));

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