nodejs中stream和pipe的深度理解

本篇文章主要介紹了理解nodejs的stream和pipe機制的原理和實現，具有一定的參考價值，感興趣的小伙伴們可以參考一下

##前言

前幾天別人請教我關於pipe的問題，我發現我雖然用了nodejs很久，但是由於每次用的不多所以經常迴避stream的使用，導致一直不熟，現在重新學習整理一下相關知識。

透過nodeschool學習stream

nodeschool有一個stream-adventure教學教導stream的使用，很簡單

簡單stream進行pipe

首先，我們可以透過管道將輸入定位到輸出，輸入輸出可以是控制台或檔案流或http請求，例如

process.stdin.pipe(process.stdout)
process.stdin.pipe(fs.createWriteStream(path))
fs.createReadStream(path).pipe(process.stdin)

pipe中間進行處理

如果我們想要在管道中間進行處理，例如想將輸入的字串變成大寫寫到輸出裡，我們可以使用一些可以作為中間處理的框架，例如through2就很方便

var through2 = require('through2');
var stream = through2(write,end)
process.stdin
  .pipe(stream)
  .pipe(process.stdout);

function write(line,_,next){
  this.push(line.toString().toUpperCase())
  next();
})
function end(done){
  done();
})

#stream轉換成普通回調

當我們輸入是流，而輸出是普通函數，我們需要把輸入流轉換成普通的buffer，這時可以試試concat-stream函式庫

#

var concat = require('concat-stream');

var reverseStream=concat(function(text){
  console.log(text.toString().split("").reverse().join(""));
})

process.stdin.pipe(reverseStream)

##http server中的流

類似stdin和fs，http由於其特性也適合使用流，所以其自帶類似特性

#

var http = require('http');
var server = http.createServer(function(req,res){
  req.pipe(res);
})

既作為輸入也作為輸出的流

request框架實作瞭如下功能，將一個串流pipe到request請求中，然後將流的內容髮送給伺服器，然後傳回作為流供其他程式碼使用，實作如下

var request = require('request');
var r = request.post('http://localhost:8099');
process.stdin.pipe(r).pipe(process.stdout)

分支管道

下邊是一個例子，這個例子將輸入管道中html包含loud class的元素放入另一個管道進行大寫操作，然後最後合併成輸出

• var trumpet = require('trumpet');
  var through2 = require('through2');
  var fs = require('fs');
  var tr = trumpet();
  var stream = tr.select('.loud').createStream();
  var upper = through2(function(buf,_,next){
    this.push(buf.toString().toUpperCase());
    next();
  })
  stream.pipe(upper).pipe(stream);
  process.stdin.pipe(tr).pipe(process.stdout);

合併輸入輸出stream範例

• 合併後的輸入輸出可像前文request一樣使用，下邊這個例子實作了使用流的方式進行子程序呼叫

• var spawn = require('child_process').spawn;
  var duplexer2 = require('duplexer2');
  
  module.exports = function(cmd, args){
    var c = spawn(cmd,args)
    return duplexer2(c.stdin,c.stdout)
  }

• 總結
  ##透過上邊的例子，可以知道stream應該還有如何合併等更複雜的應用方式。總之整體上符合以下特性：

• Stream分為readable、writeble
######Stream透過pipe方法控制流向##################################################### #####httpServer和httpClient和file system和process.stdin\out\err通常可以作為stream############Stream可以被on(event)轉換為普通的變量，普通變量可以被write轉換成stream############Stream本身可以被拆分、合併、過濾#########

以上是nodejs中stream和pipe的深度理解的詳細內容。更多資訊請關注PHP中文網其他相關文章！