• 作者:老汪软件
  • 发表时间:2023-12-28 22:00
  • 浏览量:

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

流的特点是数据是有序的,而且必须依次读取,或者依次写入,不能像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();

一个流和一个流串起来后,所有的数据自动从流进入流,这种操作叫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)