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

首頁 > 語言 > JavaScript > 正文

Nodejs極簡入門教程(三):進程

2024-05-06 16:10:06
字體:
來源:轉載
供稿:網友
這篇文章主要介紹了Nodejs極簡入門教程(三):進程,本文講解了Node 進程間通信、cluster 模塊等內容,需要的朋友可以參考下
 
 

Node 雖然自身存在多個線程,但是運行在 v8 上的 JavaScript 是單線程的。Node 的 child_process 模塊用于創建子進程,我們可以通過子進程充分利用 CPU。范例:

 

復制代碼代碼如下:

var fork = require('child_process').fork;
// 獲取當前機器的 CPU 數量
var cpus = require('os').cpus();
for (var i = 0; i < cpus.length; i++) {
    // 生成新進程
    fork('./worker.js');
}

 

這里了解一下包括 fork 在內的幾個進程創建方法:

1.spawn(command, [args], [options]),啟動一個新進程來執行命令 command,args 為命令行參數
2.exec(command, [options], callback),啟動一個新進程來執行命令 command,callback 用于在進程結束時獲取標準輸入、標準輸出,以及錯誤信息
3.execFile(file, [args], [options], [callback]),啟動一個新進程來執行可執行文件 file,callback 用于在進程結束時獲取標準輸入、標準輸出,以及錯誤信息
4.fork(modulePath, [args], [options]),啟動一個新進程來執行一個 JavaScript 文件模塊,這時候創建的是 Node 子進程

Node 進程間通信

父進程

 

復制代碼代碼如下:

// parent.js
var fork = require('child_process').fork;
// fork 返回子進程對象 n
var n = fork('./child.js');
// 處理事件 message
n.on('message', function(m) {
    // 收到子進程發送的消息
    console.log('got message: ' + m);
});
 
// 向子進程發送消息
n.send({hello: 'world'});

 

子進程

 

復制代碼代碼如下:

// child.js
// 處理事件 message
process.on('message', function(m) {
    console.log('got message: ' + m);
});
 
// process 存在 send 方法,用于向父進程發送消息
process.send({foo: 'bar'});

 

需要注意的是,這里的 send 方法是同步的,因此不建議用于發送大量的數據(可以使用 pipe 來代替,詳細見:http://nodejs.org/api/all.html#child_process_child_process_spawn_command_args_options)。
特殊的情況,消息中 cmd 屬性值包含 NODE_ 前綴(例如:{cmd: ‘NODE_foo'} 消息),那么此消息不會被提交到 message 事件(而是 internalMessage 事件),它們被 Node 內部使用。

send 方法的原型為:

 

復制代碼代碼如下:

send(message, [sendHandle])

 

這里,sendHandle(handle)可以被用于發送:

1.net.Native,原生的 C++ TCP socket 或者管道
2.net.Server,TCP 服務器
3.net.Socket,TCP socket
4.dgram.Native,原生的 C++ UDP socket
5.dgram.Socket,UDP socket

send 發送 sendHandle 時實際上不是(也不能)直接發送 JavaScript 對象,而是發送文件描述符(最終以 JSON 字符串發送),其他進程能夠通過這個文件描述符還原出對應對象。

現在看一個例子:

父進程

 

復制代碼代碼如下:

// parent.js
var fork = require('child_process').fork;
 
var n = fork('./child.js');
 
var server = require('net').createServer();
server.listen(7000, function() {
    // 發送 TCP server 到子進程
    n.send('server', server);
}).on('connection', function() {
    console.log('connection - parent');
});

 

子進程

 

復制代碼代碼如下:

process.on('message', function(m, h) {
    if (m === 'server') {
        h.on('connection', function() {
            console.log('connection - child');
        });
    }
});

 

通過端口 7000 訪問此程序,得到輸出可能為 connection – parent 也可能得到輸出 connection – child。這里子進程和父進程同時監聽了端口 7000。通常來說,多個進程監聽同一個端口會引起 EADDRINUSE 的異常,而此例的情況是,不同的兩個進程使用了相同的文件描述符,且 Node 底層在監聽端口時對 socket 設置了 SO_REUSEADDR 選項,這使得此 socket 可以在不同的進程間復用。在多個進程監聽同一個端口時,同一時刻文件描述符只能被一個進程使用,這些進程對 socket 的使用是搶占式的。

cluster 模塊

在 Node 的 v0.8 新增了 cluster 模塊,通過 cluster 模塊能夠輕松的在一臺物理機器上構建一組監聽相同端口的進程。范例:

復制代碼代碼如下:

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
 
// 檢查進程是否是 master 進程
if (cluster.isMaster) {
    for (var i = 0; i < numCPUs; ++i)
        // 生成新的 worker 進程(只有 master 進程才可以調用)
        cluster.fork();
 
    cluster.on('exit', function(worker, code, signal) {
        console.log('worker ' + worker.process.pid + ' died');
    });
} else {
    http.createServer(function(req, res) {
        res.writeHead(200);
        res.end('hello world/n');
    }).listen(8000);
}

 

我們在 worker 進程中調用 listen 方法,監聽請求將會傳遞給 master 進程。如果 master 進程已經存在一個正在監聽的 server 符合 worker 進程的要求,那么此 server 的 handle 將會傳遞給 worker,如果不存在,master 進程則會創建一個,然后將 handle 傳遞給 worker 進程。

更多詳細的關于 cluster 的文檔:http://www.nodejs.org/api/cluster.html


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

主站蜘蛛池模板: 福海县| 惠水县| 高碑店市| 陕西省| 铁岭市| 抚远县| 祁门县| 北海市| 泸州市| 观塘区| 广灵县| 德化县| 天门市| 达孜县| 岗巴县| 萨嘎县| 宜春市| 鄂托克前旗| 凉城县| 高台县| 平昌县| 元江| 玉树县| 隆德县| 来安县| 白山市| 广南县| 清丰县| 新蔡县| 大悟县| 洪湖市| 开原市| 财经| 新化县| 卓资县| 宁强县| 清徐县| 武安市| 江山市| 宁波市| 威宁|