Node.js child_process多次写入stdin并获取stdout输出问题求助

我来帮你捋清楚这个问题：你想用child_process给子进程多次写stdin，每次提交后拿到stdout输出，但试了cork/uncork不管用，只有end()能看到结果对吧？

为啥cork/uncork没用？ #

首先得明白cork()和uncork()的作用——它们只是控制Node.js是否缓冲写入的数据，不会触发子进程的执行逻辑。你用的是spawn('node')，也就是Node的交互式REPL，它的规则是收到一行输入（带换行符\n）才会执行代码，但这里还有个坑：默认情况下，子进程的stdout是缓冲输出的，只有当缓冲区满或者进程退出时才会把内容发回父进程，这就是为啥你只有调用end()（让子进程退出）才能看到输出的原因。

解决方案：让子进程实时响应输入并输出 #

要实现多次写入并实时获取结果，我们需要调整子进程的启动选项，同时封装一个“写入-等待输出”的逻辑，确保每次写入后能拿到对应的结果。

1. 基础示例代码

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

// 启动Node子进程，关闭REPL的readline避免提示符，强制实时输出
const node = spawn('node', ['-i'], {
  env: { ...process.env, NODE_NO_READLINE: '1' },
  stdio: ['pipe', 'pipe', 'inherit']
});

// 监听子进程的stdout，过滤掉多余的提示符
node.stdout.on('data', (data) => {
  const output = data.toString().replace(/^> /gm, '').trim();
  if (output) {
    console.log(`子进程输出: ${output}`);
  }
});

// 封装异步函数：写入输入并等待输出结果
async function sendCommand(input) {
  return new Promise((resolve) => {
    // 临时监听输出，拿到结果后移除监听
    const handleOutput = (data) => {
      const output = data.toString().replace(/^> /gm, '').trim();
      if (output) {
        node.stdout.off('data', handleOutput);
        resolve(output);
      }
    };
    node.stdout.on('data', handleOutput);
    // 写入命令并加换行，触发REPL执行
    node.stdin.write(`${input}\n`);
  });
}

// 测试多次写入
(async () => {
  const result1 = await sendCommand(`console.log('hello, world!')`);
  console.log(`第一次执行结果: ${result1}`);

  const result2 = await sendCommand(`10 + 20`);
  console.log(`第二次执行结果: ${result2}`);

  const result3 = await sendCommand(`const name = 'Maciej'; \`Hello \${name}\``);
  console.log(`第三次执行结果: ${result3}`);

  // 最后关闭子进程
  node.stdin.end();
})();

2. 封装成抽象层

如果你要构建可复用的抽象层，可以把逻辑封装成一个类，方便调用：

class ProcessCommunicator {
  constructor(command, args = [], options = {}) {
    // 合并默认选项和用户传入的选项
    this.child = spawn(command, args, {
      env: { ...process.env, NODE_NO_READLINE: '1' },
      stdio: ['pipe', 'pipe', 'inherit'],
      ...options
    });
    this.currentResolver = null;

    // 统一处理子进程输出
    this.child.stdout.on('data', (data) => {
      const output = data.toString().replace(/^> /gm, '').trim();
      if (output && this.currentResolver) {
        const resolve = this.currentResolver;
        this.currentResolver = null;
        resolve(output);
      }
    });
  }

  // 发送命令并返回结果
  async send(input) {
    return new Promise((resolve) => {
      this.currentResolver = resolve;
      this.child.stdin.write(`${input}\n`);
    });
  }

  // 关闭子进程
  close() {
    this.child.stdin.end();
  }
}

// 使用示例
(async () => {
  const nodeCommunicator = new ProcessCommunicator('node', ['-i']);
  
  const res1 = await nodeCommunicator.send(`console.log('抽象层测试1')`);
  console.log(res1);
  
  const res2 = await nodeCommunicator.send(`Math.pow(2, 10)`);
  console.log(res2);
  
  nodeCommunicator.close();
})();

注意事项 #

• 如果你的子进程不是Node REPL，而是其他命令（比如bash、python），需要调整结束符和输出过滤逻辑——比如bash也是用换行触发执行，但输出格式不同。
• 要避免多个命令同时发送导致输出混乱，所以用异步函数等待上一个命令的结果返回后再发下一个，确保顺序执行。

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