如何阻止Node.js子进程管道流间的终止信号传播？

核心思路 #

• 启动第二个进程时，确保其stdin不会因第一个进程的输出流结束而被自动关闭
• 监听第一个进程的exit事件，在进程终止时自动重启并重新建立流连接
• 封装第一个进程的启动逻辑，方便重复调用

代码实现 #

const cp = require('child_process');

// 启动第二个进程，保持stdin处于可写入状态
const secondProc = cp.spawn('/ffmpeg/path', [/* args */], {
  stdio: ['pipe', 'inherit', 'inherit']
});

// 封装第一个进程的启动逻辑
function startFirstProc() {
  const firstProc = cp.spawn('/some/proc/path', [/* args */]);

  // 将stdout pipe到第二个进程的stdin，设置end: false避免关闭目标流
  firstProc.stdout.pipe(secondProc.stdin, { end: false });

  // 捕获第一个进程的错误输出
  firstProc.stderr.on('data', (data) => {
    console.error(`第一个进程错误: ${data}`);
  });

  // 进程终止时自动重启
  firstProc.on('exit', (code, signal) => {
    console.log(`第一个进程退出，代码: ${code}，信号: ${signal}。正在重启...`);
    // 添加延迟避免频繁崩溃导致资源占用过高
    setTimeout(startFirstProc, 1000);
  });

  // 处理进程启动失败的情况
  firstProc.on('error', (err) => {
    console.error(`启动第一个进程失败: ${err.message}`);
    setTimeout(startFirstProc, 2000);
  });

  return firstProc;
}

// 初始化启动第一个进程
let firstProc = startFirstProc();

// 主进程退出时优雅关闭子进程
process.on('SIGINT', () => {
  console.log('开始关闭进程...');
  firstProc.kill();
  secondProc.stdin.end(); // 手动结束第二个进程的输入流，使其正常退出
});

关键细节解释 #

• pipe({ end: false })：这是解决问题的核心设置。默认情况下，当源流（firstProc.stdout）结束时，会自动调用目标流（secondProc.stdin）的end()方法，导致第二个进程退出。设置end: false后，源流结束不会关闭目标流，让第二个进程持续运行。
• 重启逻辑：通过监听exit事件触发重启，添加延迟避免因进程频繁崩溃导致资源耗尽。
• 错误处理：监听error事件处理进程启动失败的场景，保证重启逻辑的稳定性。
• 优雅退出：主进程收到终止信号时，手动关闭第一个进程并结束第二个进程的输入流，避免产生僵尸进程。

替代方案（灵活流控制） #

如果需要更复杂的流处理（比如数据缓存、格式转换），可以用PassThrough流作为中间层，让中间流始终与第二个进程的stdin保持连接：

const { PassThrough } = require('stream');

const intermediateStream = new PassThrough();
intermediateStream.pipe(secondProc.stdin, { end: false });

function startFirstProc() {
  const firstProc = cp.spawn('/some/proc/path', [/* args */]);
  // 只需将新进程的输出接入中间流即可
  firstProc.stdout.pipe(intermediateStream, { end: false });
  // 其余错误、退出监听逻辑同上
}

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