Stream(流)

Stream 是一个抽象接口,Node 中有很多对象实现了这个接口。例如,对 http 服务器发起请求的 request 对象就是一个 Stream,还有 stdout(标准输出)。

Node.js,Stream 有四种流类型:

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

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

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

本教程会为大家介绍常用的流操作。


从流中读取数据

语法:

1
fs.createWriteStream(path[, options])

创建 read.txt 文件,内容如下:

1
blog.juanertu.com

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

1
2
3
4
5
6
7
8
9
10
11
12
13
let fs = require('fs')
// 创建一个可读流
let rs = fs.createReadStream('read.txt', { flags: 'r', encoding: 'utf-8' })
// 事件监听
rs.on('open', function () {
console.log('打开文件')
})
rs.on('close', function () {
console.log('读取结束')
})
rs.on('data', function (chunk) {
console.log(chunk)
})

以上代码执行结果如下:

读取流


写入流

语法:

1
fs.createWriteStream(path[, options])

创建 index.js 文件, 代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
let fs = require('fs')
// 创建一个可写流
let ws = fs.createWriteStream('write.txt', { flags: 'a', encoding: 'utf-8' })
// 监听事件
ws.on('open', function () {
console.log('文件打开')
})
ws.on('ready', function () {
console.log('文件准备写入')
})
ws.on('close', function () {
console.log('文件关闭')
})
ws.write('你真是一个美好的人类', function (err) {
if (err) {
console.log(err)
} else {
console.log('文件正在写入')
}
})
// 文件写入完成
ws.end()

以上程序会将 data 变量的数据写入到 write.txt 文件中。代码执行结果如下

写入流

管道流

管道提供了一个输出流到输入流的机制。通常我们用于从一个流中获取数据并将数据传递到另外一个流中。

我们把文件比作装水的桶,而水就是文件里的内容,我们用一根管子(pipe)连接两个桶使得水从一个桶流入另一个桶,这样就慢慢的实现了大文件的复制过程。

以下实例我们通过读取一个文件内容并将内容写入到另外一个文件中。

设置 input.txt 文件内容如下:

1
2
博客地址:blog.juanertu.com
管道流操作实例

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

1
2
3
4
5
6
7
8
9
10
11
12
13
var fs = require('fs')

// 创建一个可读流
var readerStream = fs.createReadStream('input.txt')

// 创建一个可写流
var writerStream = fs.createWriteStream('output.txt')

// 管道读写操作
// 读取 input.txt 文件内容,并将内容写入到 output.txt 文件中
readerStream.pipe(writerStream)

console.log('程序执行完毕')

代码执行结果如下:

1
2
$ node main.js
程序执行完毕

查看 output.txt 文件的内容:

1
2
3
$ cat output.txt
博客地址:blog.juanertu.com
管道流操作实例

链式流

链式是通过连接输出流到另外一个流并创建多个流操作链的机制。链式流一般用于管道操作。

接下来我们就是用管道和链式来压缩和解压文件。

创建 compress.js 文件, 代码如下:

1
2
3
4
5
6
7
8
9
var fs = require('fs')
var zlib = require('zlib')

// 压缩 input.txt 文件为 input.txt.gz
fs.createReadStream('input.txt')
.pipe(zlib.createGzip())
.pipe(fs.createWriteStream('input.txt.gz'))

console.log('文件压缩完成。')

代码执行结果如下:

1
2
$ node compress.js
文件压缩完成。

执行完以上操作后,我们可以看到当前目录下生成了 input.txt 的压缩文件 input.txt.gz。

接下来,让我们来解压该文件,创建 decompress.js 文件,代码如下:

1
2
3
4
5
6
7
8
9
var fs = require('fs')
var zlib = require('zlib')

// 解压 input.txt.gz 文件为 input.txt
fs.createReadStream('input.txt.gz')
.pipe(zlib.createGunzip())
.pipe(fs.createWriteStream('input.txt'))

console.log('文件解压完成。')

代码执行结果如下:

1
2
$ node decompress.js
文件解压完成。