今天主要是對readline模塊和Stream(流)的學習使用
什么是readline
readline允許從可讀流中以逐行的方式讀取數(shù)據(jù)材泄，比如process.stdin等沮焕。 在node.js命令行模式下默認引入了readline模塊，但如果是使用node.js運行腳本的話拉宗，則需要自己通過require('readline')方式手動引入該模塊峦树。
// 導入readline模塊
const readline = require('readline');
如何使用readline
1.創(chuàng)建readline接口實例
// 1.創(chuàng)建readline接口實例
const ReL = readline.createInterface({
input: process.stdin, //設(shè)置標準的輸入流
output: process.stdout //設(shè)置標準輸出流
});
2.定義一個事件，以問答為例（question）
ReL.question('今天天氣怎么樣旦事？\n ', function(answer){
console.log('今天天氣：', answer);
// 不加close魁巩，則不會結(jié)束
ReL.close();
});
//close事件監(jiān)聽
ReL.on('close',function () {
// 結(jié)束
process.exit(0)
})
圖片.png
圖片.png
// Promise封裝
function RelQuestion(questionTitle) {
return new Promise(function (resolve,reject) {
ReL.question('問：'+questionTitle+'\n', function(answer){
resolve(answer);
console.log('答：', answer);
});
})
}
// 異步調(diào)用
async function RelQ() {
await RelQuestion('今天星期幾？');
await RelQuestion('你在上班嗎姐浮？');
await RelQuestion('心情怎么樣谷遂？');
await RelQuestion('再見');
ReL.close();
}RelQ()
//close事件監(jiān)聽
ReL.on('close',function () {
// 結(jié)束
process.exit(0)
})
可以搭配文件讀取和文件寫入，實現(xiàn)將輸入內(nèi)容寫入到文件中等功能卖鲤。
圖片.png
二肾扰、什么是Stream(流)
Stream是一個抽象接口，Node 中有很多對象實現(xiàn)了這個接口蛋逾。例如集晚，對http 服務(wù)器發(fā)起請求的request 對象就是一個 Stream，還有stdout（標準輸出）区匣。
Node.js偷拔，Stream 有四種流類型：
- Readable - 可讀操作。
- Writable - 可寫操作亏钩。
- Duplex - 可讀可寫操作.
- Transform - 操作被寫入數(shù)據(jù)莲绰，然后讀出結(jié)果。
所有的 Stream 對象都是 EventEmitter 的實例铸屉。常用的事件有：
- data - 當有數(shù)據(jù)可讀時觸發(fā)钉蒲。
- end - 沒有更多的數(shù)據(jù)可讀時觸發(fā)。
- error - 在接收和寫入過程中發(fā)生錯誤時觸發(fā)彻坛。
- finish - 所有數(shù)據(jù)已被寫入到底層系統(tǒng)時觸發(fā)顷啼。
如何使用Stream(流)
1.寫入流
// 寫入流
// 1.創(chuàng)建寫入流
let createW = fs.createWriteStream('hello.txt',{flag:'w',encoding:'utf-8'})
// 監(jiān)聽文件打開(open)、文件關(guān)閉(close)和準備(ready)事件
createW.on('open',function () {
console.log('文件打開');
})
createW.on('ready',function () {
console.log('文件準備寫入昌屉！');
})
createW.on('close',function () {
console.log('寫入完成钙蒙，文件關(guān)閉！');
})
// 2.文件流寫入(write)
createW.write('今天有點冷间驮！',function (err) {
if(err){
console.log('出錯：'+err);
}else{
console.log('寫入流1成功躬厌！');
}
})
createW.write('不想上班！',function (err) {
if(err){
console.log('出錯：'+err);
}else{
console.log('寫入流2成功！');
}
})
// 3.寫入完成--結(jié)束(end)
createW.end(function () {
console.log('寫入結(jié)束--關(guān)閉文件');
})
圖片.png
圖片.png
2.可讀流
// 可讀流
// 1.創(chuàng)建可讀流
let createR = fs.createReadStream('hello.txt',{flag:'r',encoding:'utf-8'})
// 監(jiān)聽文件打開(open)扛施、文件關(guān)閉(close)事件
createR.on('open',function () {
console.log('讀取文件打開');
})
createR.on('close',function () {
console.log('讀取完成鸿捧，文件關(guān)閉！');
})
// 監(jiān)聽數(shù)據(jù)流讀取
createR.on('data',function (res) {
console.log('單批數(shù)據(jù):'+res);
})
圖片.png
3.管道流
管道提供了一個輸出流到輸入流的機制疙渣。通常我們用于從一個流中獲取數(shù)據(jù)并將數(shù)據(jù)傳遞到另外一個流中匙奴。
// 管道流
// 1.創(chuàng)建可讀流
let createR = fs.createReadStream('hello.txt',{flag:'r',encoding:'utf-8'})
// 2.創(chuàng)建寫入流
let createW = fs.createWriteStream('hello2.txt',{flag:'w',encoding:'utf-8'})
//3.監(jiān)聽讀寫
createR.on('open',function () {
console.log('讀取文件打開');
})
createR.on('close',function () {
console.log('讀取完成，文件關(guān)閉妄荔！');
})
createW.on('open',function () {
console.log('文件打開');
})
createW.on('ready',function () {
console.log('文件準備寫入泼菌！');
})
createW.on('close',function () {
console.log('寫入完成，文件關(guān)閉啦租！');
})
// 4.管道讀寫操作
createR.pipe(createW)
// 讀取 hello.txt 文件內(nèi)容哗伯，并將內(nèi)容寫入到 hello2.txt 文件中,沒有hello2.txt文件會自動新建。
圖片.png
圖片.png
4.鏈式流
鏈式是通過連接輸出流到另外一個流并創(chuàng)建多個流操作鏈的機制篷角。鏈式流一般用于管道操作焊刹。
接下來我們就是用管道和鏈式來壓縮和解壓文件。
- 創(chuàng)建 compress.js 文件, 代碼如下：
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("文件壓縮完成内地。");
代碼執(zhí)行結(jié)果如下：
$ node compress.js
文件壓縮完成伴澄。
執(zhí)行完以上操作后，我們可以看到當前目錄下生成了 input.txt 的壓縮文件 input.txt.gz阱缓。
接下來非凌，讓我們來解壓該文件，創(chuàng)建 decompress.js 文件荆针，代碼如下：
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("文件解壓完成敞嗡。");
代碼執(zhí)行結(jié)果如下：
$ node decompress.js
文件解壓完成。
今天星期六航背，在上班喉悴，花了一個小時學習，天氣很冷玖媚，心情很憂傷箕肃，用凍僵的雙手創(chuàng)造財富，加油搬磚今魔！明天休息勺像！
日期：2021/11/13
學習參考視頻：*https://www.bilibili.com/video/BV1i7411G7kW?p=6&t=1.1
