Nodejs极简入门教程(三):进程

 更新时间:2014年10月27日 08:58:57   投稿:junjie  
这篇文章主要介绍了Nodejs极简入门教程(三):进程,本文讲解了Node 进程间通信、cluster 模块等内容,需要的朋友可以参考下

Node 虽然自身存在多个线程,但是运行在 v8 上的 JavaScript 是单线程的。Node 的 child_process 模块用于创建子进程,我们可以通过子进程充分利用 CPU。范例:

复制代码 代码如下:

var fork = require('child_process').fork;
// 获取当前机器的 CPU 数量
var cpus = require('os').cpus();
for (var i = 0; i < cpus.length; i++) {
    // 生成新进程
    fork('./worker.js');
}

这里了解一下包括 fork 在内的几个进程创建方法:

1.spawn(command, [args], [options]),启动一个新进程来执行命令 command,args 为命令行参数
2.exec(command, [options], callback),启动一个新进程来执行命令 command,callback 用于在进程结束时获取标准输入、标准输出,以及错误信息
3.execFile(file, [args], [options], [callback]),启动一个新进程来执行可执行文件 file,callback 用于在进程结束时获取标准输入、标准输出,以及错误信息
4.fork(modulePath, [args], [options]),启动一个新进程来执行一个 JavaScript 文件模块,这时候创建的是 Node 子进程

Node 进程间通信

父进程

复制代码 代码如下:

// parent.js
var fork = require('child_process').fork;
// fork 返回子进程对象 n
var n = fork('./child.js');
// 处理事件 message
n.on('message', function(m) {
    // 收到子进程发送的消息
    console.log('got message: ' + m);
});
 
// 向子进程发送消息
n.send({hello: 'world'});

子进程

复制代码 代码如下:

// child.js
// 处理事件 message
process.on('message', function(m) {
    console.log('got message: ' + m);
});
 
// process 存在 send 方法,用于向父进程发送消息
process.send({foo: 'bar'});

