流式读取

流式读取

• 流式读取
• 可读流
• rs.resume()与rs.readableFlowing()
• rs.on()
• pipe()

流式读取

在nodejs的文件模块中我们学习了readFile和writeFile,这两种方式在读取、写入体量较小的文件时使用体验较为良好，但是一旦文件体量较大时，就会明显出现卡顿，引发内存溢出等问题，针对这个问题，我们可以用流式读取来做到完美解决

可读流

首先创建stream.js文件，并引入fs模块

const fs = require('fs')

创建可读流的基本代码格式为

const rs = fs.createReadStream('filename')

rs.resume()与rs.readableFlowing()

可读流与普通的读取文件有一个不同的地方，可读流不会自动读取文件，可以理解为可读流是静止的，我们可以使用resume()方法使可读流流动起来

const rs = fs.createReadStream('filename')
rs.resume()

同时也提供了

rs.readableFlowing()

方法来检测可读流是否可以读取数据。当数据没有流动时，rs.readableFlowing()返回null，反之返回true。
rs.resume()也存在一个缺点，他只能使可读流进行流动，但无法获取读到的数据。所以我们用更好的方法来代替它

rs.on()

rs.on()让可读流运动 还可以在回调函数中得到可读流读取的数据

//作用：让可读流运动 还可以在回调函数中得到可读流读取的数据 
rs.on('data',function(chunk){
    ws.write(chunk)
})

rs.on() 与 readFile()方法还有一点不一样的是rs.on是把数据分批读取，readFile是把数据一次性读取。当用rs.on读取一个文件时，得到的结果是这样的

很多个buffer数据的集合。
因为函数底层规定，rs.on一次最多读65536个字节的数据，可以读很多次。

pipe()

不论是rs.on() 还是 readFile()，将一个文件读取并写入到另一个文件都需要两个各自方法的两个函数搭配使用才能达成效果，这样较为麻烦，而pipe方法可以完美解决这个问题

//创建一个读取指定文件的可读流
const rs = fs.createReadStream('D:/Windows 7 Documents/Desktop/1.mp4')

//创建一个在指定文件写入的可写流
const ws = fs.createWriteStream('./2.mp4')

rs.pipe(ws)

pipe为管道的意思，rs.pipe(ws)是将可读流与可写流直接连通在一起，自动完成数据的读写

• 点赞
• 收藏
• 分享
• • 文章举报

0 error（s）0 warning（s） 发布了11 篇原创文章 · 获赞 0 · 访问量 561 私信 关注

标签：fs,读取,rs,流式,pipe,读流,可读
来源： https://blog.csdn.net/weixin_44845533/article/details/104424225