文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

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

2023-07-05 06:48

关注

这篇“Node中的可读流和可写流实例代码分析”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“Node中的可读流和可写流实例代码分析”文章吧。

stream 也就是流,可以理解为一连串的字节像水流那样的存在。按照官方文档的解释:

A stream is an abstract interface for working with streaming data in Node.js.

流是用于在 Node.js 中处理流数据,也就是连续字节的抽象接口。 

可读的(Readable)

我们可以通过 fs.createReadStream() 创建一个可读流 readableStream,第 1 个参数可以是要读取的文件路径,比如现有文件 test.txt 内容为:

hello juejin

第 2 个参数(可选)可以传入一个选项对象,用来控制读取数据的起止位置等: 

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

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

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

打印结果如下,默认是 Buffer 对象,可以通过 toString() 方法转为字符串:

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

注意,读取数据时一次最多读取 64 * 1024 字节,如果想改变该数值,可以通过 highWaterMark 选项更改。另外还可以使用 pause() 进行暂停操作,使用 resume() 继续读取:

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

打印结果如下:

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

可写的(Writable)

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

const writableStream = fs.createWriteStream('test.txt', {  flags: 'a'})writableStream.write('养成', err => console.log(`错误信息:${err}`)) // 错误信息:undefinedwritableStream.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 方法进行连接,实现对文件的复制:

const readableStream = fs.createReadStream('./test.txt')const writableStream = fs.createWriteStream('./copy.txt')readableStream.pipe(writableStream)

如此,便能将 ./test.txt 内的文本复制到 ./copy.txt 中。

以上就是关于“Node中的可读流和可写流实例代码分析”这篇文章的内容,相信大家都有了一定的了解,希望小编分享的内容对大家有帮助,若想了解更多相关的知识内容,请关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