var http = require('http');
function fib (n) {
if (n < 2) {
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 < 2) {
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的斐波納契數列的值
以上就是本文的全部內容了，希望大家能夠喜歡。
