Node.js -- Stream 使用小例 ( 流运用 :读取、写入、写出、拷贝)
前些天發(fā)現(xiàn)了一個巨牛的人工智能學(xué)習(xí)網(wǎng)站,通俗易懂,風(fēng)趣幽默,忍不住分享一下給大家。點擊跳轉(zhuǎn)到教程。
Stream 是一個抽象接口,Node 中有很多對象實現(xiàn)了這個接口。例如,對http 服務(wù)器發(fā)起請求的request 對象就是一個 Stream,還有stdout(標(biāo)準(zhǔn)輸出)。
Node.js,Stream 有四種流類型:
-  Readable?- 可讀操作。 
-  Writable?- 可寫操作。 
-  Duplex?- 可讀可寫操作. 
-  Transform?- 操作被寫入數(shù)據(jù),然后讀出結(jié)果。 
所有的 Stream 對象都是 EventEmitter 的實例。常用的事件有:
-  data?- 當(dāng)有數(shù)據(jù)可讀時觸發(fā)。 
-  end?- 沒有更多的數(shù)據(jù)可讀時觸發(fā)。 
-  error?- 在接收和寫入過程中發(fā)生錯誤時觸發(fā)。 
-  finish?- 所有數(shù)據(jù)已被寫入到底層系統(tǒng)時觸發(fā)。 
?
第一例、從已有文件中讀取:
?
event.js :?
var fs = require("fs"); var data = '';// 創(chuàng)建可讀流 var readerStream = fs.createReadStream('input.txt');// 設(shè)置編碼為 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("程序執(zhí)行完畢");?
第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("程序執(zhí)行完畢了哦。");第3例、拷貝文件到新文件:
?
?pipe.js :
var fs = require("fs");var readerStream = fs.createReadStream('output.txt');var writerStream = fs.createWriteStream('output2.txt');readerStream.pipe(writerStream);console.log("程序執(zhí)行完畢啦\n");?
深入學(xué)習(xí)資料:
node.js 中文網(wǎng):http://nodejs.cn/api/
總結(jié)
以上是生活随笔為你收集整理的Node.js -- Stream 使用小例 ( 流运用 :读取、写入、写出、拷贝)的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
 
                            
                        - 上一篇: OpenCV学习笔记——判断两张图的相似
- 下一篇: 【OpenCV】直方图应用:直方图均衡化
