源程序终止/崩溃时，如何捕获管道输出的完整内容？

这个问题的核心在于：当发送进程（a.js）意外崩溃时，它的标准输出会被立即关闭，导致接收进程（b.js）的标准输入触发end事件。而Node.js进程默认会在标准输入结束后直接退出，此时标准输出缓冲区中可能还有未完成写入的数据，最终导致输出不完整。

从接收方（b.js）角度的解决方案 #

我们需要让接收进程等待标准输出完全写完所有数据后再退出，而不是在输入结束时立即终止。具体可以通过监听stdout的finish事件来实现——这个事件只有当所有数据都被写入底层文件描述符后才会触发。

修改后的b.js代码如下：

const stdin = process.stdin;
const stdout = process.stdout;

// 建立管道连接
stdin.pipe(stdout);

// 当输入结束时，不要立即退出，而是告知stdout没有更多数据要写入
stdin.on('end', () => {
  stdout.end();
});

// 等待stdout完成所有数据写入后，再退出进程
stdout.on('finish', () => {
  process.exit(0);
});

// 处理可能的写入错误（比如管道另一端意外关闭）
stdout.on('error', (err) => {
  // EPIPE错误是管道另一端关闭时的正常情况，优雅退出即可
  if (err.code === 'EPIPE') {
    process.exit(0);
  }
  // 其他错误抛出并异常退出
  throw err;
});

验证效果 #

用你提供的CLI命令替换接收端代码，测试是否能输出完整内容：

node --eval "let index = 0; let output = ''; while (index < 1000000) { output += ' ' + (index++); } console.log(output); throw new Error('test');" | node --eval "const stdin = process.stdin; const stdout = process.stdout; stdin.pipe(stdout); stdin.on('end', () => { stdout.end(); }); stdout.on('finish', () => { process.exit(0); }); stdout.on('error', (err) => { if (err.code === 'EPIPE') process.exit(0); throw err; });"

执行后你会看到输出最终会到999999，不再提前终止。

为什么会出现这个问题？ #

• Node.js的标准输出在管道模式下默认是块缓冲（默认64KB），大体积数据会被分成多个块异步写入。
• 当发送进程崩溃时，管道被关闭，接收进程的stdin触发end事件，默认行为是直接退出进程，此时stdout缓冲区中剩余的块还没来得及写入到终端/后续管道。
• 通过监听finish事件，我们确保了所有缓冲数据都被处理完成后才退出，从而避免了数据丢失。

补充：关于cat的复现问题 #

cat的这个行为和系统内核的管道缓冲策略有关——当发送进程意外终止时，内核可能还没把所有数据传递给cat的输入缓冲区。但从Node.js接收方的角度，我们的解决方案是通用的，因为它强制等待输出完成，不受发送方的终止方式影响。

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