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

nodejs中stream和pipe的深度理解

巴扎黑
發布: 2017-08-15 10:16:14
原創
1871 人瀏覽過

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

##前言

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

透過nodeschool學習stream

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

簡單stream進行pipe

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


1

2

3

process.stdin.pipe(process.stdout)

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

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

登入後複製

pipe中間進行處理

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


1

2

3

4

5

6

7

8

9

10

11

12

13

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函式庫


#

1

2

3

4

5

6

7

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由於其特性也適合使用流,所以其自帶類似特性


#

1

2

3

4

var http = require('http');

var server = http.createServer(function(req,res){

  req.pipe(res);

})

登入後複製

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

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


1

2

3

var request = require('request');

var r = request.post('http://localhost:8099');

process.stdin.pipe(r).pipe(process.stdout)

登入後複製

分支管道

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

  • 1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    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一樣使用,下邊這個例子實作了使用流的方式進行子程序呼叫
  • 1

    2

    3

    4

    5

    6

    7

    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
最新問題
怎麼實作 JavaScript點與圓的位置關係
來自於 1970-01-01 08:00:00
0
0
0
JavaScript鉤子函數是什麼?
來自於 1970-01-01 08:00:00
0
0
0
c++ 呼叫javascript
來自於 1970-01-01 08:00:00
0
0
0
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板