北京网站建设及appcrm客户管理系统 项目

四种基本流类型:
1.Writable: 可以向其写入数据的流
2.Readable: 可以从中读取数据的流
3.Duplex：同时为Readable 和 Writable
4.Transform: Duplex可以在写入和读取数据时修改或转换数据的流

一、Readable

const fs = require('fs');// 创建文件的Readable
const reader = fs.createReadStream('./test.txt', {start: 8, // 文件读取开始的位置end: 18, // 文件读取结束的位置highWaterMark: 4 // 一次性读取字节的长度，默认是64kb；
})// 监听 read 数据
reader.on('data', (data) => {console.log(data.toString());
})// 监听打开文件
reader.on('open', (fd) => {console.log('文件被打开！');
})// 监听读取结束
reader.on('end', () => {console.log('文件读取结束！');
})// 监听关闭文件
reader.on('close', () => {console.log('文件被关闭！');
})

二、Writable

// 创建文件的Writable
const writer = fs.createWriteStream('./test.txt', {flags: 'a+', // 追加写入start: 8 // 写入位置
});// 写入数据 
writer.write("Hello OUTMAN", () => {console.log('写入成功！');
})// 监听文件打开
writer.on('open', () => {console.log('文件被打开！');
})// 监听文件关闭（无法监听）
// 无法监听的原因：写入流在打开后不会自动关闭，必须手动触发来通知node已经写入结束，并发射finish事件
writer.on('close', () => {console.log('文件被关闭！'); // 无法监听，不打印
})// 手动close后, finish ---> close
writer.close();writer.on('finish', () => {console.log('文件写入完成！');
})writer.on('close', () => {console.log('文件被关闭！');
})// 直接使用end，end = write传值 + 文件close，一步到位
writer.end('Hello Outman!')

三、pipe方法

// pip方法
const reader = fs.createReadStream('./test.txt');
const writer = fs.createWriteStream('./copy.txt');// 常规方法，嵌套 read & write
reader.on('data', (data) => {console.log(data);writer.write(data, (err) => {console.log(err);})
})// 利用pipe实现
reader.pipe(writer);