node 可读流与可写流的运用详解

const rs =  fs.createReadStream("./1.txt",config)//参1文件路径,参2配置对象

//一般都是直接默认
const config = {
    encoding:"utf-8",//编码格式
    highWaterMark:3,//每次读取几字节,汉字占三字节
    autoClose:true,//自动关闭
    start:0//从何处开始读
    flawing:false//创建时暂停读取
    flags:'r'//如何读取
}

const rs =  fs.createReadStream("./1.txt",{highWaterMark:1})//每次读取1字节
/**用来保存可读流读取的数据 */
const arr =[];
rs.on("data", (val) => {
    console.log(val);//这个函数会触发九次
    arr.push(val)//将val添加到数组末尾
});
//监听end方法,可读流读取完毕时该方法调用
rs.on("end",()=>{
    console.log(arr)
})
//监听错误
rs.on("error", (err: Error) => {
    console.log(err);
});

rs.on("data", (val: string) => {
    console.log(val);
    rs.pause()//暂停读取
    rs.resume() //继续读取
});
rs.pipe(我是可写流!下面会说!)//将读取的文件直接放入写入的文件中

rs.on("open", () => {
    console.log("打开了");
  });
rs.on("close", () => {
    console.log("关闭了");
});

const arr = [];
rs.on("data", (val) => {
    console.log(val);//这个函数会触发九次 
    arr.push(val)//将val添加到数组末尾
    rs.on("end",()=>{
        // !!! 注意 这样书写监听监听并不会按照我们的预期执行
        console.log(arr);
    })
});

//创建可写流
const ws = fs.createWriteStream("./2.text",config)
//使用可写流
ws.write('1')//写入,当缓存区满时会返回false,反之true
ws.close()//关闭可写流
ws.end("写完我后并关闭可写流")
//侦听可写流
ws.on('poen',()=>{console.log('可写流打开了')})
ws.on('close',()=>{console.log('可写流关闭了')})
ws.on("drain",()=>{console.log("写入缓存空了,可以继续写入")})//重要

//创建可读流
const rs = fs.createReadStream("./1.txt")
//创建可写流
const ws = fs.createWriteStream("./2.txt")
//监听data方法,可读流每次读取会调用
rs.on("data", val => { 
    if(!ws.write(val+"64k分隔\n")){//\n是回车,\t是进格...
        //如果缓存满了会进此这个代码块
        rs.pause()//暂停读取
    }
});
//监听可写流的drain方法,写入缓存空了会调用此方法
ws.on("drain",()=>{
    rs.resume() //继续读取
})
//监听end方法,可读流读取完毕时该方法调用
rs.on("end",()=>{ 
    console.log("读取完毕")
    //记得关闭可写流!!!
    ws.close()
})
//监听错误 
rs.on("error", err =>  console.log(err));

//创建可读流 
const rs = fs.createReadStream("./1.txt") 
//创建可写流
const ws = fs.createWriteStream("./2.txt")
rs.pipe(ws)//这就搞定了!,非常方便...

# 安装koa-body
npm i koa-body

cosnt koaBody = require('koa-body')
app.use(koaBody({
  multipart: true,//接收文件开关
  formidable: {
        maxFileSize: 1 * 1024 * 1024//最大上传1M
    }
}));
//收到文件后文件常用信息
const file = ctx.request.files.img //img是前端上传文件时文件对应的key名
file.size //文件大小
file.filepath//文件缓存路径
file.originalFilename//文件原名称
file.mimetype//文件类型
file.lastModifiedDate//文件上传时间
file.newFilename//文件新名称
file._writeStream//文件可写流,这个没啥用...
//如果有多个文件,file将会是一个数组
//可以使用文件的 file.filepath 缓存路径来创建一个可读流,然后保存到服务器或者数据库或者第三方平台