|
在单核 CPU 体系之上我们回收 单历程 + 单线程 的模式来开拓。在多核 CPU 体系之上，可以通过 child_process.fork 开启多个历程(Node.js 在 v0.8 版本之后新增了Cluster 来实现多历程架构) ，即 多历程 + 单线程 模式。留意：开启多历程不是为了办理高并发，首要是办理了单历程模式下 Node.js CPU 操作率不敷的环境，充实操作多核 CPU 的机能。
Node.js 中的历程
process 模块
Node.js 中的历程 Process 是一个全局工具，无需 require 直接行使，给我们提供了当前历程中的相干信息。官方文档提供了具体的声名，感乐趣的可以亲身实践下 Process 文档。
- process.env：情形变量，譬喻通过 process.env.NODE_ENV 获取差异情形项目设置信息
- process.nextTick：这个在谈及 Event Loop 时常常为会提到
- process.pid：获取当前历程id
- process.ppid：当前历程对应的父历程
- process.cwd()：获取当前历程事变目次，
- process.platform：获取当前历程运行的操纵体系平台
- process.uptime()：当前历程已运行时刻，譬喻：pm2 保卫历程的 uptime 值
- 历程变乱：process.on(‘uncaughtException’, cb) 捕捉非常信息、process.on(‘exit’, cb)历程推出监听
- 三个尺度流：process.stdout 尺度输出、process.stdin 尺度输入、process.stderr 尺度错误输出
- process.title 指定历程名称，有的时辰必要给历程指定一个名称
以上仅罗列了部门常用到成果点，除了 Process 之外 Node.js 还提供了 child_process 模块用来对子历程举办操纵，在下文 Nodejs历程建设会继承报告。
Node.js 历程建设
历程建设有多种方法，本篇文章以child_process模块和cluster模块举办讲授。
child_process模块
child_process 是 Node.js 的内置模块，官网地点：
- child_process 官网地点：http://nodejs.cn/api/child_pr...
几个常用函数：
四种方法
- child_process.spawn()：合用于返回大量数据，譬喻图像处理赏罚，二进制数据处理赏罚。
- child_process.exec()：合用于小量数据，maxBuffer 默认值为 200 * 1024 超出这个默认值将会导致措施瓦解，数据量过大可回收 spawn。
- child_process.execFile()：相同 child_process.exec()，区别是不能通过 shell 来执行，不支持像 I/O 重定向和文件查找这样的举动
- child_process.fork()： 衍生新的历程，历程之间是彼此独立的，每个历程都有本身的 V8 实例、内存，体系资源是有限的，不提议衍生太多的子历程出来，通长按照体系 CPU 焦点数配置。
CPU 焦点数这里出格声名下，fork 确实可以开启多个历程，可是并不提议衍生出来太多的历程，cpu焦点数的获取方法const cpus = require('os').cpus();,这里 cpus 返回一个工具数组，包括所安装的每个 CPU/内核的信息，二者总和的数组哦。假设主机装有两个cpu，每个cpu有4个核，那么总核数就是8。
fork开启子历程 Demo
fork开启子历程办理文章早先的计较耗时造成线程阻塞。
在举办 compute 计较时建设子历程，子历程计较完成通过 send 要领将功效发送给主历程，主历程通过 message 监听到信息后处理赏罚并退出。
- fork_app.js
- const http = require('http');
- const fork = require('child_process').fork;
-
- const server = http.createServer((req, res) => {
- if(req.url == '/compute'){
- const compute = fork('./fork_compute.js');
- compute.send('开启一个新的子历程');
-
- // 当一个子历程行使 process.send() 发送动静时会触发 'message' 变乱
- compute.on('message', sum => {
- res.end(`Sum is ${sum}`);
- compute.kill();
- });
-
- // 子历程监听到一些错误动静退出
- compute.on('close', (code, signal) => {
- console.log(`收到close变乱，子历程收到信号 ${signal} 而终止，退出码 ${code}`);
- compute.kill();
- })
- }else{
- res.end(`ok`);
- }
- });
- server.listen(3000, 127.0.0.1, () => {
- console.log(`server started at http://${127.0.0.1}:${3000}`);
- });
- fork_compute.js
（编辑：湖南网）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!
|
