nodejs中怎么利用cluster實現(xiàn)多進程

本篇文章為大家展示了nodejs中怎么利用cluster實現(xiàn)多進程，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

創(chuàng)新互聯(lián)建站是專業(yè)的大慶網(wǎng)站建設(shè)公司，大慶接單;提供網(wǎng)站制作、成都網(wǎng)站制作,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進行大慶網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

cluster

  • node進行多進程的模塊；

屬性和方法

  1. isMaster屬性，返回是不是主進程，boolean值；

  2. isWorker屬性, 返回該進程是不是工作進程；

  3. fork()方法，只能通過主進程調(diào)用，衍生出一個新的worker子進程，返回worker對象；

  4. setupMaster([setting])方法，用于修改fork的默認(rèn)行為，一旦調(diào)用，將會按照cluster.settings進行設(shè)置；

  5. settings屬性；用于配置；

  • 參數(shù)exec:worker文件路徑，

  • args：傳遞給worker的參數(shù)；

  • execArgv: 傳遞給nodejs可執(zhí)行文件的參數(shù)列表；

const cluster = require('cluster');
const cpuNums = require('os').cpus().length;
const http = require('http');

if (cluster.isMaster) {
  console.log(cpuNums);
  for (var i = 0; i < cpuNums; i++) {
    cluster.fork(); // 相當(dāng)于node main.js，重新執(zhí)行自己
    // 和process_child相比，不用重新創(chuàng)建child.js，
  }
  
  cluster.on('fork', worker => {
    console.log(`主進程fork了一個worker，pid為${worker.process.pid}`)
  })
  
  cluster.on('listening', worker => {
    console.log(`主進程fork了一個worker，pid為${worker.process.pid}`)
  })
  
  cluster.on('message', data => {
      console.log('主進程接收到了子進程消息為：'，data)
  })
  
  Object.keys(cluster.workers).forEach(item => {
    cluster.workers[item].on('message', data => {
      console.log(data);
    });
  });
  
  cluster.on('disconnect', (worker) => {
    console.log('有工作進程退出了'，worker.process.pid)
  })

} else {

  http.createServer((req, res) => {
    res.end('hello')
  }).listen(8001, () =>{
      console.log('child server is runing')
  })    
  
  console.log('我是子進程');
  
  process.send('子說：你好');
}
事件

  1. fork事件，當(dāng)新的工作進程被fork時觸發(fā)，可以用來記錄工作進程活動；

  2. listening事件，當(dāng)一個工作進程調(diào)用listen()后觸發(fā)，事件處理器兩個參數(shù)：worker:工作進程對象, address:包含了鏈接屬性

  • 只有http的服務(wù)的listen事件才能觸發(fā)此事件

  1. message事件，監(jiān)聽子進程的消息；當(dāng)cluster主進程接收任何工作進程發(fā)送的消息時觸發(fā)；

  • 比較特殊需要在單獨的worker上監(jiān)聽；

  1. online事件，

  2. disconnect事件，當(dāng)工作進程斷開時調(diào)用；

  3. exit事件，

  4. setup事件，cluster.setupMaster()執(zhí)行后觸發(fā)；

cluster多進程模型

  • 每個worker進程通過使用cluster.fork()函數(shù)，基于IPC(Inter-Process-Communication),實現(xiàn)與master進程間通信；

那通過child_process.fork()直接創(chuàng)建不就可以了，為什么要通過cluster

這種方式只實現(xiàn)了多進程，多進程運行還涉及父子進程通信，子進程管理，以及負載均衡等問題，這些特性cluster已經(jīng)做了處理了；

驚群現(xiàn)象

  • 多個進程間會競爭一個accept連接，產(chǎn)生驚群現(xiàn)象，效率比較低；

  • 由于無法控制一個新的連接由哪個進程來處理，導(dǎo)致worker進程間負載不均衡；

master.js

const net = require('net'); // 是最基礎(chǔ)的網(wǎng)絡(luò)模塊，http的基礎(chǔ)就是網(wǎng)絡(luò)模塊，最底層是socket
const fork = require('child_process').fork; // 驚群
var handle = net._createServerHandle('0.0.0.0', 5000); // net模塊創(chuàng)建一個服務(wù)，綁定到3000端口，返回一個callback
for (var i = 0; i < 4; i++) {
  console.log('fork', i);
  fork('./worket.js').send({}, handle); // 主進程fork子進程，send信息
}

worker.js

const net = require('net');
process.on('message', (m, handle) => { // 子進程接收到master信息
  // master接收客戶端的請求，worker去響應(yīng)
  start(handle);
});

var buf = 'hello nodejs';
var res =
  ['HTTP/1.1 200 OK', 'content-length' + buf.length].join('\r\n') +
  ' \r\n\r\n' +
  buf;

var data = {};

