Node.js中child_process實作多重進程-js教程-PHP中文網

Node.js中child_process實作多重進程

高洛峰

發布： 2016-12-26 09:14:54

原創

1356 人瀏覽過

var http = require(&#39;http&#39;);
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(&#39;child_process&#39;);
var n = cp.fork(__dirname + &#39;/sub.js&#39;);
n.on(&#39;message&#39;, function(m) {
  console.log(&#39;PARENT got message:&#39;, m);
});
n.send({ hello: &#39;world&#39; });

登入後複製

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

PARENT got message: { foo: &#39;bar&#39; }
CHILD got message: { hello: &#39;world&#39; }

登入後複製

sub.js的內容如下:

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

登入後複製

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

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

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

var http = require(&#39;http&#39;);
var cp = require(&#39;child_process&#39;);
var server = http.createServer(function(req, res) {
    var child = cp.fork(__dirname + &#39;/fibonacci-calc.js&#39;);//每个请求都单独生成一个新的子进程
    child.on(&#39;message&#39;, function(m) {
        res.end(m.result + &#39;\n&#39;);
    });
    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(&#39;message&#39;, function(m) {
    process.send({result: fib(m.input)});
});

登入後複製

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

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

更多Node.js中child_process實現多進程相關文章請關注PHP中文網！