需要注意的是,这里的 send 方法是同步的,因此不建议用于发送大量的数据(可以使用 pipe 来代替,详细见:http://nodejs.org/api/all.html#child_process_child_process_spawn_command_args_options)。
特殊的情况,消息中 cmd 属性值包含 NODE_ 前缀(例如:{cmd: ‘NODE_foo'} 消息),那么此消息不会被提交到 message 事件(而是 internalMessage 事件),它们被 Node 内部使用。

send 方法的原型为:

复制代码 代码如下:

send(message, [sendHandle])

这里,sendHandle(handle)可以被用于发送:

1.net.Native,原生的 C++ TCP socket 或者管道
2.net.Server,TCP 服务器
3.net.Socket,TCP socket
4.dgram.Native,原生的 C++ UDP socket
5.dgram.Socket,UDP socket

send 发送 sendHandle 时实际上不是(也不能)直接发送 JavaScript 对象,而是发送文件描述符(最终以 JSON 字符串发送),其他进程能够通过这个文件描述符还原出对应对象。

现在看一个例子:

父进程

复制代码 代码如下:

// parent.js
var fork = require('child_process').fork;
 
var n = fork('./child.js');
 
var server = require('net').createServer();
server.listen(7000, function() {
    // 发送 TCP server 到子进程
    n.send('server', server);
}).on('connection', function() {
    console.log('connection - parent');
});

子进程

复制代码 代码如下:

process.on('message', function(m, h) {
    if (m === 'server') {
        h.on('connection', function() {
            console.log('connection - child');
        });
    }
});

通过端口 7000 访问此程序,得到输出可能为 connection – parent 也可能得到输出 connection – child。这里子进程和父进程同时监听了端口 7000。通常来说,多个进程监听同一个端口会引起 EADDRINUSE 的异常,而此例的情况是,不同的两个进程使用了相同的文件描述符,且 Node 底层在监听端口时对 socket 设置了 SO_REUSEADDR 选项,这使得此 socket 可以在不同的进程间复用。在多个进程监听同一个端口时,同一时刻文件描述符只能被一个进程使用,这些进程对 socket 的使用是抢占式的。

cluster 模块

在 Node 的 v0.8 新增了 cluster 模块,通过 cluster 模块能够轻松的在一台物理机器上构建一组监听相同端口的进程。范例:

复制代码 代码如下:

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
 
// 检查进程是否是 master 进程
if (cluster.isMaster) {
    for (var i = 0; i < numCPUs; ++i)
        // 生成新的 worker 进程(只有 master 进程才可以调用)
        cluster.fork();
 
    cluster.on('exit', function(worker, code, signal) {
        console.log('worker ' + worker.process.pid + ' died');
    });
} else {
    http.createServer(function(req, res) {
        res.writeHead(200);
        res.end('hello world\n');
    }).listen(8000);
}

我们在 worker 进程中调用 listen 方法,监听请求将会传递给 master 进程。如果 master 进程已经存在一个正在监听的 server 符合 worker 进程的要求,那么此 server 的 handle 将会传递给 worker,如果不存在,master 进程则会创建一个,然后将 handle 传递给 worker 进程。

更多详细的关于 cluster 的文档:http://www.nodejs.org/api/cluster.html

相关文章

  • Windows系统中安装nodejs图文教程

    Windows系统中安装nodejs图文教程

    这篇文章主要介绍了Windows系统中安装nodejs图文教程,本文分解了安装中的各个步骤并给出图文说明,需要的朋友可以参考下
    2015-02-02
  • Node.js用readline模块实现输入输出

    Node.js用readline模块实现输入输出

    在学C++的时候,有cout和cin,Java也有println和Scanner控件,Node.js也有如同C++和Java的标准输入,当然,是用JavaScript实现的,它就是Readline模块。下面这篇文章就给大家详细介绍一下readline模块,来实现Node.js的控制台输入输出。有需要的可以参考借鉴。
    2016-12-12
  • 浅谈node的事件机制

    浅谈node的事件机制

    本篇文章主要介绍了node的事件机制,本文通过实现一个简易的、具有发布/订阅模式的事件机制,以此来理清EventEmitter类的实现思路,有兴趣的可以了解一下
    2017-10-10
  • nodejs实现遍历文件夹并统计文件大小

    nodejs实现遍历文件夹并统计文件大小

    这篇文章主要介绍了nodejs实现遍历文件夹并统计文件大小,下面使用nodejs的遍历文件夹文件内容,并且读取所有的文件,并采取排序往大到小的顺序进行输出,需要的朋友可以参考下
    2015-05-05
  • Node.js查找当前目录下文件夹实例代码

    Node.js查找当前目录下文件夹实例代码

    本篇文章主要介绍了Node.js查找当前目录下文件夹实例代码,具有一定的参考价值,有兴趣的可以了解一下。
    2017-03-03
  • 深入理解Node.js中通用基础设计模式

    深入理解Node.js中通用基础设计模式

    大家在谈到设计模式时最先想到的就是 singletons, observers(观察者) 或 factories(工厂方法)。本文重点给大家介绍Node.JS一些基础模式的实现方法,感兴趣的朋友跟随脚本之家小编一起学习吧
    2017-09-09
  • Node4-5静态资源服务器实战以及优化压缩文件实例内容

    Node4-5静态资源服务器实战以及优化压缩文件实例内容

    这篇文章主要介绍了Node4-5静态资源服务器实战以及优化压缩文件实例内容,有需要的朋友们可以参考学习下。
    2019-08-08
  • 在Node.js中使用TypeScript的方法示例

    在Node.js中使用TypeScript的方法示例

    在前端开发中,随着TypeScript的不断普及,越来越多的开发者使用TypeScript进行开发,然而,在后端开发中,在Node.js中使用 TypeScript还是相对较少见的,这篇文章将介绍如何在Node.js中配置TypeScript ,以及如何使用TypeScript来开发高质量的应用程序
    2023-06-06
  • nodejs实现简单的gulp打包

    nodejs实现简单的gulp打包

    因为之前一直有人给我推荐gulp,说他这里好哪里好的。实际上对我来说够用就行。grunt熟悉以后实际上他的配置也不难,说到效率的话确实是个问题,尤其项目大了以后,目前位置遇到的项目都还可以忍受。不过不管怎么说,需要亲自用过gulp之后才能品评他和grunt之间的优劣。
    2017-12-12
  • vscode执行npm时的一些错误以及处理办法

    vscode执行npm时的一些错误以及处理办法

    在前端开发过程中,npm的使用是少不了的,所以需要知道基本的操作使用,并且了解常见的异常情况处理,下面这篇文章主要给大家介绍了关于vscode执行npm时的一些错误以及处理办法的相关资料,需要的朋友可以参考下
    2022-07-07

最新评论