Node.js 是以單線程的模式運行的,但它使用的是事件驅動來處理并發,這樣有助于在多核 cpu 的系統上創建多個子進程,從而提高性能。 Node 提供了 child_PRocess 模塊來創建子進程.
child_process.exec 使用子進程執行命令,緩存子進程的輸出,并將子進程的輸出以回調函數參數的形式返回。屬于“同步中的異步”,即直到完全讀取到內容,才會從子進程返回數據。
child_process.exec(command[, options], callback)command: 字符串, 將要運行的命令,參數使用空格隔開options :對象,可以是: cwd ,字符串,子進程的當前工作目錄 encoding,字符串,字符編碼(默認:’utf8’) shell ,字符串,將要執行命令的 Shell(默認: 在 UNIX 中為/bin/sh,在 Windows 中為cmd.exe, Shell 應當能識別 -c開關在 UNIX 中,或 /s /c 在 Windows 中。timeout,數字,超時時間(默認: 0) maxBuffer,數字, 在stdout 或 stderr 中允許存在的最大緩沖(二進制),如果超出那么子進程將會被殺死 (默認: 200*1024)killSignal ,字符串,結束信號(默認:’SIGTERM’)uid,數字,設置用戶進程的 ID gid,數字,設置進程組的 IDcallback :回調函數,包含三個參數error, stdout 和 stderr。sub.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++) { //執行node命令,當前子進程目錄為sub.js,用戶進程id為當前的i,用空格隔開 //command與options各參數之間用空格分開,共同拼接成一個字符串 var workerProcess = child_process.exec('node sub.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); });}child_process.spawn 使用指定的命令行參數創建新進程。返回一個stream對象,因此當想要子進程返回大量數據時,例如圖像處理,讀取二進制數據等,最好使用此方法,此方法屬于“異步中的異步”,這意味著從子進程開始執行開始,就開始有數據流從子進程傳輸給node。
child_process.spawn(command[, args][, options])command: 將要運行的命令args: Array 字符串參數數組options Object cwd String 子進程的當前工作目錄 env Object 環境變量鍵值對 stdio Array|String 子進程的 stdio 配置 detached Boolean 這個子進程將會變成進程組的領導 uid Number 設置用戶進程的 ID gid Number 設置進程組的 IDsub.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', ['sub.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); });}spawn() 方法的特殊形式,不同之處就是它創建子進程只需要指定要執行的文件模塊即可,返回的對象除了擁有ChildProcess實例的所有方法,還有一個內建的通信信道。
child_process.fork(modulePath[, args][, options])modulePath: String,將要在子進程中運行的模塊args: Array 字符串參數數組options:Object cwd String 子進程的當前工作目錄 env Object 環境變量鍵值對 execPath String 創建子進程的可執行文件 execArgv Array 子進程的可執行文件的字符串參數數組(默認:process.execArgv) silent Boolean 如果為true,子進程的stdin,stdout和stderr將會被關聯至父進程,否則,它們將會從父進程中繼承。(默認為:false)uid Number 設置用戶進程的 ID gid Number 設置進程組的 IDsub.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("sub.js", [i]); worker_process.on('close', function (code) { console.log('子進程已退出,退出碼 ' + code); });}JXcore 是一個支持多線程的 Node.js 發行版本,基本不需要對現有的代碼做任何改動就可以直接線程安全地以多線程運行。 https://github.com/jxcore/jxcore
新聞熱點
疑難解答