接收大文件流_Node.js实战10：“流”是Node.js最强大的功能之一

墨蓝 2023-01-07 08:54 9阅读 0赞

# 流是Nodejs的高级应用，掌握流的使用，才能真正胜任NodeJS开发。 #

Nodejs中，流是基于事件的API，用于管理和处理数据，而且效率很好！

# 什么是流？ #

流是一个抽象接口，Node 中有很多对象实现了这个接口。

例如，对http 服务器发起请求的request 对象就是一个 Stream，还有stdout(标准输出)等。

# 流的四种类型 #

dable - 可读操作。

Writable - 可写操作。

Duplex - 可读可写操作.

Transform - 操作被写入数据，然后读出结果。

# 流的事件 #

所有的流对象都是 EventEmitter 的实例，流常用的事件有：

data - 当有数据可读时触发。

end - 没有更多的数据可读时触发。

error - 在接收和写入过程中发生错误时触发。

finish - 所有数据已被写入到底层系统时触发。

# 什么时候使用流？ #

举例说明：

1、当使用fs.readFileSync同步读取一个文件的时候，所有的数据会被全部读到内存中，这个操作过程中程序会被阻塞。

2、如果使用fs.readFile，由于它是异步方法，那么阻塞不会发生，但数据仍会被全部读到内存中再处理。

当处理大文件压缩、媒体文件等的时候，无疑会很吃力。那么这时，就是使用流的时候了。

3、流会将分批次的读取适量的内容到缓存区进行操作，而不是一次性读取所有目标内容。

**这样，程序对内存的使用量会极大减少、执行性能会提升很多：**

![b03665ea2be0a1dca63cbbd8cfb9ca61.png][]

# 举例说明，使用流的优势 #

先使用node内置的核心模块http实现一个简单的静态web服务器：

![8e200fcb20bfed956b6f7d6060f3bb92.png][]

这段代码使用非阻塞的fs.readfile的方法。

当被访问时，读取文件内容(代码中读取的是本举程代码)并发送给访问者。

测试访问，效果：

![9a63efe2e149bcb91e21d2c384bdc12b.png][]

可能说，功能并无问题。但如果被读取的文件test10.js文件非常大呢。就会有效率问题。

这时，可以改用流的方式：

注意图中标识出的内容，是修改的内容：使用流的方式读取，通过管道(pipe)传给res。

![46ee4cb1e3bc79b1863dca4c995f8f72.png][]

var http = require("http");var fs = require("fs");http.createServer(function(req,res){  fs.createReadStream(__dirname+"/test10.js").pipe(res);}).listen(8000);

![e5f70e9d08c1450cd4f51fdac9944671.png][]

执行效果一样，但对内存的使用得到优化，性能得到提升。

同时，代码也更简洁。

流不仅高效优雅，扩展性也更强。比如对上面的代码稍做改动，就可以实现gzip压缩传输数据，可以使网页打开更快。

![64f8545b710fa70aa06f65ad08ee09d9.png][]

var http = require("http");var fs = require("fs");var zlib = require("zlib");http.createServer(function(req,res){ res.writeHead(200,{"content-encoding":"gzip"}); fs.createReadStream(__dirname+"/test10.js").pipe( zlib.createGzip() ).pipe(res);}).listen(8000);

![09a7fef3f3463d40d9e7425f74d92b63.png][]

从浏览器信息中可以看到，内容已启用gzip压缩。

更多本系列文章：

Node.js实战9：用EventEmitter触发和响应事件

Node.js实战8：可用于压缩、加密的zlib

Node.js实战7：你了解buffer吗？

[b03665ea2be0a1dca63cbbd8cfb9ca61.png]: /images/20221119/2f89bb3bd9d74dfd8431b62ad4db8ac4.png
[8e200fcb20bfed956b6f7d6060f3bb92.png]: /images/20221119/9ef554d86c304bcb8e9c28e6ecc39cb6.png
[9a63efe2e149bcb91e21d2c384bdc12b.png]: /images/20221119/4e151cd7c51f4087974d799ed6c59469.png
[46ee4cb1e3bc79b1863dca4c995f8f72.png]: /images/20221119/6516c9c0c27b44faade1074c7f832ba1.png
[e5f70e9d08c1450cd4f51fdac9944671.png]: /images/20221119/bc74aadf0657488194135e5277f3e6a0.png
[64f8545b710fa70aa06f65ad08ee09d9.png]: /images/20221119/060b7c8bd4b245e8af9ae35a1170ed4b.png
[09a7fef3f3463d40d9e7425f74d92b63.png]: /images/20221119/d51a03dea5bc491ba6d61ddfed49ad7f.png