成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

through2原理解析

leap_frog / 3243人閱讀

摘要：的源碼僅僅就多行，本質(zhì)上就是對(duì)于原生的流進(jìn)行的封裝，先來看下。是一個(gè)雙工流，既可讀，也可寫，但是與還是有著一些區(qū)別，的寫和讀可以說是沒有任何的關(guān)聯(lián)，是兩個(gè)緩沖區(qū)和管道互補(bǔ)干擾，而將其輸入和輸出是存在相互關(guān)聯(lián)的，中間做了處理。

寫在前面

through2經(jīng)常被用于處理node的stream，假如使用過gulp的話，對(duì)于這個(gè)包一定不會(huì)陌生，如：

gulp.task("rewrite", () => {
  return gulp.src("./through/enter.txt")
    .pipe(through2.obj(function(chunk, enc, callback) {
      const { contents } = chunk;
      for (var i = 0; i < contents.length; i++) {
        if (contents[i] === 97) {
          contents[i] = 122;
        }
      }

      chunk.contents = contents;
      this.push(chunk);

      callback();
    }))
    .pipe(gulp.dest("./dist"));
});

這里將文件中所有的字符a轉(zhuǎn)換為字符z，在寫gulp插件時(shí)一定會(huì)應(yīng)用到這個(gè)包，下面就來窺探一下這個(gè)使用率非常高的包。

Transform stream

through2的源碼僅僅就100多行，本質(zhì)上就是對(duì)于node原生的transform流進(jìn)行的封裝，先來看下Transform stream。Transform是一個(gè)雙工流，既可讀，也可寫，但是與Duplex還是有著一些區(qū)別，Duplex的寫和讀可以說是沒有任何的關(guān)聯(lián)，是兩個(gè)緩沖區(qū)和管道互補(bǔ)干擾，而Transform將其輸入和輸出是存在相互關(guān)聯(lián)的，中間做了處理。具體差別可以參考下面圖片對(duì)比：

Duplex stream:

Transform stream:

Transform stream的兩個(gè)緩存區(qū)相互關(guān)聯(lián)，對(duì)于每個(gè)緩沖區(qū)來說，highWaterMark為閾值，超過閾值后，將會(huì)停止讀或者寫操作，如：

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

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

readable.pipe(transform);

stream流向?yàn)椋?/p>

由于閾值為2，所以只能push到f，這時(shí)readable的緩存區(qū)已滿，transform的讀緩存區(qū)和寫緩存區(qū)已經(jīng)滿了（由于transform的兩個(gè)緩存區(qū)的閾值為2，所以寫緩存區(qū)在寫入b之后就已經(jīng)滿了，后續(xù)不能繼續(xù)寫入），全部滿之后，自然停止了讀取，最終e,f存在A中，c,d存在B中，a,b存在C中，想要解決很簡(jiǎn)單，在添加一個(gè)流向就可以：

readable.pipe(transform).pipe(process.stdout);
through2源碼

在了解Transform stream之后，through2的源碼非常的簡(jiǎn)單，就是對(duì)于其的一層封裝，暴露出三個(gè)api(through2，through2.obj，through2.ctor)而且三者接收的參數(shù)一致，因?yàn)槎际怯梢粋€(gè)工廠方法創(chuàng)造出的：

function through2 (construct) {
  return function (options, transform, flush) {
    // 做了一些參數(shù)整理
    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)
  }
}

來看一下through2對(duì)于Transform stream的再加工，也就是源碼中的DestroyableTransform，與其名字一樣，就是一個(gè)替我們實(shí)現(xiàn)好了destory方法的Transform stream：

DestroyableTransform.prototype.destroy = function(err) {
  if (this._destroyed) return
  this._destroyed = true

  var self = this
  // 觸發(fā)destory后，close掉流
  process.nextTick(function() {
    if (err)
      self.emit("error", err)
    self.emit("close")
  })
}

through2與through2.obj全部是創(chuàng)造出一個(gè)再加工后的Transform，區(qū)別如下：

后者開啟了對(duì)象模式（objectMode屬性為true），寫入的參數(shù)不僅僅限制在string or uint8Array

后者降低了閾值（highWaterMark為16，而不是默認(rèn)的16kb），這樣做的原因，是為了和node的默認(rèn)保持一致，具體可以參見這里

through2.ctor可以用來再次定制，其返回的是一個(gè)構(gòu)造函數(shù)，用法可以參考下面：

const Tran = through.ctor(function(chunk, enc, callback) {
  console.log("transform", chunk.toString());
  callback(null, chunk);
});
const transform = new Tran();
寫在最后

stream在node中有著非常廣泛的應(yīng)用，但是它使用起來卻不是那么友好，throgh2的出現(xiàn)可以減少使用上的麻煩，其原理也非常的簡(jiǎn)單；以上內(nèi)容均為本人理解，如有錯(cuò)誤還請(qǐng)指出，不勝感激~

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/89349.html

相關(guān)文章

  • 【每日一包0021】csv2,through2

    摘要：地址采用流模式讀取文件，每次讀取一行數(shù)據(jù)對(duì)流的二次封裝，更加易于使用普通用法等同于可以使號(hào)或者號(hào)參數(shù)每次流傳完可以和一樣做一些數(shù)據(jù)處理將文件中的全部替換為輸出到完事寫入完成對(duì)于需要相同處理過程的數(shù)據(jù)可以采用該方法創(chuàng)建一個(gè)構(gòu)造函數(shù)完事 [github地址：https://github.com/ABCDdouyae...] csv2 采用流模式讀取.csv文件，每次讀取一行數(shù)據(jù) throu...

    AnthonyHan 評(píng)論0 收藏0

  • 【每日一包0021】csv2,through2

    摘要：地址采用流模式讀取文件，每次讀取一行數(shù)據(jù)對(duì)流的二次封裝，更加易于使用普通用法等同于可以使號(hào)或者號(hào)參數(shù)每次流傳完可以和一樣做一些數(shù)據(jù)處理將文件中的全部替換為輸出到完事寫入完成對(duì)于需要相同處理過程的數(shù)據(jù)可以采用該方法創(chuàng)建一個(gè)構(gòu)造函數(shù)完事 [github地址：https://github.com/ABCDdouyae...] csv2 采用流模式讀取.csv文件，每次讀取一行數(shù)據(jù) throu...

    XBaron 評(píng)論0 收藏0

  • 【每日一包0021】csv2,through2

    摘要：地址采用流模式讀取文件，每次讀取一行數(shù)據(jù)對(duì)流的二次封裝，更加易于使用普通用法等同于可以使號(hào)或者號(hào)參數(shù)每次流傳完可以和一樣做一些數(shù)據(jù)處理將文件中的全部替換為輸出到完事寫入完成對(duì)于需要相同處理過程的數(shù)據(jù)可以采用該方法創(chuàng)建一個(gè)構(gòu)造函數(shù)完事 [github地址：https://github.com/ABCDdouyae...] csv2 采用流模式讀取.csv文件，每次讀取一行數(shù)據(jù) throu...

    pkhope 評(píng)論0 收藏0

  • through2.js,xtend.js源碼

    摘要：優(yōu)化性能這里有個(gè)有意思的地方。在多個(gè)參數(shù)的情況下。無則跳過，支持覆蓋不可變。與原先不同的是，這里使用了一份初始化的對(duì)象引用來作為容器承載其余沒有不同 through2 本質(zhì)上是一種transform的流 被封裝更好地操作流 var Transform = require(readable-stream/transform) , inherits = require(util).i...

    pekonchan 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<