车震门 小游戏,野茱萸,美女校园购物
前言
本文主要给大家介绍了关于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);
可读流的一些概念
可读流是 对提供数据的源头的抽象
可读流的实例
可读流的模式
可读流有两种工作模式:flowing和paused.
在flowing模式下,可读流自动从系统底层读取数据,并通过eventemitter接口的事件尽快将数据提供给应用.
可读流在创建的时候都是处在paused模式.
可读流可以在两种模式下切换.
处于paused模式可读流,可以通过下面三种途径切换到flowing模式:
stream.resume()
方法.stream.pipe()
方法将数据发送到writable处于flowing模式可读流,可以通过下面两种途径切换到paused模式:
stream.pause()
方法实现stream.unpipe()
方法移除所有管道来实现可读流事件
可读流提供了以下事件:
总结
以上就是这篇文章的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对移动技术网的支持。
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Object.keys() 和 Object.getOwnPropertyNames() 的区别详解
JavaScript使用prototype属性实现继承操作示例
JavaScript直接调用函数与call调用的区别实例分析
JavaScript设计模式--简单工厂模式实例分析【XHR工厂案例】
网友评论