浅谈Node.js 子进程与应用场景
背景
由于ons（阿里云 RocketMQ 包）基于 C艹 封装而来，不支持单一进程内实例化多个生产者与消费者，为了解决这一问题，使用了 Node.js 子进程。
在使用的过程中碰到的坑
发布：进程管理关闭主进程后，子进程变为操作系统进程（pid 为 1）
几种解决方案
将子进程看做独立运行的进程，记录 pid，发布时进程管理关闭主进程同时关闭子进程
主进程监听关闭事件，主动关闭从属于自己的子进程
子进程种类
- spawn：执行命令
- exec：执行命令（新建 shell）
- execFile：执行文件
- fork：执行文件
子进程常用事件
- exit
- close
- error
- message
close 与 exit 是有区别的，close 是在数据流关闭时触发的事件，exit 是在子进程退出时触发的事件。因为多个子进程可以共享同一个数据流，所以当某个子进程 exit 时不一定会触发 close 事件，因为这个时候还存在其他子进程在使用数据流。
子进程数据流
- stdin
- stdout
- stderr
因为是以主进程为出发点，所以子进程的数据流与常规理解的数据流方向相反，stdin：写入流，stdout、stderr：读取流。
spawn
spawn(command[, args][, options])
执行一条命令，通过 data 数据流返回各种执行结果。
基础使用
const { spawn } = require('child_process');
const child = spawn('find', [ '.', '-type', 'f' ]);
child.stdout.on('data', (data) => {
console.log(`child stdout:\n${data}`);
});
child.stderr.on('data', (data) => {
console.error(`child stderr:\n${data}`);
});
child.on('exit', (code, signal) => {
console.log(`child process exit with: code $[code], signal: ${signal}`);
});
常用参数
{
cwd: String,
env: Object,
stdio: Array | String,
detached: Boolean,
shell: Boolean,
uid: Number,
gid: Number
}
重点说明下 detached 属性，detached 设置为 true 是为子进程独立运行做准备。子进程的具体行为与操作系统相关，不同系统表现不同，Windows 系统子进程会拥有自己的控制台窗口，POSIX 系统子进程会成为新进程组与会话负责人。
这个时候子进程还没有完全独立，子进程的运行结果会展示在主进程设置的数据流上，并且主进程退出会影响子进程运行。当 stdio 设置为 ignore 并调用 child.unref(); 子进程开始真正独立运行，主进程可独立退出。
exec
exec(command[, options][, callback])
执行一条命令，通过回调参数返回结果，指令未执行完时会缓存部分结果到系统内存。
const { exec } = require('child_process');
exec('find . -type f | wc -l', (err, stdout, stderr) => {
if (err) {
console.error(`exec error: ${err}`);
return;
}
console.log(`Number of files ${stdout}`);
});
两全其美 —— spawn 代替 exec
由于 exec 的结果是一次性返回，在返回前是缓存在内存中的，所以在执行的 shell 命令输出过大时，使用 exec 执行命令的方式就无法按期望完成我们的工作，这个时候可以使用 spawn 代替 exec 执行 shell 命令。
const { spawn } = require('child_process');
const child = spawn('find . -type f | wc -l', {
stdio: 'inherit',
shell: true
});
child.stdout.on('data', (data) => {
console.log(`child stdout:\n${data}`);
});
child.stderr.on('data', (data) => {
console.error(`child stderr:\n${data}`);
});
child.on('exit', (code, signal) => {
console.log(`child process exit with: code $[code], signal: ${signal}`);
});
execFile
child_process.execFile(file[, args][, options][, callback])
执行一个文件
与 exec 功能基本相同，不同之处在于执行给定路径的一个脚本文件，并且是直接创建一个新的进程，而不是创建一个 shell 环境再去运行脚本，相对更轻量级更高效。但是在 Windows 系统中如 .cmd 、 .bat 等文件无法直接运行，这是 execFile 就无法工作，可以使用 spawn、exec 代替。
fork
child_process.fork(modulePath[, args][, options])
执行一个 Node.js 文件
// parent.js
const { fork } = require('child_process');
const child = fork('child.js');
child.on('message', (msg) => {
console.log('Message from child', msg);
});
child.send({ hello: 'world' });
// child.js
process.on('message', (msg) => {
console.log('Message from parent:', msg);
});
let counter = 0;
setInterval(() => {
process.send({ counter: counter++ });
}, 3000);
fork 实际是 spawn 的一种特殊形式，固定 spawn Node.js 进程，并且在主子进程间建立了通信通道，让主子进程可以使用 process 模块基于事件进行通信。
子进程使用场景
- 计算密集型系统
- 前端构建工具利用多核 CPU 并行计算，提升构建效率
- 进程管理工具，如：PM2 中部分功能
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章介绍了node.js读写json文件的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-06-06
这篇文章主要介绍了koa router 多文件引入的方法示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-05-05
很多时候我们需要遍历我们的页面来检查页面是否存在问题，以更好的保证可用性和安全性，下面就来讲讲如何使用puppeteer来实现页面遍历的功能吧2023-06-06
这篇文章主要介绍了轻松创建nodejs服务器（6）：作出响应,我们接着改造服务器,让请求处理程序能够返回一些有意义的信息,需要的朋友可以参考下2014-12-12
Node.js是一个基于Chrome V8引擎的JavaScript运行时。类似于Java中的JRE，.Net中的CLR。本文将详细为大家介绍Node.js中的回调函数及异步与同步，感兴趣的可以了解一下2022-03-03
这篇文章主要介绍了详解nvm管理多版本node踩坑，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-07-07
这篇文章主要介绍了node.js操作mongodb学习小结,本文给出了mongodb创建数据库、插入数据以及连接mongodb数据库并查询数据等代码实例,需要的朋友可以参考下2015-04-04
这篇文章主要介绍了koa-router源码学习小结，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-09-09
有时候需要运行不同的项目,node版本不一致会导致不少问题,特别是最新版本对应的一些插件,由于语法等原因导致不一定兼容低版本,这样运行低版本环境的项目的时候很多坑,这篇文章主要给大家介绍了关于nodejs切换版本使用(不需要卸载重装)的相关资料,需要的朋友可以参考下2022-11-11
npm link可以帮助我们模拟包安装后的状态，它会在系统中做一个快捷方式映射，让本地的包就好像 install 过一样，可以直接使用，这篇文章主要介绍了Npm link的作用与使用示例代码,需要的朋友可以参考下2023-01-01
最新评论