一、理論

之前看多進程這一章節(jié)時發(fā)現(xiàn)這塊東西挺多,寫Process模塊的時候也有提到，今天下午午休醒來靜下心來好好的看了一遍，發(fā)現(xiàn)也不是太難理解。

Node.js是單線程的,對于現(xiàn)在普遍是多處理器的機器是一種浪費,怎么能利用起來呢？于是child_process模塊出現(xiàn)了。child_process模塊可以在其他進程上產(chǎn)生、派生，并執(zhí)行工作。

child_process模塊提供了一個ChildProcess的新類，它可以作為從父進程訪問子進程的表示形式。Process模塊也是ChildProcess對象。當你從父模塊訪問process時，它是父ChildProcess對象，當你從子進程訪問Process是，它是ChildProcess對象

了解一個對象無外乎事件、方法、屬性。ChildProcess也是一樣。下面列出一些常用的事件、方法和屬性。

事件:

message:當ChildProcess對象調(diào)用send()方法來發(fā)送數(shù)據(jù)時觸發(fā)。

error:在工作進程中出現(xiàn)錯誤時發(fā)出。該處理程序接收一個錯誤對象作為唯一的參數(shù)。

exit:當工作進程結(jié)束時發(fā)出。該處理程序接收兩個參數(shù),code,signal.

close:當工作進程的所有stdio流都已經(jīng)終止的時候發(fā)出。與exit不同的是，因為多個進程可以共享相同的stdio流。

disconnect:當disconnect()在一個工作進程上被調(diào)用時發(fā)出。

方法:

kill([signal]):導(dǎo)致操作系統(tǒng)發(fā)送一個kill信號給子進程。默認是SIGTERM.

send(message,[sendHandle]):將消息發(fā)送到句柄。消息可是字符串或?qū)ο蟆endhandle可以把TCP Server或socket對象發(fā)送到客戶端。這允許客戶端進程共享相同的端口和地址。

disconnect():關(guān)閉父進程與子進程之間的進程通信(或IPC)通道,并把父進程和子進程的連接標志都設(shè)置為false。

屬性:

stdin:輸入Writable流。

stdout:標準輸出Readable流。

strerr:用于輸出錯誤的標準輸出Readable流。

pid:進程的ID。

connected:一個布爾值。在disconnect()被調(diào)用后，它被設(shè)置為false，當是false時，就不能將消息發(fā)送給子進程。

二、實踐

1.exec()在另一進程執(zhí)行一個系統(tǒng)命令

exec()函數(shù)在一個子shell中執(zhí)行系統(tǒng)命令。幾乎可以執(zhí)行能從控制臺提示符下執(zhí)行的任何東西，如二進制可執(zhí)行文件、shell腳本、Python腳本或批處理文件。

exec(command,[options],callback)函數(shù)返回一個ChildProcess對象

command:字符串，指定在子shell中執(zhí)行的命令。

options:對象，指定執(zhí)行命令時使用的設(shè)置。選項如下：

• cwd:指定子進程執(zhí)行的當前工作目錄
• env:一個對象，指定property:value作為環(huán)境的鍵/值對
• encoding:指定存儲命令的輸出時輸出緩沖區(qū)使用的編碼
• maxBuffer:指定stdout、stderror輸出緩沖區(qū)的大小。默認200*1024.
• timeout:指定父進程在殺掉子進程之前，如果子進程未完成等待的毫秒數(shù)。默認0
• killSignal:指定終止子進程時使用的kill信號。默認SIGTERM。

callback:接收error、stdout、stderr3個參數(shù)。

var childProcess = require('child_process');
var options = {maxBuffer:100*1024, encoding:'utf8', timeout:5000};
var child = childProcess.exec('dir /B', options, 
                              function (error, stdout, stderr) {
  if (error) {
    console.log(error.stack);
    console.log('Error Code: '+error.code);
    console.log('Error Signal: '+error.signal);
  }
  console.log('Results: \n' + stdout);
  if (stderr.length){
    console.log('Errors: ' + stderr);
  }
});
child.on('exit', function (code) {
  console.log('Completed with code: '+code);
});

輸出結(jié)果：

"C:\Program Files (x86)\JetBrains\WebStorm 11.0.3\bin\runnerw.exe" F:\nodejs\node.exe child_process_exec.js
Completed with code: 0
Results: 
chef.js
child_fork.js
child_process_exec.js
child_process_exec_file.js
child_process_spawn.js
cluster_client.js
cluster_server.js
cluster_worker.js
file.txt
process_info.js


Process finished with exit code 0

2.execFile()在另一個進程上執(zhí)行一個可執(zhí)行文件

它與exec()相似,不同的是execFile()沒有使用子shell,執(zhí)行的命令必須是一個二進制可執(zhí)行文件Linux的shell腳本和Windows的批處理文件不能使用ecexFile().

execFile(file,args,options,callback)也是返回一個ChildProcess。

file:字符串，執(zhí)行要執(zhí)行的可執(zhí)行文件的路徑。

args:數(shù)組,指定傳遞給可執(zhí)行文件的命令行參數(shù)。

options:參考exec()的。

callback:參考exec().

