在 Node.js 中用子進(jìn)程操作標(biāo)準(zhǔn)輸入/輸出

leeon 發(fā)布于2019-08-23 15:29 / 500人閱讀

摘要：在行中，我們將子進(jìn)程的連接到當(dāng)前進(jìn)程的。等待子進(jìn)程通過(guò)退出函數(shù)如下所示。子進(jìn)程的實(shí)現(xiàn)以下代碼用異步寫入以命令運(yùn)行的子進(jìn)程的我們?yōu)槊钌梢粋€(gè)名為的獨(dú)立進(jìn)程。而是子進(jìn)程完成。沒(méi)有這個(gè)，將會(huì)在調(diào)用之前被輸出。

翻譯：瘋狂的技術(shù)宅
原文：http://2ality.com/2018/05/chi...

本文首發(fā)微信公眾號(hào)：jingchengyideng
歡迎關(guān)注，每天都給你推送新鮮的前端技術(shù)文章

在本中，我們?cè)?Node.js 中把 shell 命令作為子進(jìn)程運(yùn)行。然后異步讀取這些進(jìn)程的 stdout 并寫入其 stdin。

在子進(jìn)程中運(yùn)行 shell 命令

首先從在子進(jìn)程中運(yùn)行 shell 命令開始：

const {onExit} = require("@rauschma/stringio");
const {spawn} = require("child_process");

async function main() {
  const filePath = process.argv[2];
  console.log("INPUT: "+filePath);

  const childProcess = spawn("cat", [filePath],
    {stdio: [process.stdin, process.stdout, process.stderr]}); // (A)

  await onExit(childProcess); // (B)

  console.log("### DONE");
}
main();

解釋：

我們用了 spawn()，它可以使我們?cè)诿钸\(yùn)行時(shí)訪問(wèn)命令的 stdin，stdout 和 stderr。

在 A 行中，我們將子進(jìn)程的 stdin 連接到當(dāng)前進(jìn)程的 stdin。

B 行等待該過(guò)程完成。

等待子進(jìn)程通過(guò) Promise 退出

函數(shù) onExit()如下所示。

function onExit(childProcess: ChildProcess): Promise {
  return new Promise((resolve, reject) => {
    childProcess.once("exit", (code: number, signal: string) => {
      if (code === 0) {
        resolve(undefined);
      } else {
        reject(new Error("Exit with error code: "+code));
      }
    });
    childProcess.once("error", (err: Error) => {
      reject(err);
    });
  });
}

子進(jìn)程的實(shí)現(xiàn)

以下代碼用 @rauschma/stringio 異步寫入以 shell 命令運(yùn)行的子進(jìn)程的 stdin：

const {streamWrite, streamEnd, onExit} = require("@rauschma/stringio");
const {spawn} = require("child_process");

async function main() {
  const sink = spawn("cat", [],
    {stdio: ["pipe", process.stdout, process.stderr]}); // (A)

  writeToWritable(sink.stdin); // (B)
  await onExit(sink);

  console.log("### DONE");
}
main();

async function writeToWritable(writable) {
  await streamWrite(writable, "First line
");
  await streamWrite(writable, "Second line
");
  await streamEnd(writable);
}

我們?yōu)?shell 命令生成一個(gè)名為 sink 的獨(dú)立進(jìn)程。用 writeToWritable 寫入 sink.stdin。它借助 await 異步執(zhí)行并暫停，以避免緩沖區(qū)被消耗太多。
解釋：

在A行中，我們告訴 spawn() 通過(guò) sink.stdin（"pipe"）訪問(wèn) stdin。 stdout 和 stderr 被轉(zhuǎn)發(fā)到 process.stdin 和 process.stderr，如前面所述。

在B行中不會(huì) await 寫完成。而是 await 子進(jìn)程 sink 完成。

接下來(lái)了解 streamWrite() 的工作原理。

寫流操作的 promise

Node.js 寫流的操作通常涉及回調(diào)（參見文檔）。代碼如下。

function streamWrite(
  stream: Writable,
  chunk: string|Buffer|Uint8Array,
  encoding="utf8"): Promise {
    return new Promise((resolve, reject) => {
      const errListener = (err: Error) => {
        stream.removeListener("error", errListener);
        reject(err);
      };
      stream.addListener("error", errListener);
      const callback = () => {
        stream.removeListener("error", errListener);
        resolve(undefined);
      };
      stream.write(chunk, encoding, callback);
    });
}

streamEnd()的工作方式是類似的。

從子進(jìn)程中讀取數(shù)據(jù)

下面的代碼使用異步迭代（C行）來(lái)讀取子進(jìn)程的 stdout 中的內(nèi)容：

const {chunksToLinesAsync, chomp} = require("@rauschma/stringio");
const {spawn} = require("child_process");

async function main() {
  const filePath = process.argv[2];
  console.log("INPUT: "+filePath);

  const source = spawn("cat", [filePath],
    {stdio: ["ignore", "pipe", process.stderr]}); // (A)

  await echoReadable(source.stdout); // (B)

  console.log("### DONE");
}
main();

async function echoReadable(readable) {
  for await (const line of chunksToLinesAsync(readable)) { // (C)
    console.log("LINE: "+chomp(line))
  }
}

解釋：

A行：我們忽略 stdin，希望通過(guò)流訪問(wèn) stdout 并將 stderr 轉(zhuǎn)發(fā)到process.stderr。

B行：開始 awat 直到 echoReadable() 完成。沒(méi)有這個(gè) await，DONE 將會(huì)在調(diào)用 source.stdout 之前被輸出。

在子進(jìn)程之間進(jìn)行管道連接

在下面的例子中，函數(shù)transform() 將會(huì)：

從 source 子進(jìn)程的 stdout 中讀取內(nèi)容。

將內(nèi)容寫入 sink 子進(jìn)程的 stdin。

換句話說(shuō)，我們正在實(shí)現(xiàn)類似 Unix 管道的功能：

cat someFile.txt | transform() | cat

這是代碼：

const {chunksToLinesAsync, streamWrite, streamEnd, onExit}
  = require("@rauschma/stringio");
const {spawn} = require("child_process");

async function main() {
  const filePath = process.argv[2];
  console.log("INPUT: "+filePath);

  const source = spawn("cat", [filePath],
    {stdio: ["ignore", "pipe", process.stderr]});
  const sink = spawn("cat", [],
    {stdio: ["pipe", process.stdout, process.stderr]});

  transform(source.stdout, sink.stdin);
  await onExit(sink);

  console.log("### DONE");
}
main();

async function transform(readable, writable) {
  for await (const line of chunksToLinesAsync(readable)) {
    await streamWrite(writable, "@ "+line);
  }
  await streamEnd(writable);
}

擴(kuò)展閱讀

博客：“通過(guò) Node.js 的異步迭代讀取流”

“探索ES2018和ES2019”中的“異步迭代一章

“探索ES2016和ES2017”中的“異步功能” 一章

歡迎繼續(xù)閱讀本專欄其它高贊文章：

12個(gè)令人驚嘆的CSS實(shí)驗(yàn)項(xiàng)目

世界頂級(jí)公司的前端面試都問(wèn)些什么

CSS Flexbox 可視化手冊(cè)

過(guò)節(jié)很無(wú)聊？還是用 JavaScript 寫一個(gè)腦力小游戲吧！

從設(shè)計(jì)者的角度看 React

CSS粘性定位是怎樣工作的

一步步教你用HTML5 SVG實(shí)現(xiàn)動(dòng)畫效果

程序員30歲前月薪達(dá)不到30K，該何去何從

第三方CSS安全嗎？

談?wù)剆uper(props) 的重要性

