Node.js 16中使用child_process.spawn启动进程时如何阻塞读取子进程标准输出？

首先明确问题根源：

• 默认状态下，subprocess.stdout处于流动模式，data事件会持续消费缓冲区数据，此时调用read()自然拿不到内容，返回null。
• 另外，read()本身是非阻塞方法，不会主动等待数据到来，无数据时直接返回null。

以下是两种可行的阻塞式读取实现方案：

方法1：封装Promise实现阻塞读取函数 #

通过监听readable事件等待数据可用，将读取逻辑封装为可await的阻塞方法：

const { spawn } = require('child_process');

// 封装阻塞读取函数，支持指定读取字节数
async function readBlocking(stream, targetBytes = null) {
  return new Promise((resolve) => {
    // 切换到暂停模式，避免data事件提前消费数据
    stream.pause();

    function attemptRead() {
      const data = stream.read(targetBytes);
      if (data !== null) {
        resolve(data);
      } else {
        // 数据不可用时，监听readable事件重试
        stream.once('readable', attemptRead);
      }
    }

    attemptRead();
  });
}

// 使用示例
async function run() {
  const p = spawn('your-child-process'); // 替换为你的子进程命令

  // 向子进程输入第一行
  p.stdin.write('ping\n');
  // 阻塞读取输出
  const output1 = await readBlocking(p.stdout);
  console.log('收到输出:', output1.toString().trim());

  // 输入第二行
  p.stdin.write('ping\n');
  const output2 = await readBlocking(p.stdout);
  console.log('收到输出:', output2.toString().trim());
}

run();

方法2：使用异步迭代器（for await...of） #

Node.js 12+支持对可读流使用异步迭代器，会自动等待每个数据块，实现类阻塞效果：

const { spawn } = require('child_process');

async function run() {
  const p = spawn('your-child-process');

  // 启动异步迭代器监听输出
  (async () => {
    for await (const chunk of p.stdout) {
      console.log('收到输出:', chunk.toString().trim());
    }
  })();

  // 按逻辑向子进程输入数据
  p.stdin.write('ping\n');
  // 可根据实际场景调整等待逻辑，这里用定时器做示例
  await new Promise(resolve => setTimeout(resolve, 100));
  p.stdin.write('ping\n');
}

run();

注意事项 #

• 若需精确读取指定字节数，方法1的readBlocking可传入目标字节数（如readBlocking(p.stdout, 16)），但需确保子进程输出的字节数符合预期，避免无限等待。
• 向子进程stdin写入数据时，需根据子进程的输入要求添加换行符（如\n），确保子进程能正确识别输入行。

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