Node.js中child_process實作多進程_node.js

複製程式碼 程式碼如下:

var http = require('http');
function fib (n) {
    if (n         return 1;
    } else {
        return fib(n - 2) fib(n - 1);
    }
}
var server = http.createServer(function (req, res) {
    var num = parseInt(req.url.substring(1), 10);
    res.writeHead(200);
    res.end(fib(num) "n");
});
server.listen(8000);

以上範例提供了一個斐波納契數列的計算服務,由於此計算相當耗時,且是單線程,當同時有多個請求時只能處理一個,通過child_process.fork()就可以解決此問題

這裡引用官網上的一個例子,透過這個例子可以很好的理解fork()的功能

複製程式碼 程式碼如下:

var cp = require('child_process');
var n = cp.fork(__dirname '/sub.js');
n.on('message', function(m) {
  console.log('PARENT got message:', m);
});
n.send({ hello: 'world' });

執行上述程式碼片段的運行結果:

複製程式碼 程式碼如下:

PARENT got message: { foo: 'bar' }
CHILD got message: { hello: 'world' }

sub.js的內容如下:

複製程式碼 程式碼如下:

process.on('message', function(m) {
  console.log('CHILD got message:', m);
});
process.send({ foo: 'bar' });

在子進程中process物件有send()方法,同時它在每一次接收到訊息時都會發布訊息物件

有點暈的是:child.send()發送的訊息,是由process.on()方法接收的,process.send()方法發送的訊息是由child.on()方法接收的

參考這個例子我們就可以把第一個提供斐波納契資料的服務進行改進,使每一個請求都有單獨的一個新的進程來處理

複製程式碼 程式碼如下:

var http = require('http');
var cp = require('child_process');
var server = http.createServer(function(req, res) {
    var child = cp.fork(__dirname '/fibonacci-calc.js');//每個請求單獨產生一個新的子程序
    child.on('message', function(m) {
        res.end(m.result 'n');
    });
    var input = parseInt(req.url.substring(1));
    child.send({input : input});
});
server.listen(8000);

fibonacci-calc.js

複製程式碼 程式碼如下:

function fib(n) {
    if (n         return 1;
    } else {
        return fib(n - 2) fib(n - 1);
    }
}
process.on('message', function(m) {
    process.send({result: fib(m.input)});
});

啟動服務後,訪問http://localhost:8080/9就可以計算出9的斐波納契數列的值

以上就是本文的全部內容了，希望大家能夠喜歡。