管道流,就是从一个文件拿出倒出数据到另一个数据文件中去
//createReadStream.js const fs = require('fs') //流的方式读取文件 var readStream=fs.createReadStream('input.txt'); var str=''; /*保存数据*/ var count=0; /*次数*/ readStream.on('data',function(chunk){ str+=chunk; count++; }) //读取完成 readStream.on('end',function(chunk){ console.log(count); console.log(str); }) //读取失败 readStream.on('error',function(err){ console.log(err); }) //writeStream.js var fs = require("fs") var data = '我是从数据库获取的数据,我要保存起来11\n'; // 创建一个可以写入的流,写入到文件 output.txt 中 var writerStream = fs.createWriteStream('output.txt'); for(var i=0;i<100;i++){ writerStream.write(data,'utf8'); } //标记写入完成 writerStream.end(); writerStream.on('finish',function(){ console.log('写入完成'); }) //失败 writerStream.on('error',function(){ console.log('写入失败'); }) var fs = require("fs"); // 创建一个可读流 var readerStream = fs.createReadStream('input.txt'); // 创建一个可写流 var writerStream = fs.createWriteStream('output.txt'); // 管道读写操作 // 读取 input.txt 文件内容,并将内容写入到 output.txt 文件中 readerStream.pipe(writerStream); console.log("程序执行完毕");