首页 > Web开发 > 详细

node.js 利用流实现读写同步,边读边写

时间:2017-09-10 13:04:18      阅读:271      评论:0      收藏:0      [点我收藏+]
//10个数 10个字节,每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {
    //先创建可读流,再创建可写流
    //先读一次,rs.on(data)
    //将读到的类容写入目标中 ,返回布尔值,如果是ture,继续写,默认情况应该是false,暂停读取
    //ws.on(‘drain‘),抽干后,回复读取
    //监听读取文件完毕后,关闭读取rs.on(‘end‘)

    let rs=fs.createReadStream(source,{highWaterMark:4});
    let ws=fs.createWriteStream(target,{highWaterMark:1});

    rs.on(‘data‘,function (chunk) {  //chunk是buffer类型

        if(ws.write(chunk)===false){
            //写不下,停止读取
            rs.pause()
        }

    });
    ws.on(‘drain‘,function () {
        //每次写的内存干了就恢复读取
        console.log("111");
        rs.resume() //恢复读取
    });
    rs.on(‘end‘,function (chunk) {
        ws.end();
    })

}
pipe(‘./1.txt‘,‘./3.txt‘)

 上面这种写法比较繁琐,大家看完后,忘记就行

node.js提供给我们内置方法pipe

//10个数 10个字节,每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {

    let rs=fs.createReadStream(source,{highWaterMark:4});
    let ws=fs.createWriteStream(target,{highWaterMark:1});
    //可读流到可写流,异步操作,可以保证内存不会被淹没,读一点,写一点
    // 如果想看文件类容,使用readFile

    rs.pipe(ws);
}
pipe(‘./1.txt‘,‘./4.txt‘)

直接将读取的流操作到写入流中,还是异步操作

node.js 利用流实现读写同步,边读边写

原文:http://www.cnblogs.com/null11/p/7500705.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!