在死磕進程一個禮拜后,終于把晦澀難懂文檔看明白了,準備把自己的理解分享給大家,也希望大家能指出一些意見
進程的概念
進程中幾個重要的屬性
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
進程的方法
say() //方法不存在process.on('uncaughtException',function(err){ console.log('捕獲到一個未被處理的錯誤:',err);});
child_process
子進程是今天要講的重點,我也有一些不太明白,希望能和大家多多交流
child_process出現的背景
在Node.js中,只有一個線程執行所有操作,如果某個操作需要大量消耗CPU資源的情況下,后續操作都需要等待。
在Node.js中,提供了一個child_process模塊,通過它可以開啟多個子進程,在多個子進程之間可以共享內存空間,可以通過子進程的互相通信來實現信息的交換。
child_process模塊給予node任意創建子進程的能力,node官方文檔對于child_proces模塊給出了四種方法,映射到操作系統其實都是創建子進程。但對于開發者而已,這幾種方法的api有點不同
child_process.exec(command[, options][, callback]) 啟動
子進程來執行shell命令,可以通過回調參數來獲取腳本shell執行結果
child_process.execfile(file[, args][, options][, callback])
與exec類型不同的是,它執行的不是shell命令而是一個可執行文件
child_process.spawn(command[, args][, options])僅僅執行一個shell命令,不需要獲取執行結果
child_process.fork(modulePath[, args][, options])可以用node
執行的.js文件,也不需要獲取執行結果。fork出來的子進程一定是node進程
spawn
語法:child_process.spawn(command, [args], [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開啟一個子進程
子進程代碼
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)})
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持武林網。
新聞熱點
疑難解答