浅析Node.js中StreamAPI的使用_node.js
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了浅析Node.js中StreamAPI的使用_node.js，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3996字，纯文字阅读大概需要6分钟。
内容图文
本文由浅入深给大家介绍node.js stream api，具体详情请看下文吧。
基本介绍
在 Node.js 中，读取文件的方式有两种，一种是用 fs.readFile ，另外一种是利用 fs.createReadStream 来读取。
fs.readFile 对于每个 Node.js 使用者来说最熟悉不过了，简单易懂，很好上手。但它的缺点是会先将数据全部读入内存，一旦遇到大文件的时候，这种方式读取的效率就非常低下了。
而 fs.createReadStream 则是通过 Stream 来读取数据，它会把文件（数据）分割成小块，然后触发一些特定的事件，我们可以监听这些事件，编写特定的处理函数。这种方式相对上面来说，并不好上手，但它效率非常高。
事实上， Stream 在 Node.js 中并非仅仅用在文件处理上，其他地方也可以看到它的身影，如 process.stdin/stdout , http , tcp sockets , zlib , crypto 等都有用到。
本文是我学习 Node.js 中的 Stream API 中的一点总结，希望对大家有用。
特点
基于事件通讯
可以通过 pipe 来连接流
种类
Readable Stream 可读数据流
Writeable Stream 可写数据流
Duplex Stream 双向数据流，可以同时读和写
Transform Stream 转换数据流，可读可写，同时可以转换（处理）数据
事件
可读数据流的事件
readable 数据向外流时触发
data 对于那些没有显式暂停的数据流，添加data事件监听函数，会将数据流切换到流动态，尽快向外提供数据
end 读取完数据时触发。注意不能和 writeableStream.end() 混淆，writeableStream 并没有 end 事件，只有 .end() 方法
close 数据源关闭时触发
error 读取数据发生错误时触发
可写数据流的事件
drain writable.write(chunk) 返回 false 之后，缓存全部写入完成，可以重新写入时就会触发
finish 调用 .end 方法时，所有缓存的数据释放后触发，类似于可读数据流中的 end 事件，表示写入过程结束
pipe 作为 pipe 目标时触发
unpipe 作为 unpipe 目标时触发
error 写入数据发生错误时触发
状态
可读数据流有两种状态： 流动态 和 暂停态 ，改变数据流状态的方法如下：
暂停态 -> 流动态
添加 data 事件的监听函数
调用 resume 方法
调用 pipe 方法
注意：如果转为流动态时，没有 data 事件的监听函数，也没有 pipe 方法的目的地，那么数据将遗失。
流动态 -> 暂停态
不存在 pipe 方法的目的地时，调用 pause 方法
存在 pipe 方法的目的地时，移除所有 data 事件的监听函数，并且调用 unpipe 方法，移除所有 pipe 方法的目的地
注意：只移除 data 事件的监听函数，并不会自动引发数据流进入「暂停态」。另外，存在 pipe 方法的目的地时，调用 pause 方法，并不能保证数据流总是处于暂停态，一旦那些目的地发出数据请求，数据流有可能会继续提供数据。
用法
读写文件
更多用法
可以参考一下 https://github.com/jeresig/node-stream-playground ，进去示例网站之后直接点 add stream 就能看到结果了。
常见坑
用 rs.pipe(ws) 的方式来写文件并不是把 rs 的内容 append 到 ws 后面，而是直接用 rs 的内容覆盖 ws 原有的内容
已结束/关闭的流不能重复使用，必须重新创建数据流
pipe 方法返回的是目标数据流，如 a.pipe(b) 返回的是 b，因此监听事件的时候请注意你监听的对象是否正确
如果你要监听多个数据流，同时你又使用了 pipe 方法来串联数据流的话，你就要写成：
data
常用类库
event-stream 用起来有函数式编程的感觉，个人比较喜欢
awesome-nodejs#streams 由于其他 stream 库我都没用过，所以有需求的就直接看这里吧
以上内容是小编给大家介绍的Node.js 中 Stream API 的使用，希望大家喜欢。
内容总结
以上是互联网集市为您收集整理的浅析Node.js中StreamAPI的使用_node.js全部内容，希望文章能够帮你解决浅析Node.js中StreamAPI的使用_node.js所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。