Node.js 第二次spawn创建的子进程无法接收stdin消息问题求助

问题根因 #

1. 写入stdin时机不对：spawn是异步操作，刚创建子进程就立刻写入数据时，子进程的stdin流可能还未完成初始化，数据会丢失或被缓存，第一次执行成功只是子进程初始化速度刚好赶上写入操作的巧合。
2. 旧进程资源未完全清理：你注释了close事件里的流销毁逻辑，且错误地用exit事件做清理（exit触发时子进程已退出，但stdio流可能还存在未处理的缓冲数据，只有close事件才代表所有流完全关闭）。
3. IPC报错ERR_IPC_CHANNEL_CLOSED是因为你大概率调用了已退出的旧子进程实例的send方法，未使用新创建的子进程实例发送消息。

修复代码 #

主进程示例

const { spawn } = require('child_process');
let isRunning = false;
const taskQueue = [];

// 触发事件时调用该方法添加任务，自动控制串行执行
function addTask(script, arg1, sendMsg) {
  taskQueue.push({ script, arg1, sendMsg });
  runNextTask();
}

function runNextTask() {
  if (isRunning || taskQueue.length === 0) return;
  isRunning = true;
  const { script, arg1, sendMsg } = taskQueue.shift();

  // 每次创建全新的子进程实例，不要复用旧实例引用
  const child = spawn('node', [script, arg1], {
    cwd: './',
    stdio: ['pipe', 'pipe', 'pipe', 'ipc']
  });

  // 等子进程启动完成、流初始化后再写入消息
  child.on('spawn', () => {
    child.stdin.write(sendMsg, () => {
      // 写入完成后主动end stdin，通知子进程输入结束，避免消息卡住
      child.stdin.end();
    });
  });

  // 按需监听子进程输出
  child.stdout.on('data', data => console.log('子进程输出：', data.toString()));
  child.stderr.on('data', data => console.error('子进程错误：', data.toString()));

  // 所有流关闭后再清理标记，运行下一个任务
  child.on('close', code => {
    console.log(`子进程退出，退出码：${code}`);
    // 手动销毁残留流，避免资源泄漏
    child.stdin.destroy();
    child.stdout.destroy();
    child.stderr.destroy();
    isRunning = false;
    runNextTask();
  });

  child.on('error', err => {
    console.error('子进程启动失败：', err);
    isRunning = false;
    runNextTask();
  });
}

// 调用示例
addTask('./child.js', 'testArg', 'my_message');

子进程示例

let receiveMsg = '';
// 拼接所有buffer，避免数据被截断
process.stdin.on('data', data => {
  receiveMsg += data.toString();
});

// 监听stdin end事件，确保所有数据接收完成再执行业务逻辑
process.stdin.on('end', async () => {
  // 此处写你的业务代码
  console.log('收到主进程消息：', receiveMsg);
  process.exit(0);
});

// 若使用IPC通信的写法，可替换为以下代码，主进程调用child.send发消息即可
// process.on('message', msg => {
//   console.log('IPC收到消息：', msg);
//   process.exit(0);
// })

注意事项 #

• 不要省略child.stdin.end()调用，否则子进程会一直等待输入，不会触发end事件。
• 使用IPC通信时，必须确保调用send方法的是当前正在运行的新子进程实例，不要使用缓存的旧实例引用。

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