JavaScript
发布时间:2022-04-16 发布网站:大佬教程 code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Node.js中child_process实现多进程,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
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.ur
l.sub
String
(1),10
);
re
s.writeHead(200
);
re
s.end(fib(num) + "\n"
);
}
);
server.listen(8000
);
以上示例提供了一个斐波纳契数列的计算服务,由于此计算相当耗时,且是单线程,当同时有多个请求时只能处理一个,通过child_process.fork()就可以解决此问题
这里引用一下官网上的一个示例,通过这个例子可以很好的理解fork()的功能
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' }
);
执行上述代码片段的运行结果:
message:
{ foo: 'bar' }
CHILD got
message:
{ Hello: 'world' }
sub.js的内容如下:
s.on('
message',function(m)
{
console.log('CHILD got
message:',m
);
}
);
proces
s.send(
{ foo: 'bar' }
);
在子进程中process对象有send()方法,同时它在每一次接收到消息时都会发布消息对象
有点晕的是:child.send()发送的消息,是由process.on()方法接收的,process.send()方法发送的消息是由child.on()方法接收的
参照这个例子我们就可以把第一个提供斐波纳契数据的服务进行改进,使每一个请求都有单独的一个新的进程来处理
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)
{
re
s.end(
m.result + '\n'
);
}
);
var input = parseInt(req.ur
l.sub
String
(1));
child.send(
{input : input}
);
}
);
server.listen(8000
);
fibonacci-calc.js
{
if (n < 2)
{
return 1;
} else
{
return fib(n - 2) + fib(n - 1
);
}
}
proces
s.on('
message',function(m)
{
proces
s.send(
{result: fib(
m.input)}
);
}
);
启动服务后,访问http://localhost:8080/9">http://localhost:8080/9就可以计算出9的斐波纳契数列的值
以上就是本文的全部内容了,希望大家能够喜欢。
大佬总结
以上是大佬教程为你收集整理的Node.js中child_process实现多进程全部内容,希望文章能够帮你解决Node.js中child_process实现多进程所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。