上一节熟悉了常用的fs方法,现在就来练习一下文件的拷贝
一、小文件拷贝
代码如下:
var fs=require('fs');
var filepath='./1.txt';
fs.stat(filepath,(error,stats)=>{
if(error){
console.log(error);
}else{
fs.readFile(filepath,(error,data)=>{
if(error){
console.log(error);
}else{
fs.writeFile('./copy.txt',data,(error)=>{
if(error){
console.log(error);
}else{
console.log('文件拷贝成功!');
console.log('文件内容如下:');
fs.readFile('./copy.txt','utf8',(error,data)=>{
if(error){
console.log(error);
}else{
console.log(data);
}
})
}
})
}
});
}
})
下面执行看下效果:
一开始文件夹里只有一个待拷贝的txt文件和一个js执行文件
文件执行后:
可以看到成功拷贝生成了copy.txt文件,控制台也输出了文件内容
二、大文件拷贝
上边的程序拷贝一些小文件没啥问题,但这种一次性把所有文件内容都读取到内存中后再一次性写入磁盘的方式不适合拷贝大文件,内存会被撑爆。对于大文件,我们只能读一点写一点,直到完成拷贝,这个时候就用到了文件读取流和写入流。
- data事件
代码如下:
var fs=require('fs');
var fileFrom='./sql_server.iso'; //待拷贝的文件路径
var fileTo='./copy.iso' // 拷贝后的文件路径
fs.stat(fileFrom,(error,stats)=>{
if(error){
console.log(error);
}else{
var fileSize=stats.size;
var totalChunk=0;
var reader=fs.createReadStream(fileFrom); //读取流
var writer=fs.createWriteStream(fileTo); //写入流
reader.on('data',(chunk)=>{
writer.write(chunk,(error)=>{
if(error){
console.log(error);
}else{
// 拷贝进度
totalChunk += chunk.length;
progress=parseInt((totalChunk/fileSize)*100)+'%'
console.log(progress);
}
})
})
reader.on('end',()=>{
console.log('文件拷贝完成');
})
}
})
这里增加了个显示拷贝进度,准备文件是个2G多的大文件,如图:
代码执行过程中:
可以看到和期望中一样,文件没有问题
-
pipe
其实上面的代码可以pipe进行简化:
var fs=require('fs');
var fileFrom='./sql_server.iso'; //待拷贝的文件路径
var fileTo='./copy.iso' // 拷贝后的文件路径
fs.stat(fileFrom,(error,stats)=>{
if(error){
console.log(error);
}else{
var fileSize=stats.size;
var totalChunk=0;
var reader=fs.createReadStream(fileFrom); //读取流
var writer=fs.createWriteStream(fileTo); //写入流
//下面的这一段仅仅是为了显示拷贝进度
writer.on('pipe',(read)=>{
//此处的read指向流向writer的读取流,即reader===read
read.on('data',(chunk)=>{
// 拷贝进度
totalChunk += chunk.length;
progress=parseInt((totalChunk/fileSize)*100)+'%'
console.log(progress);
})
})
reader.pipe(writer); // 这一句话就可以实现文件的拷贝
}
})
实现拷贝的功能只需要这一句 reader.pipe(writer);
是不是最简单了