前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。
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");
?
深入學習資料:
node.js 中文網:http://nodejs.cn/api/