Node.js中流(stream)的使用方法示例
前言
本文主要给大家介绍了关于Node.js 流(stream)的使用方法,分享出来供大家参考学习,下面话不多说,来一起看看详细的介绍:
流是基于事件的API,用于管理和处理数据,而且有不错的效率.借助事件和非阻塞I/O库,流模块允许在其可用的时候动态处理,在其不需要的时候释放掉.
使用流的好处
举一个读取文件的例子:
使用fs.readFileSync
同步读取一个文件,程序会被阻塞,所有的数据都会被读取到内存中.
换用fs.readFile
读取文件,程序不会被阻塞,但是所有的数据依旧会被一次性全部被读取到内存中.
当处理大文件压缩,归档,媒体文件和巨大的日志文件的时候,内存使用就成了问题,在这种情况下,流的优势就体现出来了.
流被设计为异步的方式.相比将剩余的文件数据一次性读进内存,还是值得读取一个缓冲区,期望的操作将会被执行,而且结果会被写到输出流.
流的分类
stream.Readable
---用于在I/O上获取数据stream.Writable
---用于在输出的目标写入数据stream.Duplex
---一个可读可写的流,例如网络连接stream.Transform
---一个会以某种方式修改数据的双工流
创建一个可读流
方法一
var Stream = require('stream') var readable = Stream.Readable(); var source = ['a', 'b', 'c']; readable._read = function() { this.push(source.shift() || null); } readable.pipe(process.stdin);
方法二
var Readable = require('stream').Readable; function MyStream(options) { Readable.call(this, options); } MyStream.prototype = Object.create(Readable.prototype, { constructor: { value: MyStream } }); MyStream.prototype._read = function() { this.push("hello"); this.push(null); } var streams = new MyStream(); streams.pipe(process.stdin);
方法三
var stream = require('stream'); var util = require('util'); function MyStream(options) { stream.Readable.call(this, options); } MyStream.prototype._read = function(size) { this.push('hello'); this.push(null); } util.inherits(MyStream, stream.Readable); var streams = new MyStream(); streams.pipe(process.stdout);
可读流的一些概念
可读流是 对提供数据的源头的抽象
可读流的实例
- http responses,on the client
- http requests, on the server
- fs read stream
- zlib streams
- crypto streams
- TCP sockets
- child process stdout and stderr
- process.stdin
可读流的模式
可读流有两种工作模式:flowing和paused.
在flowing模式下,可读流自动从系统底层读取数据,并通过EventEmitter接口的事件尽快将数据提供给应用.
可读流在创建的时候都是处在paused模式.
可读流可以在两种模式下切换.
处于paused模式可读流,可以通过下面三种途径切换到flowing模式:
- 监听'data'事件.
- 调用
stream.resume()
方法. - 调用
stream.pipe()
方法将数据发送到Writable
处于flowing模式可读流,可以通过下面两种途径切换到paused模式:
- 如果不存在管道目标,可以通过调用
stream.pause()
方法实现 - 如果存在管道目标,可以通过取消'data'事件监听,并调用
stream.unpipe()
方法移除所有管道来实现
可读流事件
可读流提供了以下事件:
- 'close'事件,事件将在流或底层资源关闭后触发,但不是所有的流都会触发该事件.
- 'data'事件,data事件将会在流将数据传递给消费者时触发.当流转换到flowing模式时会触发该事件.
- 'end'事件,end事件只有在数据被完全消费后才会触发.
- 'error'事件,error事件会在底层系统内部出错从而不能产生数据,或当流的实现试图传递错误数据时发生.
- 'readble'事件,readable事件将在流中有数据可供读取时触发.
总结
以上就是这篇文章的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。
- 1615: [Usaco2008 Mar]The Loathesome Hay Baler麻烦的干草打包机
- Polyspace不认识Interrupt,肿么办?
- 1639: [Usaco2007 Mar]Monthly Expense 月度开支
- 1638: [Usaco2007 Mar]Cow Traffic 奶牛交通
- 1642: [Usaco2007 Nov]Milking Time 挤奶时间
- 1625: [Usaco2007 Dec]宝石手镯
- 1613: [Usaco2007 Jan]Running贝茜的晨练计划
- 1677: [Usaco2005 Jan]Sumsets 求和
- 1609: [Usaco2008 Feb]Eating Together麻烦的聚餐
- 1602: [Usaco2008 Oct]牧场行走
- 【LeetCode 500】关关的刷题日记27 Keyboard Row
- 1601: [Usaco2008 Oct]灌水
- 1657: [Usaco2006 Mar]Mooo 奶牛的歌声
- 1610: [Usaco2008 Feb]Line连线游戏
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 设在起始地址为STRING的存储空间存放了一个字符串(该串已存放在内存中,无需输入,且串长不超过99),统计字符串中字符“A”的个数,并将结果显示在屏幕上。
- Docker容器ElasticSearch-Head创建索引无响应406
- springboot监控&springboot配置https
- 面试中最长常问到的 HashMap,你都知道多少?
- spring security 使用自定义AuthenticationFailureHandler无法跳转failureUrl
- Android studio 下载安装教程和第一个程序运行最新,多图详解
- ubuntu16.04下qt5.14报错:/home/zhangfakai/Qt5.14.1/5.14.1/gcc_64/include/QtGui/qopengl.h:141: error: GL/
- 每天手撕一道算法-64. 最小路径和
- 每日手撕一道算法题-322.零钱兑换
- 每天手撕一道算法题-130. 被围绕的区域
- TKE上部署metrics-server
- Docker-Compose搭建mysql、redis、zookeeper、rabbitmq、consul、elasticsearch环境
- MDK更改配色方案
- Apache通过多端口配置多站点
- FatFs-目录下文件扫描