說說node中的可讀流和可寫流的區(qū)別-創(chuàng)新互聯(lián)

前言

成都創(chuàng)新互聯(lián)公司主要從事網(wǎng)頁設(shè)計、PC網(wǎng)站建設(shè)（電腦版網(wǎng)站建設(shè)）、wap網(wǎng)站建設(shè)（手機版網(wǎng)站建設(shè)）、響應(yīng)式網(wǎng)站設(shè)計、程序開發(fā)、網(wǎng)站優(yōu)化、微網(wǎng)站、微信平臺小程序開發(fā)等，憑借多年來在互聯(lián)網(wǎng)的打拼，我們在互聯(lián)網(wǎng)網(wǎng)站建設(shè)行業(yè)積累了豐富的成都網(wǎng)站設(shè)計、做網(wǎng)站、網(wǎng)站設(shè)計、網(wǎng)絡(luò)營銷經(jīng)驗，集策劃、開發(fā)、設(shè)計、營銷、管理等多方位專業(yè)化運作于一體。

nodejs中大量的api與流有關(guān)，曾經(jīng)看到公司的一些大神的node代碼，實現(xiàn)一個接口只需要pipe一下另一個java接口就可以了。簡單的一行代碼實在讓人困惑。作為小白的自己一臉懵逼卻又不敢問，因為根本不知道從何問起?，F(xiàn)在終于通過學習，也能對流說出個123，希望和大家共同交流。

流簡介

流分為緩沖模式和對象模式，緩沖模式只能處理buffer或字符串，對象模式可以處理js對象。流又分為四種類型：可讀流、可寫流、雙工流和轉(zhuǎn)換流。后兩種其實是對可讀和可寫流的應(yīng)用。所以我想先聊聊可讀流和可寫流。

可讀流

可讀流有兩種模式，并隨時可以轉(zhuǎn)換，我們可以通過監(jiān)聽可讀流的事件來操作它。

兩種模式(引用自node中文網(wǎng)的描述)：

1、流動模式：可讀流自動讀取數(shù)據(jù)，通過EventEmitter接口的事件盡快將數(shù)據(jù)提供給應(yīng)用。

2、暫停模式：必須顯式調(diào)用stream.read()方法來從流中讀取數(shù)據(jù)片段。

暫停模式切換到流動模式的api有：

1、監(jiān)聽“data”事件

2、調(diào)用 stream.resume()方法

3、調(diào)用 stream.pipe()方法將數(shù)據(jù)發(fā)送到可寫流

流動模式切換到暫停模式的api有：

1、如果不存在管道目標，調(diào)用stream.pause()方法

2、如果存在管道目標，調(diào)用 stream.unpipe()并取消'data'事件監(jiān)聽

可讀流事件：'data','readable','error','close','end'

可寫流

可寫流相對較為簡單，我們也可以通過監(jiān)聽它的事件來操作它。

可寫流事件： 'close','drain','error','finish','pipe','unpipe'

舉個栗子

我以一個簡單的例子描述一個流最常見的場景，談?wù)剬@個過程的理解。例子就是:我要讀取一個文件，然后把它的內(nèi)容寫到另一個文件（當然是用“流”的api，而不是用‘fs'模塊的api）。

接下來我解釋一下這張圖：

如上圖，當我們創(chuàng)建了一個可讀流的時候，readable._readableState.flowing屬性默認為null，這時我們有兩種選擇：

1、監(jiān)聽‘readable'事件，這時可讀流會讀取64k（可以在創(chuàng)建可讀流時，通過option參數(shù)中的highWaterMark更改）數(shù)據(jù)到流的緩存區(qū)中，等待你用read方法去讀取并消費數(shù)據(jù)，當你用read方法讀了64k數(shù)據(jù)之后，會再次觸發(fā)readable事件，直到你讀完了源文件的所有數(shù)據(jù)。記住，之所以叫暫停模式是因為如果你不調(diào)用read方法，代碼永遠會停在這里，什么事情也不會發(fā)生了。

2、如果你選擇監(jiān)聽‘data'事件，可讀流會直接讀取64k數(shù)據(jù)并通過‘data'事件的回掉函數(shù)提供給你消費，并且這個過程不會停止，如果源文件中有很多數(shù)據(jù)，會不停的觸發(fā)‘data'事件，直到全部讀取完成。當然，在這個過程中你隨時可以通過stream.pause()方法暫停它。

那么，這兩種模式有什么區(qū)別呢？在我理解，如果你不需要對數(shù)據(jù)進行精確控制，首先選擇流動模式，因為它的效率更高。如果需要對流的過程進行精確控制則可以選擇暫停模式。也就是說暫停模式是流更高級一些的用法。其實官方建議我們盡量不要手動去操作流，如果可以，盡量使用pipe方法。

接下來，不論我們以哪種方式讀到了文件中的數(shù)據(jù)，這時我們都可以創(chuàng)建一個可寫流并調(diào)用可寫流的write方法來消費讀到的數(shù)據(jù)。調(diào)用write方法會向文件中寫入數(shù)據(jù)，但是因為寫入的速度較慢，如果當前寫入還在進行，而你又調(diào)用了write方法，node會將你要寫入的數(shù)據(jù)緩存在一個緩存區(qū)中，等到文件寫入完畢會從緩存區(qū)中取出數(shù)據(jù)，繼續(xù)寫入。

write方法擁有一個布爾類型的返回值，用來表示目前是否還可以繼續(xù)調(diào)用write方法寫入內(nèi)容。如果返回false，我們應(yīng)當停止讀取數(shù)據(jù)以避免消耗過多內(nèi)存。那么什么時候會返false呢？就是當緩存區(qū)的大小大于16k（可以在創(chuàng)建可讀流時，通過option參數(shù)中的highWaterMark更改）時。

緩存區(qū)滿后，文件寫入一直在進行，不一會兒會把緩存區(qū)的內(nèi)容全部寫入，緩存區(qū)處于清空狀態(tài)，這時會觸發(fā)可寫流的‘drain'事件，這時我們可以繼續(xù)向文件寫入數(shù)據(jù)了。注意：如果緩存區(qū)從未滿過，‘drain'事件永遠也不會觸發(fā)。

那么這張圖對應(yīng)到代碼是什么樣的呢：

let fs = require('fs');
//創(chuàng)建可讀可寫流
let rs = fs.createReadStream('./1.txt');
let ws = fs.createWriteStream('./2.txt');
//監(jiān)聽‘data'事件，開啟流動模式
rs.on('data',function (data) {
  //對應(yīng)圖中的可寫流true和false
  let flag = ws.write(data);
  if(!flag){
    //如果可寫流返回false，我們應(yīng)當停止讀取，以避免消耗過多內(nèi)存
    rs.pause();
  }
});

//對應(yīng)圖中的drain事件
ws.on('drain',function () {
  //重新開啟流動模式
  rs.resume();
});

//使用可讀流的暫停模式
function read() {
  let data = rs.read()
  let flag = ws.write(data);
  if(flag){
   read()
  }
}

rs.on('readable',function(){
  read()
})

ws.on('drain',function () {
  read()
});

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

分享題目：說說node中的可讀流和可寫流的區(qū)別-創(chuàng)新互聯(lián)
瀏覽路徑：http://bm7419.com/article4/ipgoe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供用戶體驗、標簽優(yōu)化、電子商務(wù)、網(wǎng)站導航、App設(shè)計、微信小程序

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)