本文首發(fā)微信公眾號(hào)：jingchengyideng 歡迎掃描二維碼關(guān)注公眾號(hào)，每天都給你推送新鮮的前端技術(shù)文章

云服務(wù)器 GPU云服務(wù)器在阿里云服務(wù)器上安裝node.js 子進(jìn)程子進(jìn)程數(shù)據(jù) linux關(guān)閉子進(jìn)程

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/102134.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

leeon

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

【Python從入門到精通】五萬(wàn)六千字對(duì)Python基礎(chǔ)知識(shí)做一個(gè)了結(jié)吧?。ǘ耍局档檬詹亍?/a>

閱讀 810·2021-10-14 09:43

Python爬蟲--高性能的異步爬蟲（五）

閱讀 2133·2021-09-30 09:48
蘋果秋季發(fā)布會(huì)官宣 9 月 15 日，全新 iPhone 13/Pro 系列即將到來(lái)

閱讀 3457·2021-09-08 09:45
25k成功入職京東：拿到京東軟件測(cè)試崗位offer經(jīng)驗(yàn)分享

閱讀 1104·2021-09-02 15:41
creanova：creanova介紹，自營(yíng)機(jī)房，芬蘭VPS 10.00 EUR/月，芬蘭服務(wù)器月付

閱讀 1900·2021-08-26 14:15
CloudPowerall：洛杉磯Cera機(jī)房便宜VPS/1核1G/8 G存儲(chǔ)/100Mbps AS

閱讀 787·2021-08-03 14:04
讓一排圖片水平居中對(duì)齊

閱讀 2986·2019-08-30 15:56
帶標(biāo)簽的長(zhǎng)標(biāo)題省略展示的實(shí)現(xiàn)

閱讀 3082·2019-08-30 15:52

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

在 Node.js 中用子進(jìn)程操作標(biāo)準(zhǔn)輸入/輸出

相關(guān)文章

Node.js學(xué)習(xí)之路14——Process進(jìn)程

Node.js學(xué)習(xí)之路08——fs文件系統(tǒng)之stream流的基本介紹

Node.js中spawn與exec的異同比較

**深入理解Node.js 進(jìn)程與線程(8000長(zhǎng)文徹底搞懂)**

Node.js 全局對(duì)象 process

發(fā)表評(píng)論

0條評(píng)論

leeon

男|高級(jí)講師

TA的文章

【Python從入門到精通】五萬(wàn)六千字對(duì)Python基礎(chǔ)知識(shí)做一個(gè)了結(jié)吧?。ǘ耍局档檬詹亍?/a>

Python爬蟲--高性能的異步爬蟲（五）

蘋果秋季發(fā)布會(huì)官宣 9 月 15 日，全新 iPhone 13/Pro 系列即將到來(lái)

25k成功入職京東：拿到京東軟件測(cè)試崗位offer經(jīng)驗(yàn)分享

creanova：creanova介紹，自營(yíng)機(jī)房，芬蘭VPS 10.00 EUR/月，芬蘭服務(wù)器月付

CloudPowerall：洛杉磯Cera機(jī)房便宜VPS/1核1G/8 G存儲(chǔ)/100Mbps AS

讓一排圖片水平居中對(duì)齊

帶標(biāo)簽的長(zhǎng)標(biāo)題省略展示的實(shí)現(xiàn)

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

在 Node.js 中用子進(jìn)程操作標(biāo)準(zhǔn)輸入/輸出

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！