Node子进程

Nodejs有四种方式创建子进程
  • spawn
  • exec
  • fork
  • execFile
 

spawn

spawn使用示例
const childProcess = require("child_process") var spawn = childProcess.spawn('ipconfig') var spawn = childProcess.spawn('ipconfig', [a]) // 参数 var spawn = childProcess.spawn('ipconfig', [a], {}) // 配置
spawn的第二个参数是一个数组,用于传递子进程命令参数。
第三个参数是一个配置对象,里面比较常用的属性有:
  • cwd: 子进程当前工作目录
  • shell: 是否在shell中执行命令,默认是false
如果启用了 shell 选项,请不要将未经清理的用户输入传递给此函数。任何包含 shell 字符的输入都可用于触发任意命令执行。
spawn函数的返回值有三个流,由这三个流来获取子进程的输入输出和异常
  • stdout
  • stdin
  • stderr
spawn.stdout.pipe(process.stdout) spawn.stderr.pipe(process.stdout) spawn.stdin.pipe(process.stdin) // 也可以使用事件 spawn.stdout.on('data'(data)=>{ console.log(data) })

exec

exec的执行方式和spawn不同
const exec = childProcess.exec("node a.js a",(err,stdout,stderr)=>{ console.log(stdout); }) // 可以接收一个配置对象 const exec = childProcess.exec("node a.js a",{ "cwd": "./" },(err,stdout,stderr)=>{ console.log(stdout); })
区别有
  • 默认开启shell
  • 参数写在code(第一个参数)里,用空格分隔
  • 输入输出流在回调中
切勿将未经清理的用户输入传递给此函数。任何包含 shell 元字符的输入都可用于触发任意命令执行。
exec的回调第一个参数是异常对象,第二个是输出流,第三个是异常流。
exec可以接收一个配置对象,常用的属性有:
  • encoding :默认'utf8’
  • shell: 默认开启
  • cwd: 当前工作目录

execFile

该函数类似于child_process.exec()只是默认情况下它不会生成 shell。相反,指定的可执行文件直接作为新进程生成,使其比child_process.exec()稍微高效一些。
execFile可以执行可执行文件,第一个参数传入要运行的可执行文件的名称或路径。
childProcess.execFile("node ./a.js",{ shell: true },(err,stdout,stderr)=>{ if(err){ console.error(err); return err; } console.log(stdout); })

fork

该方法是child_process.spawn()的特殊情况,专门用于生成新的Node.js进程。与child_process.spawn() 一样,返回一个 ChildProcess对象。返回的子进程将具有一个内置的附加通信通道,该通道允许在父级和子级之间来回传递消息。
请记住,生成的 Node.js子进程独立于父进程,但在两者之间建立的 IPC 通信通道除外。每个进程都有自己的内存,有自己的 V8 实例。由于需要额外的资源分配,因此不建议生成大量子Nodejs进程。
if (process.argv[2] === "child") { setTimeout(() => { console.log(`Hello from ${process.argv[2]}!`); }, 1_000); process.send('hello 123') } else { const { fork } = require("node:child_process"); const controller = new AbortController(); const { signal } = controller; const child = fork(__filename, ["child"], { signal }); child.on("message", (data) => { console.log("收到的消息:" + data); }); // controller.abort(); // 停止子进程 }
fork生成的子进程与父进程之间会建立好一条通信通道,可以通过process.send发送信息,另一方通过监听message事件获取。
 

如何停止子进程

上诉的几种创建子进程的方式的配置对象中都有一个signal 属性,用于接收一个Abort控制器,可以这种方式停止子进程。
const { fork } = require("node:child_process"); const controller = new AbortController(); const { signal } = controller; const child = fork(__filename, ["child"], { signal }); child.on("message", (data) => { console.log("收到的消息:" + data); }); controller.abort(); // 停止子进程