本篇文章給大家分享的是有關(guān)node中Transform的作用是什么，小編覺得挺實用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

創(chuàng)新互聯(lián)建站長期為上千多家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊從業(yè)經(jīng)驗10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為天橋企業(yè)提供專業(yè)的網(wǎng)站制作、成都做網(wǎng)站，天橋網(wǎng)站改版等技術(shù)服務(wù)。擁有十年豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。

Transform流特性

在開發(fā)中直接接觸Transform流的情況不是很多，往往是使用相對成熟的模塊或者封裝的API來完成流的處理，最為特殊的莫過于through3模塊和gulp流操作。那么，Transform流到底有什么特點(diǎn)呢？

從名稱上說，Transform意為處理，類似于生產(chǎn)流水線上的每一道工序，每道工序針對到來的產(chǎn)品作相應(yīng)的處理；從結(jié)構(gòu)上看，Transform是一個雙工流，通俗的解釋它既可以作為可讀流，也可作為可寫流。但是，node卻對Transform流針對其特性做了更為特殊的定制，使Transform不是單純的Duplex流。

Transform流由于包含了Readable和Writeable特性，因此Transform在實際使用中有著多種方式：它既可以只作為消費(fèi)者消費(fèi)數(shù)據(jù)，也可同時作為生產(chǎn)者和消費(fèi)者完成數(shù)據(jù)中間處理。下面將逐漸深入內(nèi)部闡述Transform的運(yùn)行機(jī)理及使用技巧。

Transform內(nèi)部架構(gòu)

上圖表示一個Transform實例的組成部分：Readable部分緩沖（數(shù)組）、內(nèi)部_read函數(shù)、Writeable部分緩沖（鏈表）、內(nèi)部_write函數(shù)、Transform實例必須實現(xiàn)的內(nèi)部_transform函數(shù)以及系統(tǒng)提供的回調(diào)函數(shù)afterTransform。由于Transform實例同時擁有兩部分緩沖，因此2個緩沖的存儲、消耗的順序也就需要了解，這對于后面使用原生Transform編寫代碼有很大的指導(dǎo)意義。

傳統(tǒng)意義的流（即Readable和Writeable）的實現(xiàn)者都需要實現(xiàn)對應(yīng)的內(nèi)部函數(shù)_read()和_write()，對于Readable實例而言，_read函數(shù)用于準(zhǔn)備從源文件中獲取數(shù)據(jù)并添加到讀緩沖中；對于Writeable實例_write函數(shù)則從寫緩沖鏈表中一次刷入到磁盤中。它們分別對應(yīng)了讀寫流程的首尾步驟，具體可以關(guān)注node中的Stream一文。

而Transform中的_read和_write函數(shù)的實現(xiàn)大有不同，由于需要兼顧流的處理，因此著重分析Transform的內(nèi)部函數(shù)執(zhí)行流程。

示例demo：

readable.pipe(transform);

以上段示例代碼為例，transform作為消費(fèi)者消費(fèi)readable。

Transform的實例transform擁有transormState和readableState屬性，保存了相關(guān)屬性，如tranform狀態(tài)信息、回調(diào)函數(shù)存儲和編碼等。transform作為消費(fèi)者，會在其write函數(shù)中消費(fèi)數(shù)據(jù)，在node中的Stream文中介紹了write函數(shù)的實現(xiàn)細(xì)節(jié)，通過內(nèi)部調(diào)用_write函數(shù)實現(xiàn)數(shù)據(jù)的寫入。而在Transform中_write函數(shù)已經(jīng)重寫：

1.保存transform收到的chunk數(shù)據(jù)、編碼和函數(shù)（執(zhí)行刷新寫緩沖）

2.在一定條件下執(zhí)行_read函數(shù)（當(dāng)狀態(tài)為非轉(zhuǎn)換下，只要讀緩沖大小未超過設(shè)定的大小，則執(zhí)行_read）

如果一切順利，readable的數(shù)據(jù)會順利執(zhí)行transform的**write->_write->_read**，那么原本負(fù)責(zé)填充讀緩沖的_read在Transform中發(fā)生了哪些改變呢？

