当前位置：首页 > 资讯 > 技术文档

Node.js中流(stream)的使用方法示例

时间：2020-04-07 08:13 编辑：来源：阅读：
扫一扫，手机访问

摘要：Node.js中流(stream)的使用方法示例

[b]前言[/b] 本文主要给大家介绍了关于Node.js 流(stream)的使用方法，分享出来供大家参考学习，下面话不多说，来一起看看详细的介绍：流是基于事件的API,用于管理和处理数据,而且有不错的效率.借助事件和非阻塞I/O库,流模块允许在其可用的时候动态处理,在其不需要的时候释放掉. [b]使用流的好处[/b] 举一个读取文件的例子: 使用[code]fs.readFileSync[/code]同步读取一个文件,程序会被阻塞,所有的数据都会被读取到内存中. 换用[code]fs.readFile[/code]读取文件,程序不会被阻塞,但是所有的数据依旧会被一次性全部被读取到内存中. 当处理大文件压缩,归档,媒体文件和巨大的日志文件的时候,内存使用就成了问题,在这种情况下,流的优势就体现出来了. 流被设计为异步的方式.相比将剩余的文件数据一次性读进内存,还是值得读取一个缓冲区,期望的操作将会被执行,而且结果会被写到输出流. [img]http://files.jb51.net/file_images/article/201707/2017716143947171.png?2017616143955[/img] [b]流的分类[/b] [list] [*][code]stream.Readable[/code]---用于在I/O上获取数据[/*] [*][code]stream.Writable[/code]---用于在输出的目标写入数据[/*] [*][code]stream.Duplex[/code]---一个可读可写的流,例如网络连接[/*] [*][code]stream.Transform[/code]---一个会以某种方式修改数据的双工流[/*] [/list] [b]创建一个可读流[/b] [b]方法一[/b]

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);

[b]方法二[/b]

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);

[b]方法三[/b]

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);

[b]可读流的一些概念[/b] 可读流是对提供数据的源头的抽象 [b]可读流的实例[/b] [list] [*]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[/*] [/list] [b]可读流的模式[/b] 可读流有两种工作模式:flowing和paused. 在flowing模式下,可读流自动从系统底层读取数据,并通过EventEmitter接口的事件尽快将数据提供给应用. 可读流在创建的时候都是处在paused模式. 可读流可以在两种模式下切换. 处于paused模式可读流,可以通过下面三种途径切换到flowing模式: [list] [*]监听'data'事件.[/*] [*]调用[code]stream.resume()[/code]方法.[/*] [*]调用[code]stream.pipe()[/code]方法将数据发送到Writable[/*] [/list] 处于flowing模式可读流,可以通过下面两种途径切换到paused模式: [list] [*]如果不存在管道目标,可以通过调用[code]stream.pause()[/code]方法实现[/*] [*]如果存在管道目标,可以通过取消'data'事件监听,并调用[code]stream.unpipe()[/code]方法移除所有管道来实现[/*] [/list] [b]可读流事件[/b] 可读流提供了以下事件: [list] [*]'close'事件,事件将在流或底层资源关闭后触发,但不是所有的流都会触发该事件.[/*] [*]'data'事件,data事件将会在流将数据传递给消费者时触发.当流转换到flowing模式时会触发该事件.[/*] [*]'end'事件,end事件只有在数据被完全消费后才会触发.[/*] [*]'error'事件,error事件会在底层系统内部出错从而不能产生数据,或当流的实现试图传递错误数据时发生.[/*] [*]'readble'事件,readable事件将在流中有数据可供读取时触发.[/*] [/list] [b]总结[/b] 以上就是这篇文章的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对编程素材网的支持。

全部评论(0)

上一篇：Node.js Addons翻译(C/C++扩展)
下一篇：基于Node.js + WebSocket打造即时聊天程序嗨聊

资讯排行榜
更多>>