国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > JavaScript > 正文

Node.js中多進程模塊Cluster的介紹與使用

2019-11-19 16:28:30
字體:
來源:轉載
供稿:網友

前言

我們都知道nodejs最大的特點就是單進程、無阻塞運行,并且是異步事件驅動的。Nodejs的這些特性能夠很好的解決一些問題,例如在服務器開發中,并發的請求處理是個大問題,阻塞式的函數會導致資源浪費和時間延遲。通過事件注冊、異步函數,開發人員可以提高資源的利用率,性能也會改善。既然Node.js采用單進程、單線程模式,那么在如今多核硬件流行的環境中,單核性能出色的Nodejs如何利用多核CPU呢?創始人Ryan Dahl建議,運行多個Nodejs進程,利用某些通信機制來協調各項任務。目前,已經有不少第三方的Node.js多進程支持模塊發布,而NodeJS 0.6.x 以上的版本提供了一個cluster模塊 ,允許創建“共享同一個socket”的一組進程,用來分擔負載壓力。

本篇文章就基于該cluster模塊來講述Node.js在多核CPU下的編程。

Cluster模塊介紹

nodejs所提供的cluster模塊目前尚處于試驗階段,在v0.10.7的官方文檔上我們可以看到模塊的發布信息如下:

Stability: 1 - Experimental

關于該模塊的功能,源文檔描述如此“A single instance of Node runs in a single thread. To take advantage of multi-core systems the user will sometimes want to launch a cluster of Node processes to handle the load.” 其意就是:Node的示例以單進程的模式運行,有時為了充分利用多核系統的資源用戶需要運行一組Node進程來分擔負載。

Cluster用法介紹

首先貼出一段該模塊示例應用代碼,接下來進行詳細分析,代碼如下:

var cluster = require('cluster');var http = require('http');var numCPUs = require('os').cpus().length;if (cluster.isMaster) { require('os').cpus().forEach(function(){ cluster.fork(); }); cluster.on('exit', function(worker, code, signal) { console.log('worker ' + worker.process.pid + ' died'); }); cluster.on('listening', function(worker, address) {  console.log("A worker with #"+worker.id+" is now connected to " +  address.address + ":" + address.port);  }); } else { http.createServer(function(req, res) { res.writeHead(200); res.end("hello world/n"); console.log('Worker #' + cluster.worker.id + ' make a response'); }).listen(8000);}

這段代碼很簡單,主線程就是當前運行的js文件,主線程根據你本機系統的核數來創建子進程。所有進程共享一個監聽端口8000,當有請求發起時,主線程會將該請求隨機分配給某個子進程。console.log('Worker #' + cluster.worker.id + ' make a response');這句代碼可以打印出是哪個進程處理該請求。

問題分析

我們前面提到有請求發起時,由系統來決定將該請求交給哪個進程進行處理。這種完全依賴于系統的負載均衡存在著一個重要缺陷:在windows,linux和Solaris上,只要某個子進程的accept queue為空(通常為最后創建的那個子進程),系統就會將多個connetion分配到同一個子進程上,這會造成進程間負載極為不均衡。特別是在使用長連接的時候,單位時間內的new coming connection并不高,子進程的accept queue往往均為空,就會導致connection會不停的分配給同一個進程。所以這種負載均衡完全依賴于accept queue的空閑程度,只有在使用短連接,而且并發非常高的情況下,才能達到負載均衡,但是這個時候系統的load會非常高,系統也會變得不穩定起來。

總結

以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作能帶來一定的幫助,如果有疑問大家可以留言交流,謝謝大家對武林網的支持。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 延川县| 博乐市| 依兰县| 左权县| 大港区| 左云县| 南溪县| 库车县| 大厂| 渭源县| 家居| 湛江市| 三明市| 沾化县| 宁夏| 云浮市| 泰兴市| 蒲江县| 理塘县| 湟中县| 肇州县| 和林格尔县| 南丹县| 黎平县| 峨眉山市| 固始县| 桐城市| 来宾市| 鄂尔多斯市| 金秀| 茌平县| 塔河县| 来凤县| 吉木乃县| 安乡县| 星子县| 五原县| 襄垣县| 涟源市| 鄂托克旗| 万山特区|