Node.js中stream如何使用，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
成都创新互联坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站设计、成都网站建设、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的银州网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！使用流的好处
举一个读取文件的例子:
使用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事件将在流中有数据可供读取时触发.
关于Node.js中stream如何使用问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联网站建设公司行业资讯频道了解更多相关知识。
另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。