亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > JavaScript > 正文

使用cluster 將自己的Node服務器擴展為多線程服務器

2019-11-20 13:56:22
字體:
來源:轉載
供稿:網友

用nodejs的朋友都有了解,node是單線程的,也就是說跑在8核CPU上,只能使用一個核的算力。
單線程一直是node的一個詬病,但隨著0.6版本中引入cluster之后,這個情況則得到了改變,開發人員可以依靠cluster很輕松的將自己的Node服務器擴展為多線程服務器了。

什么是Cluster

cluster是node提供的一個多線程庫,用戶可以使用它來創建多個線程,線程之間共享一個監聽端口,當有外部請求這個端口時,cluster會將請求轉發到隨機線程里。因為每個node線程都會占用幾十兆的內存,所以不能像php那樣對每個請求創建一個線程,一般來說創建的線程數最多都不會超過cpu的核心數量。

復制代碼 代碼如下:

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;

if (cluster.isMaster) {
  // Fork workers.
  for (var i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  cluster.on('exit', function(worker, code, signal) {
    console.log('worker ' + worker.process.pid + ' died');
  });
} else {
  // Workers can share any TCP connection
  // In this case its a HTTP server
  http.createServer(function(req, res) {
    res.writeHead(200);
    res.end("hello world/n");
  }).listen(8000);
}

如以上代碼所示,程序運行時cluster.isMaster會被設置為true,當調用cluster.fork()之后,程序會創建一個線程,并重新運行,這時cluster.isMaster就被設置為false了。我們就主要通過這個變量來判斷當前線程是不是子線程的。

還可以注意到,每個子線程被創建之后,都會監聽8000端口而不會引起沖突,這就是cluster共享端口的功能了。

線程之間的通信

當線程被創建之后,他們彼此之間是沒有共享內存或者數據的。所有的數據交換只能通過worker.send和worker.on('message',handler)在主線程里處理,下面列舉一個廣播系統的實例。

復制代碼 代碼如下:

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;

if (cluster.isMaster) {

  var workers=[];
  //新建worker
  function newWorker(){
    var worker=cluster.fork();

    //監聽信息,如果type為broadcast的話,則確定為廣播
    worker.on('message', function(msg) {
      if(msg.type=='broadcast'){
        var event=msg.event;
        //向所有worker發送此條廣播
        workers.forEach(function(worker){
          worker.send(event);
        })
      }
    });
    return worker;
  }

  for (var i = 0; i < numCPUs; i++) {
    workers.push(newWorker());
  }

    cluster.on('online',function(worker){
        console.log('worker %d is online',worker.id);
    })
} else {
  var worker=cluster.worker;

  //廣播就是發送一個type為broadcast的信息,event就是廣播內容
  worker.broadcast=function(event){
    worker.send({
      type:'broadcast',
      event:event
    });
  }

  //這里用worker.on貌似不能監聽到返回的信息
  process.on('message',function(event){
    console.log('worker: '+worker.id+' recived event from '+event.workerId);
  })

  //發送廣播
  worker.broadcast({
    message:'online',
    workerId:worker.id
  })
}

需要注意的問題

在上面也提到,線程之間是不能共享數據的,所有的數據交換只能通過線程之間的通信來交換。而且所交換的數據都是可序列化的,所以函數,文件描述符和HttpResponse之類的東西都不能傳遞。

如果使用cluster,則需要在程序設計的時候考慮到數據交換的問題,我自己的做法就是將類似session的這些數據都存放在redis里,每個線程都做好存取的工作,所有的數據都不放在node內存里。

最后一點,cluster目前還被Node官方標記為Experimental狀態,api在將來也許會改變。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
亚洲性69xxxbbb| 国产在线观看一区二区三区| 亚洲开心激情网| 国产日韩视频在线观看| 国产成人精品最新| 久久久久国产精品一区| 国产在线精品播放| 懂色aⅴ精品一区二区三区蜜月| 日韩激情av在线播放| 亚洲一区二区三区sesese| 欧美日韩一区二区三区在线免费观看| 国产亚洲精品久久久久久| 大荫蒂欧美视频另类xxxx| 久久久精品一区二区| 久久久久免费视频| 超碰91人人草人人干| 国产一区二区色| 欧美国产日本在线| 欧美亚洲另类在线| 亚洲va码欧洲m码| 韩国v欧美v日本v亚洲| 亚洲精品成人av| 欧美在线视频一二三| 一区二区三区在线播放欧美| 中文字幕一区电影| 国产精品高潮视频| 亚洲第一综合天堂另类专| 亚洲成人av在线播放| 日本在线精品视频| 欧美精品激情视频| 亚洲精品久久久一区二区三区| 日韩av理论片| 国a精品视频大全| 日韩不卡中文字幕| 高潮白浆女日韩av免费看| 精品综合久久久久久97| 久久久精品在线| 欧美有码在线观看视频| 国产精品国产三级国产专播精品人| 国产精品99久久久久久www| 亚洲色图在线观看| 日韩av网站大全| 热久久视久久精品18亚洲精品| 欧美电影在线观看| 亚洲国产精品人久久电影| 欧美日韩国产限制| 欧美国产日韩二区| 国产一区二中文字幕在线看| 国模gogo一区二区大胆私拍| 欧美视频在线观看免费| 欧美最顶级的aⅴ艳星| 精品视频久久久久久久| 91久久精品国产91久久性色| 亚洲免费视频在线观看| 亚洲电影在线看| 国产日韩欧美视频| 国产精品99蜜臀久久不卡二区| 国产偷国产偷亚洲清高网站| 性色av一区二区三区红粉影视| 国产成人精品一区二区在线| 亚洲精品国产综合区久久久久久久| 久久久亚洲网站| 亚洲精选中文字幕| 亚洲精选中文字幕| 日韩av片永久免费网站| 久久中文久久字幕| 亚洲欧美在线免费| 亚洲精品小视频| 国产精品av电影| 久久精品国产亚洲精品2020| 久久久久久久色| 欧美黑人一级爽快片淫片高清| 色综合久久精品亚洲国产| 精品国内产的精品视频在线观看| 久久久久久久久久久成人| 永久免费毛片在线播放不卡| 91精品国产九九九久久久亚洲| 在线丨暗呦小u女国产精品| 欧美性极品xxxx做受| 久久亚洲影音av资源网| 欧美成人高清视频| 成人午夜一级二级三级| 亚洲国产精品va在线| 欧美超级乱淫片喷水| 韩国福利视频一区| 亚洲第一天堂无码专区| 亚洲国产天堂久久国产91| 色噜噜久久综合伊人一本| 亚洲xxxx做受欧美| 久久久久久久久久久免费精品| 91免费国产网站| 成人有码视频在线播放| 欧美电影在线观看| 亚洲色图欧美制服丝袜另类第一页| 欧美日韩精品中文字幕| 一级做a爰片久久毛片美女图片| 成人有码在线视频| 91久久国产精品91久久性色| 国产噜噜噜噜久久久久久久久| 午夜精品久久久久久久99热| 欧美日韩免费一区| 色妞在线综合亚洲欧美| 狠狠躁夜夜躁人人爽天天天天97| 欧美日韩国产限制| 国产精品网红福利| 日韩av在线播放资源| 久久精品小视频| 国产精品免费久久久久久| 国产精品香蕉在线观看| 91精品国产高清自在线看超| 亚洲天堂av女优| 高清欧美电影在线| 欧美一级片免费在线| 亚洲免费视频一区二区| 亚洲国产精品va在线看黑人动漫| 精品一区二区三区四区在线| 国产成人91久久精品| 国产精品久久99久久| 一本色道久久综合狠狠躁篇怎么玩| 日韩在线观看精品| 欧美激情视频一区二区三区不卡| 日韩中文字幕网址| 国产一区二区三区三区在线观看| 国产精品一区二区三区成人| 成人在线播放av| 亚洲精品久久久久中文字幕欢迎你| 97超级碰在线看视频免费在线看| 国产69精品久久久久9999| 久久69精品久久久久久久电影好| 亚洲成人精品久久| 久热精品视频在线观看一区| 欧美老女人在线视频| 欧美日韩福利视频| 在线播放日韩专区| 2020欧美日韩在线视频| 国产在线不卡精品| 亚洲综合中文字幕在线| 日韩欧美aaa| 成人啪啪免费看| 国产精品久久久久久亚洲影视| 国产亚洲美女久久| 成人免费观看网址| 亚洲国产精品久久久| 久久久久久久久久国产| 久久久亚洲国产天美传媒修理工| 九九热精品在线| 国产在线拍揄自揄视频不卡99| 粉嫩av一区二区三区免费野| 欧美日本国产在线| 国产精品mp4| 久久免费视频这里只有精品| 成人av在线天堂| 91精品久久久久久久久久久久久久| 色婷婷综合久久久久| 午夜精品久久久久久久白皮肤| 亚洲国产高潮在线观看| 国产精品av免费在线观看| 欧美日韩一区二区三区| 91精品国产高清自在线看超| 欧美日韩中文在线观看| 亚洲一区二区三区成人在线视频精品| 国产一区二区三区在线播放免费观看| 午夜精品三级视频福利| 亚洲成年网站在线观看|