Stream 是一个抽象接口，Node 中有很多对象实现了这个接口。例如，对http 服务器发起请求的request 对象就是一个 Stream，还有stdout（标准输出）。
Node.js，Stream 有四种流类型：

  • Readable: 可读操作。
  • Writable: 可写操作。
  • Duplex: 可读可写操作.
  • Transform: 操作被写入数据，然后读出结果。

所有的 Stream 对象都是 EventEmitter 的实例。常用的事件有：

  • data: 当有数据可读时触发。
  • end: 没有更多的数据可读时触发。
  • error: 在接收和写入过程中发生错误时触发。
  • finish: 所有数据已被写入到底层系统时触发。

从流中读取数据

创建 input.txt 文件，内容如下：

  1. Hello,一缕清风

创建 main.js 文件, 代码如下：

  1. var fs = require("fs")
  4. var readerStream = fs.createReadStream('input.txt') // 创建可读流
  5. readerStream.setEncoding('UTF8') // 设置编码为 utf8
  8. var data = ''
  9. // 处理流事件 --> data, end, and error
  10. readerStream.on('data', function (chunk) {
  11.    data += chunk
  12. })
  14. readerStream.on('end', function () {
  15.    console.log(data)
  16. })
  17. readerStream.on('error', function (err) {
  18.    console.log(err.stack)
  19. })
  21. /* 
  22. Hello, 一缕清风 
  23. */

写入流

创建 main.js 文件, 代码如下：

  1. var fs = require("fs");
  2. var data = 'Hello,一缕清风';
  4. var writerStream = fs.createWriteStream('output.txt')// 创建一个可以写入的流，写入到文件 output.txt 中
  5. writerStream.write(data, 'UTF8')// 使用 utf8 编码写入数据
  7. // 处理流事件 --> finish、error
  8. writerStream.on('finish', function () {
  9.    console.log("写入完成")
  10. })
  11. writerStream.on('error', function (err) {
  12.    console.log(err.stack);
  13. })
  15. writerStream.end() // 标记文件末尾

管道流

管道提供了一个输出流到输入流的机制。通常我们用于从一个流中获取数据并将数据传递到另外一个流中。image.png
如上面的图片所示，我们把文件比作装水的桶，而水就是文件里的内容，我们用一根管子(pipe)连接两个桶使得水从一个桶流入另一个桶，这样就慢慢的实现了大文件的复制过程。
以下实例我们通过读取一个文件内容并将内容写入到另外一个文件中。
设置 input.txt 文件内容如下：

  1. Hello,一缕清风

创建 main.js 文件, 代码如下：

  1. var fs = require("fs")
  3. var readerStream = fs.createReadStream('input.txt') // 创建一个可读流
  4. var writerStream = fs.createWriteStream('output.txt') // 创建一个可写流
  7. // 管道读写操作: 读取 input.txt 文件内容，并将内容写入到 output.txt 文件中
  8. readerStream.pipe(writerStream)
  10. console.log("程序执行完毕")

链式流

链式是通过连接输出流到另外一个流并创建多个流操作链的机制。链式流一般用于管道操作。
接下来我们就是用管道和链式来压缩和解压文件。
创建 compress.js 文件, 代码如下：

  1. var fs = require("fs")
  2. var zlib = require('zlib')
  4. // 压缩 input.txt 文件为 input.txt.gz
  5. fs.createReadStream('input.txt')
  6.    .pipe(zlib.createGzip())
  7.    .pipe(fs.createWriteStream('input.txt.gz'))

执行完以上操作后，我们可以看到当前目录下生成了 input.txt 的压缩文件 input.txt.gz。
接下来，让我们来解压该文件，创建 decompress.js 文件，代码如下：

  1. var fs = require("fs")
  2. var zlib = require('zlib')
  4. // 解压 input.txt.gz 文件为 input.txt
  5. fs.createReadStream('input.txt.gz')
  6.    .pipe(zlib.createGunzip())
  7.    .pipe(fs.createWriteStream('input.txt'))

创建流的常用方式

node.js中文件读取流方式

  1. var http = require('http');
  2. var fs = require("fs");
  5. var s1 = fs.createReadStream("input.txt");
  6. var data;
  7. s1.on("data", function (txt) {
  8.   console.log(txt);
  9.   data += txt;
  10. })
  12. s1.on("end", function (txt) {
  13.   console.log("文件流式读取成功！")
  14.   console.log(data)
  15. })

管道方式

  1. var fs = require("fs");
  2. var s1 = fs.createReadStream("input.txt");
  3. var s2 = fs.createWriteStream("output.txt");
  4. s1.pipe(s2)

获取请求的网站信息

  1. var https = require("https")
  2. var fs = require("fs")
  4. https.get("https://www.baidu.com/", function (res) {
  5.   var data
  6.   res.on("data", function (txt) {
  7.     data += txt
  8.   })
  9.   res.on("end", function () {
  10.     //console.log(data)
  11.     fs.writeFile("input.txt", data, function () {
  12.       console.log("文件写入完成！")
  13.     })
  14.   })
  15. })

批量下载图片

  1. var http = require("http");
  2. var fs = require("fs");
  3. var path = require("path");  //利用path模块，对url进行解析，以便得到想要的相关root、base等信息；
  5. http.get("http://www.itsource.cn/", function (res) {
  6.   var data;
  7.   res.on("data", function (txt) {
  8.     data += txt;
  9.   })
  10.   res.on("end", function () {
  11.     var reg = /src="((.*?)\.jpg)"/img;
  12.     var filename;
  13.     while (filename = reg.exec(data)) {
  14.       getImg(filename[1]);
  15.     };
  16.     //  fs.writeFile("input.txt",filename[1],function(){
  17.     //  console.log("文件写入成功！")  
  18.   })
  19. })
  21. function getImg(url) {
  22.   var obj = path.parse(url);
  23.   var fn = obj.base;
  25.   var stream1 = fs.createWriteStream("./files/" + fn);
  26.   console.log(fn, stream1);
  27.   if (obj.root.length === 0) {
  28.     url = "/" + url;
  29.   }
  30.   url = "http://www.itsource.cn" + url;
  31.   http.get(url, function (res) {
  32.     res.pipe(stream1);
  33.     console.log(fn + "读取完毕！")
  34.   })
  35. }