快捷導(dǎo)航

node中Stream流的詳細(xì)介紹

更新時(shí)間：2022年09月28日 08:22:21 作者：別救了這猴子廢了???????

這篇文章主要介紹了node中Stream的詳細(xì)介紹，流是一個(gè)數(shù)據(jù)傳輸手段，是端到端信息交換的一種方式，而且是有順序的,是逐塊讀取數(shù)據(jù)、處理內(nèi)容，用于順序讀取輸入或?qū)懭胼敵?/div>

一、是什么

流（Stream），是一個(gè)數(shù)據(jù)傳輸手段，是端到端信息交換的一種方式，而且是有順序的,是逐塊讀取數(shù)據(jù)、處理內(nèi)容，用于順序讀取輸入或?qū)懭胼敵?/p>

Node.js中很多對(duì)象都實(shí)現(xiàn)了流，總之它是會(huì)冒數(shù)據(jù)（以 Buffer 為單位）

它的獨(dú)特之處在于，它不像傳統(tǒng)的程序那樣一次將一個(gè)文件讀入內(nèi)存，而是逐塊讀取數(shù)據(jù)、處理其內(nèi)容，而不是將其全部保存在內(nèi)存中

流可以分成三部分：

source
dest
pipe

在source和dest之間有一個(gè)連接的管道pipe,它的基本語法是source.pipe(dest)，source和dest就是通過pipe連接，讓數(shù)據(jù)從source流向了dest，如下圖所示：

二、種類

在NodeJS，幾乎所有的地方都使用到了流的概念，分成四個(gè)種類：

可寫流：可寫入數(shù)據(jù)的流。例如 fs.createWriteStream() 可以使用流將數(shù)據(jù)寫入文件
可讀流： 可讀取數(shù)據(jù)的流。例如fs.createReadStream() 可以從文件讀取內(nèi)容
雙工流： 既可讀又可寫的流。例如 net.Socket
轉(zhuǎn)換流： 可以在數(shù)據(jù)寫入和讀取時(shí)修改或轉(zhuǎn)換數(shù)據(jù)的流。例如，在文件壓縮操作中，可以向文件寫入壓縮數(shù)據(jù)，并從文件中讀取解壓數(shù)據(jù)

在NodeJS中HTTP服務(wù)器模塊中，request 是可讀流，response 是可寫流。還有fs 模塊，能同時(shí)處理可讀和可寫文件流

可讀流和可寫流都是單向的，比較容易理解，而另外兩個(gè)是雙向的

雙工流

之前了解過websocket通信，是一個(gè)全雙工通信，發(fā)送方和接受方都是各自獨(dú)立的方法，發(fā)送和接收都沒有任何關(guān)系

如下圖所示：

基本代碼如下：

const { Duplex } = require('stream');

const myDuplex = new Duplex({
  read(size) {
    // ...
  },
  write(chunk, encoding, callback) {
    // ...
  }
});

雙工流

雙工流的演示圖如下所示：

除了上述壓縮包的例子，還比如一個(gè) babel，把es6轉(zhuǎn)換為，我們?cè)谧筮厡懭?nbsp;es6，從右邊讀取 es5

基本代碼如下所示：

const { Transform } = require('stream');

const myTransform = new Transform({
  transform(chunk, encoding, callback) {
    // ...
  }
});

三、應(yīng)用場(chǎng)景

stream的應(yīng)用場(chǎng)景主要就是處理IO操作，而http請(qǐng)求和文件操作都屬于IO操作

試想一下，如果一次IO操作過大，硬件的開銷就過大，而將此次大的IO操作進(jìn)行分段操作，讓數(shù)據(jù)像水管一樣流動(dòng)，直到流動(dòng)完成

常見的場(chǎng)景有：

get請(qǐng)求返回文件給客戶端
文件操作
一些打包工具的底層操作

get請(qǐng)求返回文件給客戶端

使用stream流返回文件，res也是一個(gè)stream對(duì)象，通過pipe管道將文件數(shù)據(jù)返回

const server = http.createServer(function (req, res) {
    const method = req.method; // 獲取請(qǐng)求方法
    if (method === 'GET') { // get 請(qǐng)求
        const fileName = path.resolve(__dirname, 'data.txt');
        let stream = fs.createReadStream(fileName);
        stream.pipe(res); // 將 res 作為 stream 的 dest
    }
});
server.listen(8000);

文件操作

創(chuàng)建一個(gè)可讀數(shù)據(jù)流readStream，一個(gè)可寫數(shù)據(jù)流writeStream，通過pipe管道把數(shù)據(jù)流轉(zhuǎn)過去

const fs = require('fs')
const path = require('path')

// 兩個(gè)文件名
const fileName1 = path.resolve(__dirname, 'data.txt')
const fileName2 = path.resolve(__dirname, 'data-bak.txt')
// 讀取文件的 stream 對(duì)象
const readStream = fs.createReadStream(fileName1)
// 寫入文件的 stream 對(duì)象
const writeStream = fs.createWriteStream(fileName2)
// 通過 pipe執(zhí)行拷貝，數(shù)據(jù)流轉(zhuǎn)
readStream.pipe(writeStream)
// 數(shù)據(jù)讀取完成監(jiān)聽，即拷貝完成
readStream.on('end', function () {
    console.log('拷貝完成')
})