NodeJS：无需人工交互向持久化子进程stdin发送消息

我完全懂你的痛点——和非Node的交互式子进程（比如你这个Python的REPL风格程序）持续收发消息，确实不像fork()处理Node子进程那样顺手。先帮你拆解下之前尝试踩的坑，再给你正确的实现方案：

先说说你之前尝试的问题出在哪 #

1. 尝试2写入父进程stdin：父进程的stdin默认关联终端，直接write()往往因为流的状态（比如默认处于暂停）不生效，而且这本来就不是正确的消息传递路径。
2. 尝试3直接写子进程stdin无反应：核心问题是Python默认会缓冲stdout输出，导致子进程的结果没即时传给父进程；另外你同时把父进程stdin pipe给子进程，可能造成流的冲突。
3. 尝试4用end()关闭stdin：这会直接切断子进程的输入流，子进程自然就退出了，肯定没法持续通信。

正确的实现方案 #

关键要解决两个核心问题：禁用子进程的IO缓冲、正确处理子进程的输入输出流。以下是完整可运行的代码：

父进程（Node.js）代码

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

// 重点：启动Python时加`-u`参数，强制禁用stdin/stdout缓冲
const child = spawn('/usr/local/bin/python3', ['-u', join(__dirname, 'hello_childstdin.py')]);

// 处理子进程stdout：因为data事件可能分片返回，需要用缓冲区拼接后按行处理
let stdoutBuffer = '';
child.stdout.on('data', (data) => {
  stdoutBuffer += data.toString();
  const lines = stdoutBuffer.split('\n');
  stdoutBuffer = lines.pop(); // 保留未完成的行，避免丢数据
  lines.forEach(line => {
    if (line.trim()) {
      console.log(`子进程输出: ${line}`);
    }
  });
});

// 处理子进程错误输出
child.stderr.on('data', (data) => {
  console.error(`子进程错误: ${data.toString()}`);
});

// 监听子进程退出事件
child.on('close', (code) => {
  console.log(`子进程已退出，退出码: ${code}`);
});

// 封装发送消息的工具函数：必须加换行符，因为Python的input()按行读取
function sendToChild(message) {
  child.stdin.write(`${message}\n`);
}

// 测试：定时发送不同消息
setTimeout(() => sendToChild('hello'), 500);
setTimeout(() => sendToChild('do it'), 1500);
setTimeout(() => sendToChild('test_cmd'), 2500);

子进程（Python）代码

while True:
    # input()会自动打印提示符，父进程会收到这个输出
    cmd = input('Enter command here (hello, bye, do it): ')
    print(f'cmd: {cmd}')
    
    # 生成响应消息
    if cmd in ('hello', 'bye', 'do it'):
        msg = f'{cmd}: done'
    else:
        msg = f'undefined cmd: {cmd}'
    
    # 写入文件的逻辑保留
    with open('/path/to/hello_childstdin.txt', 'a') as f:
        f.write(f'{msg}\n')
    
    # 输出响应，因为加了-u参数，会即时传给父进程
    print(f'msg: {msg}')

核心注意事项 #

1. Python的-u参数是关键：这个参数会强制Python关闭stdin/stdout的缓冲，确保子进程的输出能即时传递给父进程，不会出现“消息发了但父进程迟迟收不到结果”的情况。
2. 不要关闭child.stdin：除非你确实要终止子进程，否则保持stdin打开才能持续发送消息。
3. 处理stdout的分片数据：子进程的输出可能被拆分成多个data事件返回，必须用缓冲区拼接后按行处理，避免丢数据。
4. 发送消息要加换行符：Python的input()函数是读取到换行符才会结束输入，所以每次发送消息都要在末尾加上\n。

如果需要同时支持人工输入和程序自动发送，你可以单独监听父进程的stdin事件，把用户输入转发给子进程，但要注意和自动发送的消息做好隔离哦。

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