function start(server) {
  // 響應(yīng)邏輯，重點關(guān)注驚群效果，計數(shù)
  server.listen();
  server.onconnection = function(err, hand) {
    var pid = process.pid;
    if (!data[pid]) {
      data[pid] = 0;
    }
    data[pid]++;
    console.log('get a connection on worker,pid = %d', process.pid, data[pid]);
    var socket = net.Socket({
      handle: hand
    });
    socket.readable = socket.writable = true; // 修改socket的讀寫屬性
    socket.end(res);
  };
}
nginx proxy

  • Nginx 是俄羅斯人編寫的十分輕量級的http服務(wù)器，是一個高性能的HTTP和反向代理服務(wù)器，異步非阻塞I/O，而且能夠高并發(fā)；

  • 正向代理：客戶端為代理，服務(wù)端不知道代理是誰；

  • 反向代理：服務(wù)器為代理，客戶端不知道代理是誰；

  • nginx的實際應(yīng)用場景: 比較適合穩(wěn)定的服務(wù)

    • 靜態(tài)資源服務(wù)器：js，css, html

    • 企業(yè)級集群

守護進程：退出命令窗口之后，服務(wù)一直處于運行狀態(tài)；

cluster多進程調(diào)度模型

  • cluster是由master監(jiān)聽請求，在通過round-robin算法分發(fā)給各個worker，避免了驚群現(xiàn)象的發(fā)生；

round-robin 輪詢調(diào)度算法的原理是每一次把來自用戶的請求輪流分配給內(nèi)部中的服務(wù)器；

cluster-model.js

const net = require('net');
const fork = require('child_process').fork; // cluster 簡單版本，cluster就是基于child_process去封裝的；

var workers = [];
for (var i = 0; i < 4; i++) {
  workers.push(fork('./child')); // cluster workers
}
var handle = net._createServerHandle('0.0.0.0', 3001); // master
handle.listen();
handle.onconnection = function(err, handle) {
  var worker = workers.pop();
  worker.send({}, handle);
  workers.unshift(worker); // 通過pop 和 unshift實現(xiàn)一個簡單的輪詢
};

child.js

const net = require('net');
process.on('message', (m, handle) => {
  debugger;
  start(handle);
});

var buf = 'hello cluster';
var res =
  ['HTTP/1.1 200 OK', 'content-length' + buf.length].join('\r\n') +
  '\r\n\r\n' +
  buf;

function start(handle) {
  console.log('get a worker on server,pid = ' + process.pid);
  var socket = net.Socket({
    handle
  });
  socket.readable = socket.writable = true; // 修改socket的讀寫屬性
  socket.end(res);
}
cluster中的優(yōu)雅退出

  1. 關(guān)閉異常worker進程所有的TCP server(將已有的快速斷開，且不再接受新的連接)，斷開和Master的IPC通道，不再接受新的用戶請求；

  2. Master立刻fork一個新的worker進程，保證總的進程數(shù)量不變；

  3. 異常worker等待一段時間，處理完已接受的請求后退出；

    if(cluster.isMaster){
        cluster.fork();
    }else {
        // 出錯之后
        try{
            res.end(dddd);  // 報錯，整個線程掛掉，不能提供服務(wù)，
        }catch(err){
         // 斷開連接，斷開和Master的連接，守護進程其實就是重啟；
            process.disconnect(); // or exit()
        }
    }
進程守護

  • Master進程除了接收新的連接，分發(fā)給各worker處理之外，還像天使一樣默默守護著這些進程，保障應(yīng)用的穩(wěn)定性，一旦某個worker進程退出就fork一個新的子進程頂替上去；

  • 這一切cluster模塊已經(jīng)處理好了，當(dāng)某個worker進程發(fā)生異常退出或者與Master進程失去聯(lián)系(disconnected)時，master進程都會收到相應(yīng)的事件通知；

cluster.on('exit',function(){
    cluster.fork();
})

cluster.on('disconnect',function(){
    cluster.fork();
})
IPC通信

  • IPC通信就是進程間的通信；

  • 雖然每個worker進程是相對獨立的，但是他們之間還是需要通信的；叫進程間通信(IPC)通信；

  • worker和worker之間的通信通過Master轉(zhuǎn)發(fā)：通過worker的pid

const cluster = require('cluster');
if(cluster.isMaster){
    var worker = cluster.fork();
    worker.send('hi, i am master');
    worker.on('message', (msg) =>{
        console.log(`${msg} is from worker ${worker.id}`)   
    })
}else if(cluster.isWorker){
   process.on('message', (msg) =>{
        process.send(msg);
   }) 
}

上述內(nèi)容就是nodejs中怎么利用cluster實現(xiàn)多進程，你們學(xué)到知識或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識儲備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

名稱欄目：nodejs中怎么利用cluster實現(xiàn)多進程
URL鏈接：http://bm7419.com/article10/igdcdo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供面包屑導(dǎo)航、小程序開發(fā)、網(wǎng)站維護、虛擬主機、自適應(yīng)網(wǎng)站、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都網(wǎng)站建設(shè)公司