Node.js 多进程

Node.js 是以单线程的模式运行的,但它使用的是事件驱动来处理并发,因此Node 提供了 child_process 模块来创建子进程,方法有以下三个:

exec -- child_process.exec 使用子进程执行命令,缓存子进程的输出,并将子进程的输出以回调函数参数的形式返回。

spawn -- child_process.spawn 使用指定的命令行参数创建新进程。

fork -- child_process.fork 是 spawn()的特殊形式,用于在子进程中运行的模块,如 fork('./son.js') 相当于 spawn('node', ['./son.js']) 。与spawn方法不同的是,fork会在父进程与子进程之间,建立一个通信管道,用于进程之间的通信。

exec方法

child_process.exec 使用子进程执行命令,缓存子进程的输出,并将子进程的输出以回调函数参数的形式返回。

该方法返回最大的缓冲区,等待进程解释,一次性返回缓冲区的内容。

语法如下:

child_process.exec(command[, options], callback)

参数说明:

command:字符串,将要运行的命令,参数使用空格隔开。

option:可以是如下字段:cwd--字符串,子进程的当前工作目录;env--对象,环境变量键值对;encoding--字符串,字符编码,默认utf8;shell--字符串,将要执行命令的Shell;timeout--数组,超时时间;maxBuffer--数字,在stdout或者stderr中允许存在的最大缓冲,如果超出那么子进程将会被杀死;killSignal--字符串,结束信号;uid--数字,设置用户进程的ID;gid--数字,设置进程组的ID。

callback:回调函数,包含三个参数:error、stdout、stderr。

实例:

创建support.js文件:

console.log("进程 " + process.argv[2] + " 执行。" );

创建master.js文件:

const fs = require('fs');
const child_process = require('child_process'); 
for(var i=0; i<3; i++) {
    var workerProcess = child_process.exec('node support.js '+i, function (error, stdout, stderr) {
        if (error) {
            console.log(error.stack);
            console.log('Error code: '+error.code);
            console.log('Signal received: '+error.signal);
                    }
        console.log('stdout: ' + stdout);
        console.log('stderr: ' + stderr);
      }); 
    workerProcess.on('exit', function (code) {
        console.log('子进程已退出,退出码 '+code);
       });
}

执行结果如下:

$ node master.js 
子进程已退出,退出码 0
stdout: 进程 1 执行。

stderr: 
子进程已退出,退出码 0
stdout: 进程 0 执行。

stderr: 
子进程已退出,退出码 0
stdout: 进程 2 执行。

stderr:

spawn方法

child_process.spawn 使用指定的命令行参数创建新进程。

spawn() 方法返回流 (stdout & stderr),在进程返回大量数据时使用。进程一旦开始执行时 spawn() 就开始接收响应。

语法如下:

child_process.spawn(command[, args][, options])

参数说明:

command:将要运行的命令。

args:数组,字符串参数数组。

option:可以是如下字段:cwd--字符串,子进程的当前工作目录;env--对象,环境变量键值对;stdio--字符串数组,子进程的stdio的配置;detached--布尔,这个子进程将会变成进程组的领导;uid--数字,设置用户进程的ID;gid--数字,设置进程组的ID。

实例:

创建support.js文件:

console.log("进程 " + process.argv[2] + " 执行。" );

创建master.js文件:

const fs = require('fs');
const child_process = require('child_process'); 
for(var i=0; i<3; i++) {
   var workerProcess = child_process.spawn('node', ['support.js', i]); 
   workerProcess.stdout.on('data', function (data) {
      console.log('stdout: ' + data);
   }); 
   workerProcess.stderr.on('data', function (data) {
      console.log('stderr: ' + data);
   }); 
   workerProcess.on('close', function (code) {
      console.log('子进程已退出,退出码 '+code);
   });
}

执行结果如下:

$ node master.js stdout: 进程 0 执行。

子进程已退出,退出码 0
stdout: 进程 1 执行。

子进程已退出,退出码 0
stdout: 进程 2 执行。

子进程已退出,退出码 0

fork方法

child_process.fork 是 spawn() 方法的特殊形式,用于创建进程。

语法如下:

child_process.fork(modulePath[, args][, options])

参数说明:

modulePath:字符串,将要在子进程中运行的模块。

args:数组,字符串参数数组。

option:对象,可以是如下字段:cwd--字符串,子进程的当前工作目录;env--对象,环境变量键值对;execPath--字符串,创建子进程的可执行文件;execArgv--数组,子进程的可执行文件的字符串参数数组;silent--布尔,如果是true,子进程的stdin,stdout,stderr将会被关联到父进程,否则会从父进程中继承;uid--数字,设置用户进程的ID;gid--数字,设置进程组的ID。

实例:

创建support.js文件:

console.log("进程 " + process.argv[2] + " 执行。" );

创建master.js文件:

const fs = require('fs');
const child_process = require('child_process'); 
for(var i=0; i<3; i++) {
   var worker_process = child_process.fork("support.js", [i]);    
 
   worker_process.on('close', function (code) {
      console.log('子进程已退出,退出码 ' + code);
   });
}

执行结果如下:

$ node master.js 
进程 0 执行。
子进程已退出,退出码 0
进程 1 执行。
子进程已退出,退出码 0
进程 2 执行。
子进程已退出,退出码 0


本内容均来自互联网,仅供参考,如有侵权请及时通知本站予以删除。邮箱:wiki#imooc.com (#改成@)

意见反馈 帮助中心 APP下载
官方微信