Node.js數(shù)據流Stream之Duplex流和Transform流用法
Duplex流一個很好的例子是TCP套接字連接.需要實現(xiàn)_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 CompleteProcess finished with exit code 0
Transform變換流擴展了Duplex流，不需要實現(xiàn)而是直接提供。但要實現(xiàn)_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數(shù)據流Stream之Duplex流和Transform流的文章就介紹到這了。希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了Nodejs處理異常操作,結合實例形式分析了nodejs針對異常的捕獲與處理相關操作技巧,需要的朋友可以參考下2018-12-12
node使用querystring內置模塊解決分頁返回數(shù)據太多導致json.parse()解析報錯問題
這篇文章主要介紹了node使用querystring內置模塊解決分頁返回數(shù)據太多導致json.parse()解析報錯問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-09-09
本文主要闡述如何在 Express 中使用錯誤處理中間件（error-handling middleware）來高效處理異步錯誤。在 Github 上有對應 代碼實例 可供參考。2017-03-03
這篇文章主要為大家介紹了Nest.js系列學習之初識nest項目框架及服務,有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-02-02
nodejs基于express實現(xiàn)文件上傳的方法
這篇文章主要介紹了nodejs基于express實現(xiàn)文件上傳的方法,結合實例形式分析了nodejs基于express框架實現(xiàn)文件上傳功能的具體步驟與相關操作技巧,需要的朋友可以參考下2018-03-03
nodejs對express中next函數(shù)的一些理解
這篇文章主要介紹了nodejs對express中next函數(shù)的一些理解,具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-09-09
這篇文章主要介紹了Node.js 制作實時多人游戲框架,需要的朋友可以參考下2015-01-01
這篇文章主要為大家介紹了nodejs express搭建服務并熱更新文件過程詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-11-11
在構建視頻分享平臺時,視頻的收藏功能是用戶互動的重要組成部分,本文將介紹如何在Node.js應用中實現(xiàn)視頻收藏功能,包括數(shù)據模型的創(chuàng)建、業(yè)務邏輯的實現(xiàn)以及接口的驗證測試,需要的朋友可以參考下2024-04-04
這篇文章主要介紹了nodejs事件的監(jiān)聽與觸發(fā)的理解分析,以實例形式對比分析了nodejs與jQuery關于事件監(jiān)聽的實用技巧,有助于加深對nodejs的理解,需要的朋友可以參考下2015-02-02