首頁 >web前端 >js教程 >nodejs中stream和pipe的深度理解

nodejs中stream和pipe的深度理解

巴扎黑
巴扎黑原創
2017-08-15 10:16:141781瀏覽

本篇文章主要介紹了理解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中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn