Stream 是一個抽象接口,Node 中有很多對象實現了這個接口。 Stream 有四種流類型: - Readable - 可讀操作。 - Writable - 可寫操作。 - Duplex - 可讀可寫操作. - Transform - 操作被寫入數據,然后讀出結果。 - Stream 對象都是 EventEmitter 的實例。常用的事件有: - data - 當有數據可讀時觸發。 - end - 沒有更多的數據可讀時觸發。 - error - 在接收和寫入過程中發生錯誤時觸發。 - finish - 所有數據已被寫入到底層系統時觸發。
var fs = require("fs") var data= "" var readerStreama = fs.createReadStream("input.txt") readerStreama.setEncoding('UTF8') readerStreama.on("data",function(chunk){ data+= chunk; }) readerStreama.on("end",function(){ console.log(data); }) readerStreama.on("error",function(err){ console.log(err.stack) }) console.log("程序執行完成")
var fs = require("fs"); var data = 'www.csdn.net'; // 創建一個可以寫入的流,寫入到文件 output.txt 中 var writerStream = fs.createWriteStream('output.txt'); // 使用 utf8 編碼寫入數據 writerStream.write(data,'UTF8'); // 標記文件末尾 writerStream.end(); // 處理流事件 --> data, end, and error writerStream.on('finish', function() { console.log("寫入完成。"); }); writerStream.on('error', function(err){ console.log(err.stack); }); console.log("程序執行完畢");
var fs = require("fs"); // 創建一個可讀流 var readerStream = fs.createReadStream('input.txt'); // 創建一個可寫流 var writerStream = fs.createWriteStream('output.txt'); // 管道讀寫操作 // 讀取 input.txt 文件內容,并將內容寫入到 output.txt 文件中 readerStream.pipe(writerStream); console.log("程序執行完畢");
鏈式是通過連接輸出流到另外一個流并創建多個對個流操作鏈的機制。鏈式流一般用于管道操作。
壓縮
var fs = require("fs"); var zlib = require('zlib'); // 壓縮 input.txt 文件為 input.txt.gz fs.createReadStream('input.txt') .pipe(zlib.createGzip()) .pipe(fs.createWriteStream('input.txt.gz')); console.log("文件壓縮完成。");
解壓縮
var fs = require("fs"); var zlib = require('zlib'); // 解壓 input.txt.gz 文件為 input.txt fs.createReadStream('input.txt.gz') .pipe(zlib.createGunzip()) .pipe(fs.createWriteStream('input.txt')); console.log("文件解壓完成。");
一個 Node.js 文件就是一個模塊,這個文件可能是JavaScript 代碼、JSON 或者編譯過的C/C++ 擴展。
// main.js var hello = require("./hello") hello.sayHi()
// hello.js exports.sayHi = function(){ console.log("Hello World") }
// 將對象封裝到模塊中
function sayHi(){ this.hi = function(){ console.log("Hello World") } } module.exports = sayHi
var Hello = require("./hello") var hello = new Hello() hello.hi()
免責聲明:本站所有文章和圖片均來自用戶分享和網絡收集,文章和圖片版權歸原作者及原出處所有,僅供學習與參考,請勿用于商業用途,如果損害了您的權利,請聯系網站客服處理。
工作日 8:30-12:00 14:30-18:00 周六及部分節假日提供值班服務
工作日 8:30-12:00 14:30-18:30