Transform.prototype._read = function(n) {
 var ts = this._transformState;

 if (ts.writechunk !== null && ts.writecb && !ts.transforming) {
  ts.transforming = true;
  this._transform(ts.writechunk, ts.writeencoding, ts.afterTransform);
 } else {
  // mark that we need a transform, so that any data that comes in
  // will get processed, now that we've asked for it.
  ts.needTransform = true;
 }
};

可見，_read的實現(xiàn)非常簡單，根據(jù)條件選擇執(zhí)行_transform函數(shù)。需要注意的是_read的參數(shù)n并未有使用，因為是否插入數(shù)據(jù)至讀緩沖是由開發(fā)者在_transform中來決定。相信大家對_transform函數(shù)并不陌生，node規(guī)定Transform實例必須提供_transform函數(shù)，而該函數(shù)正是在_read中調(diào)用。

_transform有三個參數(shù)，第一個為待處理的chunk數(shù)據(jù)，第二個為編碼，第三個為回調(diào)函數(shù)。前兩個參數(shù)很好理解，我們可以在_transform中盡情的處理數(shù)據(jù)，最后調(diào)用回調(diào)函數(shù)完成處理。那么，這個回調(diào)函數(shù)究竟是什么？ 它就是Transform架構(gòu)圖中的afterTransform函數(shù)，它有幾個功能：

1.清空各種狀態(tài)信息，如transformState對象的一些屬性，用于下次處理數(shù)據(jù)使用

2.可選的保存處理結(jié)果至讀緩沖區(qū)

3.刷新寫緩沖區(qū)，執(zhí)行下一階段的數(shù)據(jù)流處理

可見，在afterTransform函數(shù)執(zhí)行后，才基本宣告transform第一階段的結(jié)束。為何是第一階段呢？因為transform才完成了作為消費(fèi)者（即Writeable）的作用，如果用戶在_transform中傳入了數(shù)據(jù)到寫緩沖區(qū)，那么此時transform也同時是一個生產(chǎn)者，提供數(shù)據(jù)讓后面的消費(fèi)者消費(fèi)數(shù)據(jù)，這就涉及到了Transform使用上的問題。

Transform的生產(chǎn)消費(fèi)實例

const stream = require('stream')
var c = 0;
const readable = stream.Readable({
 highWaterMark: 2,
 read: function () {
  var data = c < 26 ? String.fromCharCode(c++ + 97) : null;
  console.log('push', data);
  this.push(data);
}
})

const transform = stream.Transform({
 highWaterMark: 2,
 transform: function (buf, enc, next) {
  console.log('transform', buf.toString());
  next(null, buf);
 }
})

readable.pipe(transform);

示例代碼很簡單，創(chuàng)建了一個可讀流，向消費(fèi)者提供a-z的小寫字母；創(chuàng)建了一個轉(zhuǎn)換流，在_transform函數(shù)中針對數(shù)據(jù)并不做處理僅作打點(diǎn)輸出，并向回調(diào)函數(shù)傳遞數(shù)據(jù)至讀緩沖區(qū)。我們的目的是通過transform輸出26個小寫字母，但是當(dāng)前程序執(zhí)行的結(jié)果并不讓人滿意：

執(zhí)行結(jié)果：
push a
push b
transform a
push c
transform b
push d
push e
push f

tranform僅僅處理到字母b,readable也僅僅提供了a-f的數(shù)據(jù)便戛然而止，這是為何？

