您好,登錄后才能下訂單哦!
這篇“Node中的可讀流和可寫流實(shí)例代碼分析”文章的知識(shí)點(diǎn)大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細(xì),步驟清晰,具有一定的借鑒價(jià)值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“Node中的可讀流和可寫流實(shí)例代碼分析”文章吧。
stream 也就是流,可以理解為一連串的字節(jié)像水流那樣的存在。按照官方文檔的解釋:
A stream is an abstract interface for working with streaming data in Node.js.
流是用于在 Node.js 中處理流數(shù)據(jù),也就是連續(xù)字節(jié)的抽象接口。
我們可以通過 fs.createReadStream()
創(chuàng)建一個(gè)可讀流 readableStream
,第 1 個(gè)參數(shù)可以是要讀取的文件路徑,比如現(xiàn)有文件 test.txt 內(nèi)容為:
hello juejin
第 2 個(gè)參數(shù)(可選)可以傳入一個(gè)選項(xiàng)對(duì)象,用來控制讀取數(shù)據(jù)的起止位置等:
const fs = require('fs')
const readableStream = fs.createReadStream('./test.txt', {
start: 6,
end: 11
})
注意,讀取的數(shù)據(jù)是包括了 start
和 end
的。 在之前介紹 events 模塊時(shí)說過,所有的流都是 EventEmitter
的實(shí)例。所以獲取數(shù)據(jù)是通過監(jiān)聽 'data'
事件:
readableStream.on('data', data => {
console.log(data)
console.log(data.toString())
})
打印結(jié)果如下,默認(rèn)是 Buffer 對(duì)象,可以通過 toString()
方法轉(zhuǎn)為字符串:
注意,讀取數(shù)據(jù)時(shí)一次最多讀取 64 * 1024 字節(jié),如果想改變?cè)摂?shù)值,可以通過 highWaterMark
選項(xiàng)更改。另外還可以使用 pause()
進(jìn)行暫停操作,使用 resume()
繼續(xù)讀?。?/p>
const readableStream = fs.createReadStream('./test.txt', {
start: 6,
end: 11,
highWaterMark: 2 // 默認(rèn)為 64 * 1024
})
readableStream.on('data', data => {
console.log(data)
console.log(data.toString())
readableStream.pause() // 暫停讀取
setTimeout(() => {
readableStream.resume() // 恢復(fù)讀取
}, 2000)
})
除了 'data'
事件,可讀流還有其它一些事件,比如監(jiān)聽文件被打開的 'open'
(回調(diào)會(huì)被傳入 fd 參數(shù)),監(jiān)聽文件讀取到 end
(默認(rèn)為讀取到最后)的 'end'
,監(jiān)聽文件關(guān)閉的 'close'
(文件讀取完會(huì)自動(dòng)關(guān)閉):
readableStream.on('data', data => console.log(data))
readableStream.on('open', fd => console.log(`${fd}文件打開了`))
readableStream.on('end', () => console.log('文件讀取到 end 位置了'))
readableStream.on('close', () => console.log('文件已關(guān)閉'))
打印結(jié)果如下:
使用 fs.createWriteStream()
可以創(chuàng)建可寫流,第 1 個(gè)參數(shù)傳入要寫入的文件,第 2 個(gè)同樣是用于配置的可選參數(shù),這里我們將 flags
由表示覆蓋寫入的 'w'
改為 'a'
,即追加寫入(如果還指定了寫入的起始位置 start
,則為了兼容 windows 系統(tǒng), flags
應(yīng)該寫成 'r+'
):
const writableStream = fs.createWriteStream('test.txt', {
flags: 'a'
})
writableStream.write('養(yǎng)成', err => console.log(`錯(cuò)誤信息:${err}`)) // 錯(cuò)誤信息:undefined
writableStream.write('寫作的')
writableStream.end('好習(xí)慣')
寫入數(shù)據(jù)是通過 write
方法,上方代碼執(zhí)行的結(jié)果就是在原本的 "hello juejin" 后添加上了 "養(yǎng)成寫作的好習(xí)慣"。最后一次寫入可以使用 end
方法,這樣就能監(jiān)聽到可寫流的 'close'
事件了:
writableStream.on('close', () => {
console.log('關(guān)閉')
})
否則,可寫流需要手動(dòng) writableStream.close()
關(guān)閉才能監(jiān)聽到 'close'
事件。如果寫入成功,則作為 write()/end()
的第 2 個(gè)參數(shù)傳入的回調(diào)的 err
就為 undefined
。
可讀流還有另外一些事件,比如文件打開時(shí)的 'open'
事件,當(dāng) close()
或 end()
被調(diào)用后文件寫入完成的 'finish'
事件。
可讀流與可寫流可以通過 pipe
方法進(jìn)行連接,實(shí)現(xiàn)對(duì)文件的復(fù)制:
const readableStream = fs.createReadStream('./test.txt')
const writableStream = fs.createWriteStream('./copy.txt')
readableStream.pipe(writableStream)
如此,便能將 ./test.txt 內(nèi)的文本復(fù)制到 ./copy.txt 中。
以上就是關(guān)于“Node中的可讀流和可寫流實(shí)例代碼分析”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對(duì)大家有幫助,若想了解更多相關(guān)的知識(shí)內(nèi)容,請(qǐng)關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。