Nodejs如何开启多进程，进程如何通讯

最重要的一句话刻在心里&＃xff1a;JS是单线程的

进程&＃xff08;process&＃xff09;和线程&＃xff08;thread&＃xff09;的区别

• 进程&＃xff0c;OS 进行资源分配和调度的最小单位&＃xff0c;有独立内存空间
• 线程&＃xff0c;OS 进行运算调度的最小单位&＃xff0c;共享进程内存空间

为何需要多进程

• 多核 CPU&＃xff0c;更适合处理多进程
• 内存较大&＃xff0c;多个进程才能更好的利用&＃xff08;单进程有内存上限&＃xff09;

总之&＃xff0c;是为了“压榨”机器资源。

Nodejs 开启多进程的方式&＃xff1a;

• webWorker 方式开启多进程&＃xff08;此方法在浏览器中也可以使用&＃xff0c;我的使用例子就是 webview 中&＃xff0c;Custom Dashboard 项目里面&＃xff0c;为了和 desktop 进行通讯&＃xff0c;会使用 webWorker.postMessage() 方法发送数据给 desktop&＃xff0c;使用 window.addEventListener(“message”, () &＃61;> {}) 来接收 desktop 的数据&＃xff09;
• fork
• cluster

使用 child_process.fork 方式

const fork &＃61; require("child_process").fork;


下面 demo 一个创建子进程的例子&＃xff0c;该例子先创建一个 server&＃xff0c;启动服务之后访问 localhost:3000/get-sum &＃xff0c;页面会打印 sum is 4995500 字符串。

// process.js
const http &＃61; require("http");
const fork &＃61; require("child_process").fork;const server &＃61; http.createServer((req, res) &＃61;> {if (req.url &＃61;&＃61;&＃61; "/get-sum") {console.info("主进程 id", process.pid);// 开启子进程const computeProcess &＃61; fork("./compute.js");computeProcess.send("开始计算");// 接收子进程的消息computeProcess.on("message", data &＃61;> {console.info("主进程接收到的信息&＃xff1a;", data);res.end("sum is " &＃43; data);});// 接收意外情况computeProcess.on("close", () &＃61;> {console.info("子进程因报错而退出");res.end("error");})}
});
server.listen(3000, () &＃61;> {console.info("localhost:3000");
});


// compute.js
/*** &＃64;description 子进程&＃xff0c;计算*/function getSum() {let sum &＃61; 0;for (let i &＃61; 0; i< 10000; i &＃43;&＃43;) {sum &＃43;&＃61; i;}return sum;
}// 接收主进程的消息
process.on("message", data &＃61;> {console.info("子进程 id", process.pid);console.info("子进程接收到的信息&＃xff1a;", data);const sum &＃61; getSum();// 发送消息给主进程process.send(sum);});


使用 cluster 方式

运行 node cluster.js&＃xff0c;访问 localhost:3000&＃xff0c;页面会打印出 done。

// cluster.js
const http &＃61; require("http");
// 根据 cpu 的核数来决定开启进程的数量
const cpuCoreLength &＃61; require("os").cpus().length;
const cluster &＃61; require("cluster");// 如果是主进程&＃xff0c;就开启子进程
if (cluster.isMaster) {for (let i &＃61; 0; i < cpuCoreLength; i &＃43;&＃43;) {cluster.fork(); // 开启子进程}cluster.on("exit", worker &＃61;> {console.info("子进程退出");cluster.fork(); // 进程守护&＃xff0c;再次开启子进程});
} else {// 子进程// 多个子进程会共享一个 TCP 连接&＃xff0c;提供一份网络服务const server &＃61; http.createServer((req, res) &＃61;> {res.writeHead(200);res.end("done");});server.listen(3000);
}


但是&＃xff0c;实际工作中&＃xff0c;我们想要进程守护&＃xff0c;会用 pm2 这个包&＃xff0c;开启多个进程。

使用 send 和 on 来进行通讯