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);

以上示例提供了一個(gè)斐波納契數(shù)列的計(jì)算服務(wù),由于此計(jì)算相當(dāng)耗時(shí),且是單線程,當(dāng)同時(shí)有多個(gè)請求時(shí)只能處理一個(gè),通過child_process.fork()就可以解決此問題

這里引用一下官網(wǎng)上的一個(gè)示例,通過這個(gè)例子可以很好的理解fork()的功能

復(fù)制代碼代碼如下:

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' });

執(zhí)行上述代碼片段的運(yùn)行結(jié)果:

復(fù)制代碼代碼如下:

PARENT got message: { foo: 'bar' }

CHILD got message: { hello: 'world' }

sub.js的內(nèi)容如下:

復(fù)制代碼代碼如下:

process.on('message', function(m) {

  console.log('CHILD got message:', m);

});

process.send({ foo: 'bar' });

在子進(jìn)程中process對象有send()方法,同時(shí)它在每一次接收到消息時(shí)都會發(fā)布消息對象

有點(diǎn)暈的是:child.send()發(fā)送的消息,是由process.on()方法接收的,process.send()方法發(fā)送的消息是由child.on()方法接收的

參照這個(gè)例子我們就可以把第一個(gè)提供斐波納契數(shù)據(jù)的服務(wù)進(jìn)行改進(jìn),使每一個(gè)請求都有單獨(dú)的一個(gè)新的進(jìn)程來處理

復(fù)制代碼代碼如下:

var http = require('http');

var cp = require('child_process');

var server = http.createServer(function(req, res) {

    var child = cp.fork(__dirname + '/fibonacci-calc.js');//每個(gè)請求都單獨(dú)生成一個(gè)新的子進(jìn)程

    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

復(fù)制代碼代碼如下:

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)});

});

啟動服務(wù)后,訪問http://localhost:8080/9就可以計(jì)算出9的斐波納契數(shù)列的值

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

您可能感興趣的文章: