目標(biāo)

• 在主進(jìn)程中完成以下事情:

每隔1秒鐘輸出,當(dāng)前請(qǐng)求的數(shù)量

創(chuàng)建等同于CPU數(shù)量的進(jìn)程

對(duì)每個(gè)進(jìn)程施加一個(gè)處理函數(shù),用于統(tǒng)計(jì)請(qǐng)求的數(shù)量

• 在各個(gè)CPU的進(jìn)程中完成以下事情

監(jiān)聽8000端口的請(qǐng)求,并返回最簡單的信息

發(fā)送事件,以觸發(fā)主進(jìn)程中施加的事件處理函數(shù)

---

前置知識(shí)

• process.pid
  在主進(jìn)程cluster.isMaster中, process.id是主進(jìn)程的id
  在工作進(jìn)程(子進(jìn)程)cluster.isWorker中,process.id是工作進(jìn)程(子進(jìn)程)的id

---

• 獲取cpu的數(shù)量

const numCPUs = require('os').cpus().length;

---

• 判斷一個(gè)進(jìn)程是否為主進(jìn)程

const cluster = require('cluster'); if(cluster.isMaster) { ... }

---

• 創(chuàng)建一個(gè)新進(jìn)程

const cluster = require('cluster'); const work = cluster.fork();

---

實(shí)現(xiàn)

const cluster= require('cluster'); const http = require('http');if(cluster.isMaster) {// 主進(jìn)程let count = 0;// 每隔1秒鐘,就輸出當(dāng)前的訪問次數(shù)setInterval(()=>{console.log(`訪問次數(shù)為: ${count}`)}, 1000);let numCPUs = require('os').cpus().length;for(let i =0 ; i < numCPUs ; i++) {cluster.fork(); // 創(chuàng)建等同于cpu核數(shù)的進(jìn)程}for(let id in cluster.workers){cluster.workers[id].on('message', (msg) =>{if(msg.cmd && msg.cmd === 'notifyRequest') {count++;}})} } else {// 子進(jìn)程http.Server((req, res) => {if(req.url !== '/favicon.ico') {res.writeHead(200);res.end('Hi Marron');// 通知執(zhí)行 cmd.notifyRequest 事件process.send({cmd: 'notifyRequest'});}}).listen(8000) }

---

擴(kuò)展

• 由于node.js是單線程.很容易卡死而導(dǎo)致崩潰.如下

const Koa = require('koa'); const app = new Koa(); app.use(async (ctx, next) =>{aaa();await next();ctx.body = 'marron'; }); app.listen(3000);

• 說明會(huì)直接報(bào)錯(cuò)ReferenceError: aaa is not defined,會(huì)直接退出當(dāng)前進(jìn)程.
• 思路: 可以在主進(jìn)程中監(jiān)聽,一旦發(fā)現(xiàn)有進(jìn)程死亡,就開啟新的進(jìn)程.

---

綜上所述,明確在主進(jìn)程中的目標(biāo):

開啟等同于CPU核數(shù)的進(jìn)程,并將進(jìn)程保存在進(jìn)程組(workers)對(duì)象中.

監(jiān)聽進(jìn)程的死亡,一旦發(fā)現(xiàn).就創(chuàng)建新的進(jìn)程,并將新的進(jìn)程替換掛掉的那個(gè)進(jìn)程

子進(jìn)程:

創(chuàng)建一個(gè)http服務(wù)器監(jiān)聽3000端口

當(dāng)訪問該端口時(shí),以一定的幾率報(bào)錯(cuò)(讓當(dāng)天進(jìn)程死亡).

const cluster = require('cluster'); const os = require('os'); const numCPUs = os.cpus().length; const process = require('process');// 保存進(jìn)程組的對(duì)象 const workers = {}; if(cluster.isMaster) {// 主進(jìn)程for(let i = 0; i< numCPUs; i++){const worker = cluster.fork(); // 創(chuàng)建一個(gè)進(jìn)程workers[worker['pid']] = worker; // 保存當(dāng)前進(jìn)程}cluster.on('death', function(worker){// 監(jiān)聽進(jìn)程的死亡nWorker = cluster.fork(); // 新建進(jìn)程workers[worker.pid] = nWorker;}) } else {const Koa = require('koa');const app = new Koa();app.use(async (ctx, next) => {Math.random > 0.95 ? aaa() : ''; // 手動(dòng)掛掉進(jìn)程console.log(`current process ${process.pid}`);await next();ctx.body = 'marron';})app.listen(3000); }

當(dāng)掛的時(shí)候,自動(dòng)重新啟動(dòng)當(dāng)前服務(wù)

總結(jié)

以上是生活随笔為你收集整理的node --- [node接口阅读]cluster的使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。