Node.js中实现类似Linux pipe()的非标准IPC管道方案是什么？

问题描述 #

需要创建子进程并传递一个独立的文件描述符，让子进程写入进度数据，父进程读取并处理该数据。在Linux中会用pipe()创建成对相连的文件描述符，将写入端FD传递给子进程，父进程从读取端读取，同时在fork()后关闭父进程的写入FD和子进程的读取FD。要求不使用stdio的三个标准描述符，也不使用命名管道或Unix套接字，询问Node.js中的等效实现方案。

已尝试的研究方向（未找到理想方案） #

• 原生npm库node-pipe2完全匹配需求，但周下载量仅1次，仅支持OSX和Linux，不兼容Windows，低流行度可能存在未知Bug
• fsPromises.open()需要指定文件名，无法创建匿名管道对应的文件句柄
• Node.js源码中的PipeWrap类（位于src/pipe_wrap.cc）未调用创建成对描述符的uv_pipe()接口，该功能未通过fsPromises暴露给上层
• stream模块的pipeline仅用于连接子进程的stdio流，不支持创建独立的匿名管道
• stream.Duplex仅实现JavaScript层面的流管道逻辑，与系统级文件描述符无关
• 用ffi-napi调用libc的pipe()函数可行，但需要自行实现OSX和Windows的跨平台适配逻辑
• ChatGPT推荐的Unix套接字方案不符合需求

当前临时方案 #

目前暂时使用node-pipe2，接受其不支持Windows的限制。但这是项目中引入的第一个原生库，项目需要兼容x64和arm64架构，暂时无法测试arm64环境，可能存在潜在问题。

可行方案建议 #

1. 基于child_process的自定义stdio扩展 #

Node.js的child_process.spawn()支持扩展stdio数组，通过指定额外的pipe项可以创建独立的管道描述符，完全内置且跨平台支持：

// 父进程代码
const { spawn } = require('child_process');
// 前三位对应标准IO（stdin/stdout/stderr），第四位为自定义管道（对应FD3）
const child = spawn('node', ['child.js'], {
  stdio: ['ignore', 'ignore', 'ignore', 'pipe']
});

// 从自定义管道读取子进程发送的进度数据
child.stdio[3].on('data', (data) => {
  console.log('收到进度数据:', data.toString().trim());
});

child.stdio[3].on('end', () => {
  console.log('进度数据传输完成');
});

// 子进程child.js代码
const fs = require('fs');
// 通过FD3写入进度数据
const writeStream = fs.createWriteStream(null, { fd: 3 });
writeStream.write('进度：30%\n');
setTimeout(() => {
  writeStream.write('进度：70%\n');
  setTimeout(() => {
    writeStream.end('进度：100%\n');
  }, 1000);
}, 1000);

该方案无需额外依赖，FD完全独立于标准IO，Windows、Linux、OSX均兼容。

2. 用worker_threads替代（子进程为Node.js脚本时） #

如果子进程是Node.js脚本，可以使用worker_threads模块，通过MessagePort传递进度数据。虽然不基于文件描述符，但能实现同样的进程间数据传输需求，更贴合Node.js的JavaScript层设计。

3. 封装跨平台系统级pipe调用 #

如果必须使用系统级文件描述符管道，可以基于ffi-napi封装跨平台逻辑：

• Linux/OSX环境调用libc的pipe()接口
• Windows环境调用CreatePipe() API
  需自行处理不同系统的API差异、文件描述符管理（关闭冗余FD）等细节，实现完全跨平台的匿名管道功能。

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