node的fs模块

let fs = require('fs');

2. 同步读取
let fd = fs.readFileSync(__dirname + '/source/a.txt');
console.log(fd);
console.log(fd.toString());

console.log('后续的操作');

3. 异步读取
fs.readFile(__dirname + '/source/a.txt', (err, data)=>{
    if(!err){
        console.log(data);
        console.log(data.toString());
    }
});
console.log('后续的操作');

let fs = require('fs');

// 1. 打开文件
let fd = fs.openSync(__dirname + '/source/b.txt', 'w');
console.log(fd);

// 2. 同步写入内容
fs.writeFileSync(fd, '哈哈哈！');

// 3. 保存并退出
fs.closeSync(fd);

// 4. 后续操作
console.log('后续的操作');

let fs = require('fs');

// 1. 打开文件
fs.open(__dirname + '/source/c.txt', 'a', (err, fd) => {
    if (!err) {
        // 2. 写入文件
        fs.writeFile(fd, '小撩漂亮!哈哈哈哈' + Date.now() + '
', (err)=>{
            if(!err){
                console.log('写入文件成功');
            }else {
                throw err;
            }
        });

        // 3. 关闭文件
        fs.close(fd, (err)=>{
             if(!err){
                 console.log('文件已经保存并关闭!');
             }else {
                 throw err;
             }
        })
    }
});

// 后续操作
console.log('后续操作');

let fs = require('fs');

let copy = (src, target, callBack)=>{
    fs.readFile(src, (err, data)=>{
        if(!err){ // 读取成功
           fs.writeFile(target, data, (err, data)=>{
              if(!err){ // 写入成功
                  callBack && callBack(err, data);
              }else {
                  throw err;
              }
           });
        }
    });
};

copy(__dirname + '/source/b.txt', __dirname + '/source/d.txt', (err)=>{
    if(!err){
        console.log('拷贝成功!');
    }
});

let fs = require('fs');

// 1. 读取图片
/*
fs.readFile('C:/Users/yejianhua/Desktop/girl.jpg', (err, data)=>{
        if(!err){
       // 2. 写入图片文件
       fs.writeFile(__dirname + '/source/girl.jpg', data, (err)=>{
           if(err) throw err;
           console.log('写入成功');
       });
    }
});
*/


fs.readFile('C:/Users/yejianhua/Desktop/lk.mp4', (err, data)=>{
    console.log(data);
    if(!err){
        // 2. 写入图片文件
        fs.writeFile(__dirname + '/source/lk.mp4', data, (err)=>{
            if(err) throw err;
            console.log('写入成功');
        });
    }
});

let fs = require('fs');

// 1. 创建读写流
let rs = fs.createReadStream('C:/Users/yejianhua/Desktop/lk1.mp4');
let ws = fs.createWriteStream(__dirname + '/source/lk888.mp4');

// 2. 监听流的打开
rs.once('open', ()=>{
   console.log('写入流已经打开了~');
});

ws.once('open', ()=>{
    console.log('读入流已经打开了~');
});

// 3. 监听data
rs.on('data', (data)=>{
    console.log(data);
    ws.write(data);
});

// 4. 监听流的关闭
rs.once('end', ()=>{
    console.log('读入数据已经完成~');
});

rs.once('close', ()=>{
    console.log('读入数据通道关闭~');
});

let fs = require('fs');

// 1. 创建读写流
let rs = fs.createReadStream('C:/Users/yejianhua/Desktop/lk1.mp4');
let ws = fs.createWriteStream(__dirname + '/source/lk999.mp4');

// 2. 创建管道
rs.pipe(ws);

let fs = require('fs');




// 1. 创建读写流
let rs = fs.createReadStream('C:/Users/yejianhua/Desktop/lk1.mp4');
let ws = fs.createWriteStream(__dirname + '/source/lk000.mp4');

rs.on('data', (data)=>{
    let flag = ws.write(data);
    console.log(flag);
    // 判断
    if(!flag){
        // 暂停
        rs.pause();
    }
});

ws.on('drain', ()=>{
   // 继续读取流
   rs.resume();
});

rs.on('end', ()=>{
   ws.end();
});

自己写方法实现pipe功能