NodeJS向子进程发送net.socket时触发SentHandleNotReceivedWarning求助

你遇到的SentHandleNotReceivedWarning错误，核心原因是基于FIFO（命名管道）文件描述符创建的net.Socket无法通过Node.js的IPC机制正确传递到子进程。

Node.js进程间send()方法（包括cluster模块的worker.send()）支持传递的句柄类型是有限的，仅包括TCP套接字、UDP套接字、匿名管道等内核层面支持句柄转移的对象。而FIFO是命名管道，它的文件描述符不具备可转移的特性，当你尝试传递基于FIFO的net.Socket时，内核无法完成句柄的正确迁移，导致子进程无法接收到有效的句柄，从而触发警告。

针对你的场景，有两种可行的修正方式：

方式1：让Worker直接打开FIFO #

不需要在主进程创建Socket并传递，而是让Worker进程自行打开FIFO文件进行读写：

const cluster = require('cluster');
const cp = require('child_process');
const fs = require('fs');
const net = require('net');

if(cluster.isPrimary) {
  const worker = cluster.fork();
  // 创建FIFO
  cp.execSync('mkfifo __test');
  // 主进程直接写入FIFO
  fs.writeFile('__test', 'hello from primary', (err) => {
    if(err) console.error(err);
  });
} else {
  // Worker自行打开FIFO并创建Socket
  fs.open('__test', fs.constants.O_RDONLY | fs.constants.O_NONBLOCK, (e, fd) => {
    if(e) return console.log(e);
    const socket = new net.Socket({ fd, allowHalfOpen: true });
    socket.on('data', (data) => {
      console.log('Received in worker:', data.toString());
    });
  });
}

方式2：使用匿名管道替代FIFO #

如果需要进程间的管道通信，优先使用Node.js原生支持的匿名管道，它可以作为可传递的句柄：

const cluster = require('cluster');
const { Pipe } = require('net');

if(cluster.isPrimary) {
  const worker = cluster.fork();
  // 创建匿名管道
  const pipe = new Pipe();
  pipe.on('data', (data) => {
    console.log('Primary received:', data.toString());
  });
  // 发送管道句柄给Worker
  worker.send('send pipe', pipe);
  // 向管道写入数据
  pipe.write('hello from primary');
} else {
  process.on('message', (m, pipe) => {
    if(m === 'send pipe') {
      pipe.on('data', (data) => {
        console.log('Worker received:', data.toString());
      });
      pipe.write('hello from worker');
    }
  });
}

通过send()传递句柄后，原进程的句柄会被自动关闭，子进程会接管该句柄的所有权，但这种机制仅对Node.js官方支持的句柄类型有效，FIFO不在此列，这也是你遇到传递失败警告的核心原因。

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