Node.js 多历程
Node.js 多历程
我们都知道 Node.js 是以单线程的模式运行的,但它利用的是事件驱动来处理惩罚并发,这样有助于我们在多核 cpu 的系统上建设多个子历程,从而提高机能。
每个子历程老是带有三个流工具:child.stdin, child.stdout 和child.stderr。他们大概会共享父历程的 stdio 流,可能也可以是独立的被导流的流工具。
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: 字符串, 将要运行的呼吁,参数利用空格离隔
options :工具,可以是:
/bin/sh
, 在 Windows 中为cmd.exe
, Shell 该当能识别 -c
开关在 UNIX 中,或 /s /c
在 Windows 中。 在Windows 中,呼吁行理会该当能兼容cmd.exe
)callback :回调函数,包括三个参数error, stdout 和 stderr。
exec() 要领返回最大的缓冲区,并期待历程竣事,一次性返回缓冲区的内容。
实例
让我们建设两个 js 文件 support.js 和 master.js。
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 利用指定的呼吁行参数建设新历程,语法名目如下:
child_process.spawn(command[, args][, options])
参数
参数说明如下:
command: 将要运行的呼吁
args: Array 字符串参数数组
options Object
spawn() 要领返回流 (stdout & stderr),在历程返回大量数据时利用。历程一旦开始执行时 spawn() 就开始吸收响应。
实例
让我们建设两个 js 文件 support.js 和 master.js。
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); }); }
#p#分页标题#e#
执行以上代码,输出功效为:
$ node master.js stdout: 历程 0 执行。 子历程已退出,退出码 0 stdout: 历程 1 执行。 子历程已退出,退出码 0 stdout: 历程 2 执行。 子历程已退出,退出码 0
fork 要领
child_process.fork 是 spawn() 要领的非凡形式,用于建设历程,语法名目如下:
child_process.fork(modulePath[, args][, options])
参数
参数说明如下:
modulePath: String,将要在子历程中运行的模块
args: Array 字符串参数数组
options:Object
true
,子历程的stdin
,stdout
和stderr
将会被关联至父历程,不然,它们将会从父历程中担任。(默认为:false
)返回的工具除了拥有ChildProcess实例的所有要领,尚有一个内建的通信信道。
实例
让我们建设两个 js 文件 support.js 和 master.js。
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