Node中的可读流和可写流实例代码分析

这篇“Node中的可读流和可写流实例代码分析”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Node中的可读流和可写流实例代码分析”文章吧。 stream 也就是流，可以理解为一连串的字节像水流那样的存在。按照官方文档的解释：A stream is an abstract interface for working with streaming data in Node.js.流是用于在 Node.js 中处理流数据，也就是连续字节的抽象接口。我们可以通免费云主机域名过 fs.createReadStream() 创建一个可读流 readableStream，第 1 个参数可以是要读取的文件路径，比如现有文件 test.txt 内容为：


hellojuejin

第 2 个参数（可选）可以传入一个选项对象，用来控制读取数据的起止位置等：


constfs=require('fs')

constreadableStream=fs.createReadStream('./test.txt',{
start:6,
end:11
})

注意，读取的数据是包括了 start 和 end 的。在之前介绍 events 模块时说过，所有的流都是 EventEmitter 的实例。所以获取数据是通过监听 'data' 事件：


readableStream.on('data',data=>{
console.log(data)
console.log(data.toString())
})

打印结果如下，默认是 Buffer 对象，可以通过 toString() 方法转为字符串：注意，读取数据时一次最多读取 64 * 1024 字节，如果想改变该数值，可以通过 highWaterMark 选项更改。另外还可以使用 pause() 进行暂停操作，使用 resume() 继续读取：


constreadableStream=fs.createReadStream('./test.txt',{
start:6,
end:11,
highWaterMark:2//默认为64*1024
})

readableStream.on('data',data=>{
console.log(data)
console.log(data.toString())
readableStream.pause()//暂停读取
setTimeout(()=>{
readableStream.resume()//恢复读取
},2000)
})

除了 'data' 事件，可读流还有其它一些事件，比如监听文件被打开的 'open'（回调会被传入 fd 参数），监听文件读取到 end（默认为读取到最后）的 'end'，监听文件关闭的 'close'（文件读取完会自动关闭）：


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('文件已关闭'))

打印结果如下：使用 fs.createWriteStream() 可以创建可写流，第 1 个参数传入要写入的文件，第 2 个同样是用于配置的可选参数，这里我们将 flags 由表示覆盖写入的 'w' 改为 'a'，即追加写入（如果还指定了写入的起始位置 start，则为了兼容 windows 系统， flags 应该写成 'r+'）：


constwritableStream=fs.createWriteStream('test.txt',{
flags:'a'
})

writableStream.write('养成',err=>console.log(`错误信息：${err}`))//错误信息：undefined
writableStream.write('写作的')
writableStream.end('好习惯')

写入数据是通过 write 方法，上方代码执行的结果就是在原本的 “hello juejin” 后添加上了 “养成写作的好习惯”。最后一次写入可以使用 end 方法，这样就能监听到可写流的 'close' 事件了：


writableStream.on('close',()=>{
console.log('关闭')
})

否则，可写流需要手动 writableStream.close() 关闭才能监听到 'close' 事件。如果写入成功，则作为 write()/end() 的第 2 个参数传入的回调的 err 就为 undefined。可读流还有另外一些事件，比如文件打开时的 'open' 事件，当 close() 或 end() 被调用后文件写入完成的 'finish' 事件。可读流与可写流可以通过 pipe 方法进行连接，实现对文件的复制：


constreadableStream=fs.createReadStream('./test.txt')
constwritableStream=fs.createWriteStream('./copy.txt')

readableStream.pipe(writableStream)

如此，便能将 ./test.txt 内的文本复制到 ./copy.txt 中。以上就是关于“Node中的可读流和可写流实例代码分析”这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注百云主机行业资讯频道。

相关推荐: React组件的属性state、props和refs如何使用

本篇内容主要讲解“React组件的属性state、props和refs如何使用”，感兴趣的朋友不妨来看看。本文介绍的方法操免费云主机域名作简单快捷，实用性强。下面就让小编来带大家学习“React组件的属性state、props和refs如何使用”吧!概念：st…

免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。