node的process以及child_process

在死磕進程一個禮拜後，終於把晦澀難懂文檔看明白了，準備把本身的理解分享給你們，也但願你們能指出一些意見

進程的概念

1. 在Node.js中每一個應用程序都是一個進程類的實例對象。
2. 使用process對象表明應用程序,這是一個全局對象，能夠經過它來獲取Node.jsy應用程序以及運行該程序的用戶、環境等各類信息的屬性、方法和事件。

進程中幾個重要的屬性

1. stdin 標準輸入可讀流
2. stdout 標準輸入可寫流
3. stderr 標準錯誤輸出流
4. argv 終端輸入參數數組
5. env 操做系統環境信息
6. pid 應用程序進程id

stdin以及stdout

process.stdin.on('data', (chunk) => {
  process.stdout.write('進程接收到數據' + chunk)
})
複製代碼

運行結果

argv

console.log(process.env)
複製代碼

env: 在mac終端輸入 export NODE_ENV=develop

console.log(process.env.NODE_ENV) //develop
複製代碼

進程的方法

1. process.memoryUsage() 查看內存使用信息
2. process.nextTick() 當前eventloop執行完畢執行回調函數
3. process.chdir() chdir方法用於修改Node.js應用程序中使用的當前工做目錄
4. process.cwd() 進程當前工做目錄
5. process.kill() 殺死進程
6. process.uncaughtException() 當應用程序拋出一個未被捕獲的異常時觸發進程對象的uncaughtException事件

say() //方法不存在
process.on('uncaughtException',function(err){
  console.log('捕獲到一個未被處理的錯誤:',err);
});
複製代碼

child_process

子進程是今天要講的重點，我也有一些不太明白，但願能和你們多多交流

child_process出現的背景

在Node.js中，只有一個線程執行全部操做，若是某個操做須要大量消耗CPU資源的狀況下，後續操做都須要等待。

在Node.js中，提供了一個child_process模塊,經過它能夠開啓多個子進程，在多個子進程之間能夠共享內存空間，能夠經過子進程的互相通訊來實現信息的交換。

spawn

語法：child_process.spawn(command, [args], [options])

1. command 必須指定的參數，指定須要執行的命令
2. args 數組，存放了全部運行該命令須要的參數
3. options 參數爲一個對象，用於指定開啓子進程時使用的選項

const { spawn } = require('child_process')
const path = require('path')

let child1 = spawn('node', ['test1.js', 'yanyongchao'], {
    stdio: ['pipe', 'pipe', 'pipe'], // 三個元素數組 下面會詳解
    cwd: __dirname, 子進程工做目錄
    env: process.env, 環境變量
    detached: true // 若是爲true，當父進程不存在時也能夠獨立存在
})
複製代碼

其實上面都好理解除了sdtio數組，下面來一塊兒分析stdio

stdio

stdio是一個數組，用來設置標準輸入，標準輸出，錯誤輸出。我的理解

pipe：父進程和子進程之間創建一個管道

主進程代碼

const path = require('path')
const { spawn } = require('child_process')

let p = spawn('node', ['childs_t.js'], {
  cwd: path.join(__dirname, 'childs'),
  stdio: ['pipe', 'pipe', process.stderr]
})

p.stdout.on('data', (data) => {
  console.log(data.toString())
}) 
// 這裏用stdout緣由： 子進程的數據流與常規理解的數據流方向相反，
// stdin：寫入流，stdout、stderr：讀取流。
複製代碼

子進程代碼

process.stdout.write('asd')
複製代碼

若是在stdio中放一個流，process.stdout,process.stdin

主進程代碼

const { spawn } = require('child_process')
const path = require('path')


// 若是放的是一個流，則意味着父進程和子進程共享一個流
const p = spawn('node', ['child_t.js'], {
  cwd: path.join(__dirname, 'childs'),
  stdio: [process.stdin, process.stdout, process.stderr]
})
複製代碼

子進程代碼

process.stdout.write('asd') //控制檯會輸出asd
複製代碼

ipc

主進程代碼

const path = require('path')
const { spawn } = require('child_process')

let p = spawn('node', ['child_t.js'], {
  cwd: path.join(__dirname, 'childs'),
  stdio: ['ipc', 'pipe', 'pipe']
})

p.on('message', (msg) => {
  console.log(msg)
})

p.send('hello chhild_process')
複製代碼

子進程代碼

process.on('message', (msg) => {
  process.send('子進程' + msg)
})
// child.send(message,[sendHandle]);//在父進程中向子進程發送消息
// process.send(message,[sendHandle]);//在子進程中向主進程發送消息
複製代碼

detached模式

const { spawn } = require('child_process')
const fs = require('fs')
const path = require('path')
let out = fs.openSync(path.join(__dirname, 'childs/msg.txt'), 'w', 0o666)

let p = spawn('node', ['test4.js'], {
  detached: true, //保證父進程結束，子進程仍然能夠運行
  stdio: 'ignore',
  cwd: path.join(__dirname, 'childs')
})

p.unref()

p.on('close', function() {
  console.log('子進程關閉')
})

p.on('exit', function() {
  console.log('子進程退出')
})

p.on('error', function(err) {
  console.log('子進程1開啓失敗' + err)
})
複製代碼

fork開啓一個子進程

1. 衍生一個新的 Node.js 進程，並經過創建一個 IPC 通信通道來調用一個指定的模塊，該通道容許父進程與子進程之間相互發送信息
2. fork方法返回一個隱式建立的表明子進程的ChildProcess對象
3. 子進程的輸入/輸出操做執行完畢後，子進程不會自動退出，必須使用process.exit()方法顯式退出

子進程代碼

const { fork } = require('child_process')
const path = require('path')
let child = fork(path.join(__dirname, 'childs/fork1.js'))

child.on('message', (data) => {
  console.log('父進程接收到消息' + data)
})

child.send('hello fork')

child.on('error', (err) => {
  console.error(err)
})
複製代碼

子進程代碼

process.on('message', (m, setHandle) => {
  console.log('子進程接收到消息' + m)
  process.send(m) //sendHandle是一個 net.Socket 或 net.Server 對象
})
複製代碼

exec開啓子進程

// exec同步執行一個shell命令
let { exec } = require('child_process')
let path = require('path')

// 用於使用shell執行命令, 同步方法

let p1 = exec('node exec.js a b c', {cwd: path.join(__dirname, 'childs')}, function(err, stdout, stderr) {
  console.log(stdout)
})
複製代碼

execFile開啓子進程

let { execFile } = require('child_process')
let path = require('path')

let p1 = execFile('node', ['exec.js', 'a', 'b', 'c'], {
  cwd: path.join(__dirname, 'childs')
}, function(err, stdout, stderr) {
  console.log(stdout)
})
複製代碼