Node.js -- Stream 使用小例 ( 流運用 :讀取、寫入、寫出、拷貝)
阿新 • • 發佈:2018-12-19
Stream 是一個抽象介面,Node 中有很多物件實現了這個介面。例如,對http 伺服器發起請求的request 物件就是一個 Stream,還有stdout(標準輸出)。
Node.js,Stream 有四種流型別:
-
Readable - 可讀操作。
-
Writable - 可寫操作。
-
Duplex - 可讀可寫操作.
-
Transform - 操作被寫入資料,然後讀出結果。
所有的 Stream 物件都是 EventEmitter 的例項。常用的事件有:
-
data - 當有資料可讀時觸發。
-
end - 沒有更多的資料可讀時觸發。
-
error - 在接收和寫入過程中發生錯誤時觸發。
-
finish - 所有資料已被寫入到底層系統時觸發。
第一例、從已有檔案中讀取:
event.js :
var fs = require("fs"); var data = ''; // 建立可讀流 var readerStream = fs.createReadStream('input.txt'); // 設定編碼為 utf8。 readerStream.setEncoding('UTF8'); // 處理流事件 --> data, end, and error readerStream.on('data', function(chunk) { data += chunk; }); readerStream.on('end',function(){ console.log(data); }); readerStream.on('error', function(err){ console.log(err.stack); }); console.log("程式執行完畢");
第2例、讀取並寫出到檔案:
stream.js :
var fs = require("fs"); var data = '這是我的部落格地址:https://blog.csdn.net/jiangyu1013\n'; var writerStream = fs.createWriteStream('output.txt'); writerStream.write(data,'UTF8'); writerStream.end(); writerStream.on('finish', function() { console.log("哈哈,寫入完成啦。"); }); writerStream.on('error', function(err){ console.log(err.stack); }); console.log("程式執行完畢了哦。");
第3例、拷貝檔案到新檔案:
pipe.js :
var fs = require("fs");
var readerStream = fs.createReadStream('output.txt');
var writerStream = fs.createWriteStream('output2.txt');
readerStream.pipe(writerStream);
console.log("程式執行完畢啦\n");