Node.js多進(jìn)程

sunny5541 發(fā)布于2019-08-23 10:31 / 1589人閱讀

摘要：多進(jìn)程單線(xiàn)程模式運(yùn)行的，使用事件處理并發(fā)。使用子進(jìn)程的執(zhí)行命令緩存子進(jìn)程的輸出。子進(jìn)程退出進(jìn)程執(zhí)行。子進(jìn)程退出子進(jìn)程退出執(zhí)行異步相當(dāng)魔幻飄忽不定綁定兩個(gè)事件設(shè)置退出事件子進(jìn)程退出進(jìn)程執(zhí)行。

Node.js多進(jìn)程
Node.js單線(xiàn)程模式運(yùn)行的，使用事件處理并發(fā)。

exec()

使用子進(jìn)程的執(zhí)行命令,緩存子進(jìn)程的輸出。并將子進(jìn)程的輸出以回調(diào)函數(shù)參數(shù)的形式進(jìn)行返回

process.argv() 當(dāng)參數(shù)為0時(shí)

是node的文件絕對(duì)地址

當(dāng)參數(shù)為1時(shí)

是該文件的絕對(duì)地址

當(dāng)參數(shù)為2時(shí)

是命令第一個(gè)參數(shù)。

child_process.exec

回調(diào)函數(shù)有三個(gè)選項(xiàng)，error, stdout, stderr
error 為程序執(zhí)行的錯(cuò)誤，正常執(zhí)行會(huì)返回一個(gè)null
stdout 為程序的正常輸出
stderr 為程序錯(cuò)誤輸出

/*master.js*/
const fs = require("fs");
const child_process = require("child_process");
 
for(var i=0; i<3; i++) {
    var count = 0;
    var workerProcess = child_process.exec("node support.js " +i, function (err, std, stderr) {
        if (err) {
            console.log(err.stack);
            console.log("Error code: "+err.code);
            console.log("Signal received: "+err.signal);
        }
        console.log("---------------------");
        console.log(i);
        console.log("stdout: " + std);
        console.log("stderr: " + stderr);
    });
 
    workerProcess.on("exit", function (code) {
        console.log("子進(jìn)程已退出，退出碼 "+code);
        console.log("執(zhí)行順序" + count++);
    });
}

/*support.js*/
/*support.js*/
console.log("進(jìn)程 " + process.argv[2] + " 執(zhí)行。" );

執(zhí)行結(jié)果

PS C:UsersmingmDesktop	est> node master.js
子進(jìn)程已退出，退出碼 0
執(zhí)行順序0
---------------------
3
stdout: 進(jìn)程 0 執(zhí)行。

stderr:
子進(jìn)程已退出，退出碼 0
執(zhí)行順序1
---------------------
3
stdout: 進(jìn)程 1 執(zhí)行。

stderr:
子進(jìn)程已退出，退出碼 0
執(zhí)行順序2
---------------------
3
stdout: 進(jìn)程 2 執(zhí)行。

stderr:
PS C:UsersmingmDesktop	est>

node.js的執(zhí)行為異步執(zhí)行，導(dǎo)致先循環(huán)3次，每次提交。
所以輸出i的值全為3
由于先運(yùn)行子進(jìn)程，子進(jìn)程執(zhí)行完畢以后，觸發(fā)exit事件，
執(zhí)行

        console.log("子進(jìn)程已退出，退出碼 "+code);
        console.log("執(zhí)行順序" + count++);

該兩句。
接著執(zhí)行

        console.log("---------------------");
        console.log(i);
        console.log("stdout: " + std);
        console.log("stderr: " + stderr);

執(zhí)行完畢。
node最大的特點(diǎn)是異步執(zhí)行。

spawn()方法

同樣也是使用指定的命令行，創(chuàng)建新進(jìn)程。

PS C:UsersmingmDesktop	est> node master.js
stdout進(jìn)程 0 執(zhí)行。

stdout進(jìn)程 1 執(zhí)行。

子進(jìn)程退出0
stdout進(jìn)程 2 執(zhí)行。

子進(jìn)程退出0
子進(jìn)程退出0
PS C:UsersmingmDesktop	est> node master.js
stdout進(jìn)程 0 執(zhí)行。

子進(jìn)程退出0
stdout進(jìn)程 1 執(zhí)行。

stdout進(jìn)程 2 執(zhí)行。

子進(jìn)程退出0
子進(jìn)程退出0
PS C:UsersmingmDesktop	est> node master.js
stdout進(jìn)程 0 執(zhí)行。

stdout進(jìn)程 1 執(zhí)行。

子進(jìn)程退出0
stdout進(jìn)程 2 執(zhí)行。

子進(jìn)程退出0
子進(jìn)程退出0
PS C:UsersmingmDesktop	est>

node執(zhí)行異步相當(dāng)魔幻
飄忽不定

/*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]);

    // 綁定兩個(gè)事件
    workerProcess.stdout.on("data", (data) => {
        console.log("stdout" + data);
    });

    workerProcess.stderr.on("data", (data) => {
        console.log("stderr", + data);
    });

    // 設(shè)置退出事件
    workerProcess.on("close", (code) => {
        console.log("子進(jìn)程退出" + code);
    });
};

/*support.js*/
console.log("進(jìn)程 " + process.argv[2] + " 執(zhí)行。" );

和exec()的區(qū)別在于exec()是直接回調(diào)函數(shù)，而spawn()是直接綁定事件

fork()方法

PS C:UsersmingmDesktop	est> node master.js
進(jìn)程 0 執(zhí)行。
進(jìn)程 1 執(zhí)行。
進(jìn)程 2 執(zhí)行。
子進(jìn)程已經(jīng)退出0
子進(jìn)程已經(jīng)退出0
子進(jìn)程已經(jīng)退出0
PS C:UsersmingmDesktop	est>

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", (code) => {
        console.log("子進(jìn)程已經(jīng)退出" + code);
    });
}

還是喜歡fork方法。fork很方便。沒(méi)有那么多的異步讓人頭疼。