Node.js數據流Stream之Duplex流和Transform流用法

 更新時間:2022年07月06日 10:19:37   作者:社會主義接班人  
這篇文章介紹了Node.js數據流Stream之Duplex流和Transform流的用法,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下

Duplex流一個很好的例子是TCP套接字連接.需要實現_read(size)和_Write(data,encoding,callback)方法.

var stream = require('stream');
var util = require('util');
util.inherits(Duplexer, stream.Duplex);
function Duplexer(opt) {
  stream.Duplex.call(this, opt);
  this.data = [];
}
Duplexer.prototype._read = function readItem(size) {
  var chunk = this.data.shift();
  if (chunk == "stop"){
    this.push(null);
  } else{
    if(chunk){
      this.push(chunk);
    }
  }
};
Duplexer.prototype._write = function(data, encoding, callback) {
  this.data.push(data);
  callback();
};
var d = new Duplexer({allowHalfOpen:true});
d.on('data', function(chunk){
  console.log('read: ', chunk.toString());
});
d.on('readable',function(){
  console.log("readable");
})
d.on('end', function(){
  console.log('Message Complete');
});
d.write("I think, ");
d.write("therefore ");
d.write("I am.");
d.write("Rene Descartes");
d.write("stop");

輸出結果:

"C:\Program Files (x86)\JetBrains\WebStorm 11.0.3\bin\runnerw.exe" F:\nodejs\node.exe stream_duplex.js
read:  I think, 
read:  therefore 
read:  I am.
read:  Rene Descartes
readable
readable
readable
Message Complete

Process finished with exit code 0

Transform變換流擴展了Duplex流,不需要實現而是直接提供。但要實現_transform(chunk,encoding,callback)._flush()這個方法不知道用來做什么的目前

var stream = require("stream");
var util = require("util");
util.inherits(JSONObjectStream, stream.Transform);
function JSONObjectStream (opt) {
  stream.Transform.call(this, opt);
};
JSONObjectStream.prototype._transform = function (data, encoding, callback) {
  object = data ? JSON.parse(data.toString()) : "";
  this.emit("object", object);
  object.handled = true;
  this.push(JSON.stringify(object));
  callback();
};
var tc = new JSONObjectStream();
tc.on("object", function(object){
  console.log("Name: %s", object.name);
  console.log("Color: %s", object.color);
});
tc.on("data", function(data){
  console.log("Data: %s", data.toString());
});
tc.write('{"name":"Carolinus", "color": "Green"}');
tc.write('{"name":"Solarius", "color": "Blue"}');
tc.write('{"name":"Lo Tae Zhao", "color": "Gold"}');
tc.write('{"name":"Ommadon", "color": "Red"}');

輸出結果:

"C:\Program Files (x86)\JetBrains\WebStorm 11.0.3\bin\runnerw.exe" F:\nodejs\node.exe stream_transform.js
Name: Carolinus
Color: Green
Data: {"name":"Carolinus","color":"Green","handled":true}
Name: Solarius
Color: Blue
Data: {"name":"Solarius","color":"Blue","handled":true}
Name: Lo Tae Zhao
Color: Gold
Data: {"name":"Lo Tae Zhao","color":"Gold","handled":true}
Name: Ommadon
Color: Red
Data: {"name":"Ommadon","color":"Red","handled":true}

Process finished with exit code 0

到此這篇關于Node.js數據流Stream之Duplex流和Transform流的文章就介紹到這了。希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

  • Nodejs中Express 常用中間件 body-parser 實現解析

    Nodejs中Express 常用中間件 body-parser 實現解析

    這篇文章主要介紹了Nodejs中Express 常用中間件 body-parser 實現解析,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-05-05
  • 詳解Node.js:events事件模塊

    詳解Node.js:events事件模塊

    由于nodejs是單線程運行的,所以nodejs需要借助事件輪詢,本篇文章主要介紹了Node.js:events事件模塊,有興趣的可以了解一下。
    2016-11-11
  • Node.js 文件夾目錄結構創建實例代碼

    Node.js 文件夾目錄結構創建實例代碼

    下面小編就為大家帶來一篇Node.js 文件夾目錄結構創建實例代碼。小編覺得挺不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-07-07
  • koa2使用ejs和nunjucks作為模板引擎的使用

    koa2使用ejs和nunjucks作為模板引擎的使用

    這篇文章主要介紹了koa2使用ejs和nunjucks作為模板引擎的使用,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-11-11
  • node和vue實現商城用戶地址模塊

    node和vue實現商城用戶地址模塊

    這篇文章主要為大家詳細介紹了node和vue實現商城用戶地址模塊,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-12-12
  • Nodejs實現多人同時在線移動鼠標的小游戲分享

    Nodejs實現多人同時在線移動鼠標的小游戲分享

    這篇文章主要介紹了Nodejs實現多人同時在線移動鼠標的小游戲分享,本文給出了服務器端和客戶端代碼以及運行方法,需要的朋友可以參考下
    2014-12-12
  • Centos7 安裝Node.js10以上版本的方法步驟

    Centos7 安裝Node.js10以上版本的方法步驟

    這篇文章主要介紹了Centos7 安裝Node.js10以上版本的方法步驟,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2019-10-10
  • Node.js中ES6模塊化及Promise對象

    Node.js中ES6模塊化及Promise對象

    這篇文章主要介紹了Node.js中ES6模塊化及Promise對象,node.js?遵循了?CommonJS?的模塊化規范,文章圍繞主題展開詳細的內容介紹,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-07-07
  • Linux CentOS系統下安裝node.js與express的方法

    Linux CentOS系統下安裝node.js與express的方法

    這篇文章主要給大家介紹了在Linux CentOS系統下安裝node.js與express的方法,文中介紹的非常詳細,相信對大家具有一定的參考價值,需要的朋友們下面來一起看看吧。
    2017-04-04
  • 淺談KOA2 Restful方式路由初探

    淺談KOA2 Restful方式路由初探

    這篇文章主要介紹了淺談KOA2 Restful方式路由初探,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2019-03-03

最新評論

美丽人妻被按摩中出中文字幕