【Node.js】stream 流模块

流是一种抽象的数据结构。从键盘输入到应用程序就是标准输入流（stdin）。应用程序把字符一个一个输出到显示器上叫做：标准输出流（stdout）。

流的特点是数据是有序的，而且必须依次读取，或者依次写入，不能像Array那样随机定位。

在 Node.js 中，流也是一个对象，我们只需要响应流的事件就可以了：data事件表示流的数据已经可以读取了，end事件表示这个流已经到末尾了，没有数据可以读取了，error事件表示出错了。

const fs = require('fs');

// 打开一个流:
const rs = fs.createReadStream('./avatar/1.txt', 'utf-8');

// `data`事件可能会有多次，每次传递的`chunk`是流的一部分数据。
// rs.on('data', function (chunk) {
//   console.log('DATA:')
//   console.log(chunk);  // 我是 1.txt 里面的内容
// });

// rs.on('end', function () {
//   console.log('END');
// });

// rs.on('error', function (err) {
//   console.log('ERROR: ' + err);
// });

// 写入（覆盖写入）文件
const ws1 = fs.createWriteStream('./avatar/1.txt', 'utf-8');
ws1.write('使用Stream写入文本数据...\n');
ws1.write('END.');
ws1.end();
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

一个Readable流和一个Writable流串起来后，所有的数据自动从Readable流进入Writable流，这种操作叫pipe。pipe()把一个文件流和另一个文件流串起来，这样源文件的所有数据就自动写入到目标文件里了。

const fs = require('fs');
// 以下操作将 1.txt 的内容写入 2.txt
const readstream = fs.createReadStream('./avatar/1.txt')
const writestream = fs.createWriteStream('./avatar/2.txt')
readstream.pipe(writestream)
1
2
3
4
5