var childProcess = require('child_process');
var options = {maxBuffer:100*1024, encoding:'UTF-16', timeout:5000};
var child = childProcess.execFile('ping.exe', ['-n', '1', 'baidu.com'],
                                  options, function (error, stdout, stderr) {
  if (error) {
    console.log(error.stack);
    console.log('Error Code: '+error.code);
    console.log('Error Signal: '+error.signal);
  }
  console.log('Results: \n' + stdout.toString());
  if (stderr.length){
    console.log('Errors: ' + stderr.toString());
  }
});
child.on('exit', function (code) {
  console.log('Child completed with code: '+code);
});

3.spawn()在另一個Node.js實例中產(chǎn)生一個進程

spawn(cmd,[args],[options])函數(shù)產(chǎn)生一個進程，連接它們之間的stdio、stdout、stderr的管道,然后在新的線程中使用spawn()執(zhí)行文件。它和上面兩個的主要區(qū)別是產(chǎn)生的進程中的stdin可以進行配置，并且stdout、stderr都是父進程中的Readable流。這意味著exec()、execFile()必須先執(zhí)行完成，才能讀取緩沖區(qū)輸出，但一旦一個spawn()進程的輸出數(shù)據(jù)已被寫入就可以讀取它(這個可以從它們3個的輸出結(jié)果的順序可以看出,上面兩個都是先執(zhí)行exit事件，而spawn()exit處理是在后面)。

cmd、args和上面兩個的一樣。options也可以設(shè)置cwd、env，還可以設(shè)置detached、stdio。

detached：布爾值，true時使子進程成為新進程組的組長，即使父進程退出，也會繼續(xù)，可以使用child_unref()使得父進程退出之前不等待子進程

stdio:定義子進程stdio配置([stdin,stdout,stderr]).默認[0,1,2].此字符串定義每個輸入輸出流的配置。

var spawn = require('child_process').spawn;
var options = {
    env: {user:'brad'},
    detached:false,
    stdio: ['pipe','pipe','pipe']
};
var child = spawn('netstat', ['-e']);
child.stdout.on('data', function(data) {
  console.log(data.toString());
});
child.stderr.on('data', function(data) {
  console.log(data.toString());
});
child.on('exit', function(code) {
  console.log('Child exited with code', code);
});

4.實現(xiàn)子派生

Node.js提供了另外一種進程產(chǎn)生方式——派生。它主要是執(zhí)行在一個單獨的處理器上運行另外一個V8引擎實例中的Node.js模塊代碼?？梢杂门缮鷣聿⑿羞\行多個服務(wù)。不過這需要時間來運轉(zhuǎn)V8的一個新實例，每個實例需要大約10M的內(nèi)存,所以應(yīng)該把派生的進程設(shè)計為存活期更長的，不需要大量派生的進程。與spawn不同的是，它不能為子進程配置stdio。可以使用ChildProcess對象中的send()機制在父進程與子進程間通信。

fork(modulePath,[args],[options])對象也是返回一個ChildProcess對象。

modulePath：字符串，指定被新的Node.js實例啟動的JavaScript文件路徑。

args:數(shù)組，指定傳遞給node命令的命令行參數(shù)。

options：參數(shù)對象，指定執(zhí)行命令時使用的設(shè)置。

cwd、env上面有。

encoding:指定數(shù)據(jù)寫入輸出流時和穿越send()IPC機制時使用的編碼

execPath:指定用于創(chuàng)建產(chǎn)生Node.js進程的可執(zhí)行文件。

silent:一個布爾值，true時將導(dǎo)致派生的進程中的stdout和stderr不與父進程相關(guān)聯(lián)，默認false。

Child.send()父進程向子進程發(fā)送消息，Process.send()是子進程向父進程發(fā)送消息。

var child_process = require('child_process');
var options = {
    env:{user:'Brad'},
    encoding:'utf8'
};
function makeChild(){
  var child = child_process.fork('chef.js', [], options);
  child.on('message', function(message) {
    console.log('Served: ' + message);
  });
  return child;
}
function sendCommand(child, command){
  console.log("Requesting: " + command);
  child.send({cmd:command});
}
var child1 = makeChild();
var child2 = makeChild();
var child3 = makeChild();
sendCommand(child1, "makeBreakfast");
sendCommand(child2, "makeLunch");
sendCommand(child3, "makeDinner");

process.on('message', function(message, parent) {
  var meal = {};
  switch (message.cmd){
    case 'makeBreakfast':
      meal = ["ham", "eggs", "toast"];
      break;
    case 'makeLunch':
      meal = ["burger", "fries", "shake"];
      break;
    case 'makeDinner':
      meal = ["soup", "salad", "steak"];
      break;
  }
  process.send(meal);
});

輸出結(jié)果：

"C:\Program Files (x86)\JetBrains\WebStorm 11.0.3\bin\runnerw.exe" F:\nodejs\node.exe child_fork.js
Requesting: makeBreakfast
Requesting: makeLunch
Requesting: makeDinner
Served: ham,eggs,toast
Served: burger,fries,shake
Served: soup,salad,steak

上面的代碼是在主進程中創(chuàng)建3個子進程，父進程給子進程發(fā)消息，子進程接收并給父進程發(fā)消息。

到此這篇關(guān)于Node.js進程管理之子進程的文章就介紹到這了。希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論