如何在Node.js子进程中刷新Linux命令的stdout？及边传数据边消费的实现

你提到的关闭stdin、用stdbuf取消缓冲这两种方法确实管用，但如果要一边给命令喂数据，一边实时消费它的输出，还有更顺手的方案，我给你梳理清楚：

先说说你已经知道的可行方案 #

• 关闭stdin流：调用child.stdin.end()，这相当于告诉子进程"我没数据给你了"，像uniq这类命令收到这个信号后，就会立刻把缓冲区里的内容刷出来，输出结果。
• 用stdbuf改缓冲策略：启动命令的时候套一层stdbuf，比如spawn('stdbuf', ['-oL', 'uniq'])，-oL是让stdout用行缓冲模式，这样命令每输出一行就会立刻推给Node.js，不会攒满缓冲区才输出。

重点：边喂数据边实时拿输出的最优姿势 #

核心思路是让子进程的stdout不要攒数据，有输出就立刻发出来，结合Node.js的流机制来处理，分几种情况：

1. 对支持行缓冲的命令：靠换行符触发实时输出 #

像uniq、grep这类工具，只要让它们用行缓冲模式，每次输入换行符的时候，它们就会把当前行的处理结果输出。我们可以用stdbuf强制开启行缓冲，然后监听stdout的data事件实时处理：

const { spawn } = require('child_process');
// 用stdbuf强制uniq使用行缓冲
const child = spawn('stdbuf', ['-oL', 'uniq']);

// 实时捕获输出，一有数据就处理
child.stdout.on('data', (chunk) => {
  console.log(`实时拿到结果: ${chunk.toString('utf8')}`);
});

// 分批次给子进程喂数据，模拟流式输入
child.stdin.write('a\n');
setTimeout(() => child.stdin.write('b\n'), 1000);
setTimeout(() => child.stdin.write('b\n'), 2000);
setTimeout(() => child.stdin.write('c\n'), 3000);
// 最后告诉子进程输入结束
setTimeout(() => child.stdin.end(), 4000);

2. 对不支持行缓冲的命令：用工具强制取消缓冲 #

如果是一些第三方命令，本身不支持行缓冲，除了stdbuf，还可以用unbuffer（需要先装expect包，比如apt install expect）来彻底禁用缓冲：

const child = spawn('unbuffer', ['uniq']);
// 后续的监听和输入逻辑和上面一样

3. 终极方案：给子进程分配伪终端 #

Linux命令默认在连接终端时用行缓冲，而通过管道/重定向时用全缓冲。Node.js的spawn默认不给子进程分配终端，所以才会有缓冲问题。我们可以用pty.js这类库给子进程分配一个伪终端（pty），让它以为自己在和终端交互，自然就会用行缓冲：

const { spawn } = require('pty.js');
const child = spawn('uniq');

// 实时接收输出
child.on('data', (data) => {
  console.log('实时输出:', data.toString());
});

// 流式输入数据
child.write('a\nb\nb\nc\n');
// 最后可以用child.end()关闭输入

补充说明 #

为什么你的原始代码里，直接写数据后看不到实时输出？因为uniq默认在非终端环境下用全缓冲，它会攒够数据才输出，直到你关闭stdin才会把缓冲区的内容刷出来。而上面的方法都是通过改变缓冲策略，让它有输出就立刻发给Node.js。

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