迹忆博客
当前位置: 主页 > 学无止境 > 编程语言 > 文章

Node Stream 流(一)流的基本介绍及流下载文件

发布时间: 2017-02-07 作者: 迹忆 浏览次数:

什么是流,为什么要使用流?之前对流的概念一直比较模糊。最近有时间好好的看了看关于流的知识,总算有了一个比较清晰的认识。

首先我们来看一下什么是流。

就我自己的观点来看,其实流就是在两个设备之间建立一个管道,然后通过管道将数据以流动的方式传输。如何来理解这个以流动的方式呢?

举个例子来说吧,当我们读取文件的时候,如果不使用流的方式读取的话,我们会将整个文件的内容先通过I/O设备写进内存,然后再由消费者去内存中读取。而使用流的方式是边将文件内容写入缓存边由消费者去读取,不用将整个文件先写进内存,从而节省了内存的空间。

不使用流的方式

当一个文件非常大的时候我们看到,不使用流的方式的话,占用的内存也是相当大的。这样就影响了响应的速度。对用户的体验也是有一定的影响的。

var http = require('http');
var fs = require('fs');
var server = http.createServer(function (req, res) {

fs.readFile(__dirname + '/data.txt', function (err, data) {
     res.writeHead(200,{
         'Content-Type': 'application/octet-stream',
         'Content-Disposition': 'attachment; filename=data.txt',
         'Accept-Length': 1024,
     });
     res.end(data);
 });

}).listen(8000)

上面是一段文件下载的功能。要下载的文件假设500M的话,其内存占用如下

PID USER      PR  NI  VIRT  RES  SHR S %CPU %MEM    TIME+  COMMAND 
5601 root      15   0 1212m 516m 9460 R  0.7 51.7   0:10.09 node
5643 root      15   0 12764 1116  836 R  0.3  0.1   0:00.47 top   

下载一个500M的文件,上述方法会占用500多兆的内存。所以说我们应该尽量避免上述方式出现在我们代码中。

下面我们看流的方式读取文件

我们看使用流的方式的话,内存占用非常小,当然上面只是假定每次都是50M。经过测试内存使用情况流的方式平均是前者的十分之一。

其实上面流的过程我们可以这样理解

这就是我理解的流。

var http = require('http'); var fs = require('fs');
var server = http.createServer(function (req, res) {
res.writeHead(200,{
     'Content-Type': 'application/octet-stream',
     'Content-Disposition': 'attachment; filename=data.txt',
     'Accept-Length': 1024,
 });
var stream = fs.createReadStream(__dirname + '/data1.txt' );
stream.pipe(res)
}).listen(8000);

上面代码是使用流的方式来下载文件,其内存占用情况如下。

PID USER      PR  NI  VIRT  RES  SHR S %CPU %MEM    TIME+  COMMAND
5673 root      15  0  776m  49m 9992 S  7.3  5.0   0:04.47 node
5683 root      15  0  12764 1112  836 R  0.3  0.1   0:00.18 top

我们看到占用内存再50M左右。是不使用流的方式的十分之一。

至于为什么使用流,流的好处通过我们上面的例子我们也能看到,其最大的一个好处就是节省内存,提高程序的运行速度。通过上面两段文件下载的代码我们也能得到结论。除此之外node中的管道函数.pipe()(管道是流中一个非常重要的概念)还能根据消费者读取的速度通过阀门来控制写入的速度。

代码中在合适的地方加入流的使用,确能大大提高程序的性能。

赞助
迹忆博客

除非注明转载,本站文章均为原创,欢迎转载,转载请以链接形式注明出处

本文地址: