摘要：在行中，我們將子進程的連接到當前進程的。等待子進程通過退出函數如下所示。子進程的實現以下代碼用異步寫入以命令運行的子進程的我們為命令生成一個名為的獨立進程。而是子進程完成。沒有這個，將會在調用之前被輸出。

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

本文首發微信公眾號：jingchengyideng
歡迎關注，每天都給你推送新鮮的前端技術文章

在本中，我們在 Node.js 中把 shell 命令作為子進程運行。然后異步讀取這些進程的 stdout 并寫入其 stdin。

首先從在子進程中運行 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()，它可以使我們在命令運行時訪問命令的 stdin，stdout 和 stderr。

在 A 行中，我們將子進程的 stdin 連接到當前進程的 stdin。

B 行等待該過程完成。

函數 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);
    });
  });
}

以下代碼用 @rauschma/stringio 異步寫入以 shell 命令運行的子進程的 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);
}

我們為 shell 命令生成一個名為 sink 的獨立進程。用 writeToWritable 寫入 sink.stdin。它借助 await 異步執行并暫停，以避免緩沖區被消耗太多。
解釋：

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

在B行中不會 await 寫完成。而是 await 子進程 sink 完成。

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

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

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()的工作方式是類似的。

下面的代碼使用異步迭代（C行）來讀取子進程的 stdout 中的內容：

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，希望通過流訪問 stdout 并將 stderr 轉發到process.stderr。

B行：開始 awat 直到 echoReadable() 完成。沒有這個 await，DONE 將會在調用 source.stdout 之前被輸出。

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

從 source 子進程的 stdout 中讀取內容。

將內容寫入 sink 子進程的 stdin。

換句話說，我們正在實現類似 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);
}

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

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

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

12個令人驚嘆的CSS實驗項目

世界頂級公司的前端面試都問些什么

CSS Flexbox 可視化手冊

過節很無聊？還是用 JavaScript 寫一個腦力小游戲吧！

從設計者的角度看 React

CSS粘性定位是怎樣工作的

一步步教你用HTML5 SVG實現動畫效果

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

第三方CSS安全嗎？

談談super(props) 的重要性