Node.js 使用流实现读写同步边读边写功能

废话不多说了，直接给大家贴代码了，具体代码如下所示：//10个数10个字节，每次读4b,写1bl

废话不多说了，直接给大家贴代码了，具体代码如下所示：

//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 使用流实现读写同步边读边写功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！