前面讲解的都是关于文件的写入和读取操作都是一次性将数据读入内存或者一次性写入到文件中的，但是如果数据比较大, 直接将所有数据都读到内存中会导致计算机内存爆炸, 卡顿, 死机等情况，所以对于比较大的文件我们需要分批读取和写入
语法示例如下
fs.createReadStream(path[, options])
fs.createWriteStream(path[, options])
let fs = require("fs");
let path = require("path");
// 1.拼接读取的路径
let str = path.join(__dirname, "BNTang.txt");
// 2.创建一个读取流
let readStream = fs.createReadStream(str, {encoding: "utf8", highWaterMark: 1});
// 3.添加事件监听
readStream.on("open", function () {
console.log("表示数据流和文件建立关系成功");
});
readStream.on("error", function () {
console.log("表示数据流和文件建立关系失败");
});
readStream.on("data", function (data) {
console.log("表示通过读取流从文件中读取到了数据", data);
});
readStream.on("close", function () {
console.log("表示数据流断开了和文件的关系, 并且数据已经读取完毕了");
});
let fs = require("fs");
let path = require("path");
// 1.拼接写入的路径
let str = path.join(__dirname, "BNTang.txt");
// 2.创建一个写入流
let writeStream = fs.createWriteStream(str, {encoding: "utf8"});
// 3.监听写入流的事件
writeStream.on("open", function () {
console.log("表示数据流和文件建立关系成功");
});
writeStream.on("error", function () {
console.log("表示数据流和文件建立关系失败");
});
writeStream.on("close", function () {
console.log("表示数据流断开了和文件的关系");
});
let data = "";
let index = 0;
let timerId = setInterval(function () {
let ch = data[index];
index++;
writeStream.write(ch);
console.log("本次写入了", ch);
if (index === data.length) {
clearInterval(timerId);
writeStream.end();
}
}, 1000);
fs 拷贝文件
let fs = require("fs");
let path = require("path");
// 1.生成读取和写入的路径
let readPath = path.join(__dirname, "test.mp4");
let writePath = path.join(__dirname, "abc.mp4");
// 2.创建一个读取流
let readStream = fs.createReadStream(readPath);
// 3.创建一个写入流
let writeStream = fs.createWriteStream(writePath);
// 4.监听读取流事件
readStream.on("open", function () {
console.log("表示数据流和文件建立关系成功");
});
readStream.on("error", function () {
console.log("表示数据流和文件建立关系失败");
});
readStream.on("data", function (data) {
console.log("表示通过读取流从文件中读取到了数据", data);
writeStream.write(data);
});
readStream.on("close", function () {
console.log("表示数据流断开了和文件的关系, 并且数据已经读取完毕了");
writeStream.end();
});
// 5.监听写入流的事件
writeStream.on("open", function () {
console.log("表示数据流和文件建立关系成功");
});
writeStream.on("error", function () {
console.log("表示数据流和文件建立关系失败");
});
writeStream.on("close", function () {
console.log("表示数据流断开了和文件的关系");
});
pipe 拷贝文件
let fs = require("fs");
let path = require("path");
// 1.生成读取和写入的路径
let readPath = path.join(__dirname, "test.mp4");
let writePath = path.join(__dirname, "abc.mp4");
// 2.创建一个读取流
let readStream = fs.createReadStream(readPath);
// 3.创建一个写入流
let writeStream = fs.createWriteStream(writePath);
// 利用读取流的管道方法来快速的实现文件拷贝
readStream.pipe(writeStream);