這一切都?xì)w結(jié)于transform對象。認(rèn)真讀過上文后我們知道，所有的Transform實例同時有兩個緩沖區(qū)，其中寫緩沖區(qū)用來接收生產(chǎn)者的數(shù)據(jù)進(jìn)行轉(zhuǎn)換操作，讀緩沖區(qū)則緩存數(shù)據(jù)給消費(fèi)者使用。而在當(dāng)前的實現(xiàn)中，transform._transform函數(shù)輸出了待處理數(shù)據(jù)，同時執(zhí)行next(null, buf);。該函數(shù)上文已有分析，即afterTransform函數(shù)，第一個參數(shù)為Error實例，第二個則為存入讀緩沖區(qū)的數(shù)據(jù)。在本例中，執(zhí)行完_transform后將處理后的數(shù)據(jù)存入讀緩沖區(qū)，等待后面的消費(fèi)者消費(fèi)讀緩沖區(qū)的數(shù)據(jù)。可是，transform后面沒有消費(fèi)者了，因此transform在處理完字母b存入讀緩沖區(qū)后，讀緩沖區(qū)已經(jīng)滿了（設(shè)定highWaterMark為2，即讀寫緩沖區(qū)的最大值均為2字節(jié)）。當(dāng)字母c、d也執(zhí)行到tranform._write后，由于不滿足執(zhí)行transform._read的條件無法執(zhí)行transform._transform函數(shù)，更無法執(zhí)行afterTransform函數(shù)，導(dǎo)致無法刷新寫緩沖區(qū)的數(shù)據(jù)，造成字母c、d貯存在寫緩沖區(qū)。而字母e、f則由于transform的寫緩沖區(qū)滿（transform.write()返回false），只有存儲在readable的讀緩沖區(qū)中，等待消費(fèi)。這就造成了死循環(huán)，readable和transform所有的緩沖區(qū)都滿了，流也就停止了。

解決這個問題的方法很簡單，有兩種不同方案：

1.transform的讀緩沖區(qū)保持為空

2.增加消費(fèi)者消費(fèi)transform的讀緩沖區(qū)

其實本質(zhì)上都是讓transform的讀緩沖區(qū)得到消耗。

第一種方案：

保證transform的讀緩沖區(qū)為空：

const transform = stream.Transform({
 highWaterMark: 2,
 transform: function (buf, enc, next) {
  console.log('transform', buf.toString())
  next(null, null)
 }
})

只需向next函數(shù)傳入null即可，這樣transform消費(fèi)完數(shù)據(jù)后即宣告數(shù)據(jù)處理結(jié)束，讀緩沖區(qū)始終為空。

第二種方案：

添加消費(fèi)者：

const transform = stream.Transform({
 highWaterMark: 2,
 transform: function (buf, enc, next) {
  console.log('transform', buf.toString())
  next(null, buf)
 }
})

readable.pipe(transform).pipe(process.stdout);

transform實現(xiàn)不變，只是添加了消費(fèi)者process.stdout。這樣也同時保證了transform的讀緩沖區(qū)處于可添加狀態(tài)，也給了afterTransform函數(shù)刷新寫緩沖區(qū)的機(jī)會，開啟新的數(shù)據(jù)處理流程。

through3的實現(xiàn)

through3的重頭戲在于Transform流，使用through3的API可方便的創(chuàng)建一個Transform實例，完成數(shù)據(jù)流的處理。

function through3 (construct) {
 return function (options, transform, flush) {
  if (typeof options == 'function') {
   flush   = transform
   transform = options
   options  = {}
  }

  if (typeof transform != 'function')
   transform = noop

  if (typeof flush != 'function')
   flush = null

  return construct(options, transform, flush)
 }
}

module.exports = through3(function (options, transform, flush) {
 var t2 = new DestroyableTransform(options)

 t2._transform = transform

 if (flush)
  t2._flush = flush

 return t2
})

可見，through3模塊僅僅是封裝了Transform的構(gòu)造函數(shù)，并封裝了更為易用的objectMode模式。之所以建議使用through3創(chuàng)建Transform對象，不僅僅是因為其提供了方便的API，更主要的是為了兼容性。Transform對象是屬于Stream2.0的特性，早先版本的node并沒有實現(xiàn)，而通過through3創(chuàng)建的Transform實例在之前版本的node下仍可正常使用，這是由于through3并未引用node默認(rèn)提供的stream模塊，而是使用社區(qū)中較為流行的“readable-stream”模塊。

以上就是node中Transform的作用是什么，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)站標(biāo)題：node中Transform的作用是什么
網(wǎng)頁網(wǎng)址：http://jinyejixie.com/article40/pocieo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供手機(jī)網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、自適應(yīng)網(wǎng)站、面包屑導(dǎo)航、服務(wù)器托管、云服務(wù)器

廣告

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