一名热爱体感技术的
业余专业开发人员

[转]从Stream 1到Stream 3的流API比较

http://www.jdon.com/idea/nodejs/io-stream3.html

这个概念和pull-stream库貌似没啥关系,还是记录下吧。

从Stream 1到Stream 3的流API比较

Node Stream流模块是用来处理数据流的强大模块,流API不断在改进,Stream 1引入了推流push-stream允许开发者有效地使用数据,Stream 2在推流基础上加入拉流pull-stream,这两种风格不能一起使用,Stream 3以一种灵活的方式解决了这个问题,允许同样的流既能push推又能拉pull,Stream3将在Node v0.11/v0.12和io.js中适用。

Stream 1推流

在最初的流实现中,每次当有数据可用时,都有一个数据事件发生,开发者可以使用pause()和resume()来控制流,调用pause()将引起底层停止发送数据事件的发生。

// node 0.8
var fs = require(‘fs’);
var stream = fs.createReadStream(‘readme.txt’);
stream.setEncoding(‘utf8’);
stream.pause();
// 一秒后再开始流Resume the stream in 1 second
setTimeout(stream.resume.bind(stream), 1000);
var data = ;
stream.on(‘data’, function(chunk) {
  data += chunk;
})
stream.on(‘end’, function() {
  // 流终点到达 End of the stream has been reached and no more data can be read
  console.log(‘Data length: %d’, data.length);
});
> node test.js
Data length: 1506

不管怎样,Stream 1有一些问题:

  • 暂停pause() 方法并不暂停,它只是建议advisory-only.
  • 无论你是否准备好,’数据’ 事件就立即来了
  • 没有办法消费使用指定数量的字节,然后将剩余的交给程序其他部分来处理。

 

Stream 2拉流

Node 0.10引入了Streams 2 API,增加了Pull拉方式,也就是从数据流读取时可以采取拉方式,这样解决了以前的问题,流总是从暂停状态开始,通过read(numBytes) API读取,此外,当数据可用时,一个可读的事件将被发射。

// node 0.10 – pull stream, readable event example
var fs = require(‘fs’);
var stream = fs.createReadStream(‘readme.txt’);
stream.setEncoding(‘utf8’);
//不需要使用stream.pause();暂停流
var data = ;
stream.on(‘readable’, function() {
  var chunk;
  while(chunk = stream.read()) {
    data += chunk;
  }
});
stream.on(‘end’, function() {
  //流终点到达 End of the stream has been reached and no more data can be read
  console.log(‘Data length: %d’, data.length);
});
> node test.js
Data length: 1506

原来Stream 1读数据的推模型还是可以使用,能够使用一个数据事件处理器来实现,增加一个数据事件处理器在un-pausing时有副作用。

// node 0.10 – push stream, data event example
var fs = require(‘fs’);
var stream = fs.createReadStream(‘readme.txt’);
stream.setEncoding(‘utf8’);
stream.pause();
//一秒后重新开始流 Resume the stream in 1 second
setTimeout(stream.resume.bind(stream), 1000);
var data = ;
stream.on(‘data’, function(chunk) {
  data += chunk;
})
stream.on(‘end’, function() {
  // End of the stream has been reached and no more data can be read
  console.log(‘Data length: %d’, data.length);
});
> node test.js
Data length: 1506

但是拉Pull和Push推不能混合在一起使用

 

Stream 3混合流

在io.js的1.0.1中,我们有一个混合流的实现,缺省默认流还是可以被暂停,增加数据事件处理器还是可以auto-unpause自动取消暂停流,如果我们暂停流,然后使用read()方法,它将发射一个相应的数据事件。

// node 0.11+, io.js 1.0.1
var fs = require(‘fs’);
var stream = fs.createReadStream(‘readme.txt’);
stream.setEncoding(‘utf8’);
stream.pause();
var pulledData = ;
var pushedData = ;
stream.on(‘readable’, function() {
  var chunk;
  while(chunk = stream.read()) {
    pulledData += chunk;
  }
});
stream.on(‘data’, function(chunk) {
  pushedData += chunk;
});
stream.on(‘end’, function() {
  // End of the stream has been reached and no more data can be read
  console.log(‘Pulled data length: %d’, pulledData.length);
  console.log(‘Pushed data length: %d’, pushedData.length);
});
> node test.js
Pulled data length: 1506
Pushed data length: 1506

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址