node.js 利用流实现读写同步,边读边写的方法
2017-09-11 08:56
806 查看
如下所示:
//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 利用流实现读写同步,边读边写的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。
您可能感兴趣的文章:
相关文章推荐
- node.js 利用流实现读写同步,边读边写
- Node.js 使用流实现读写同步边读边写功能
- 利用node.js实现自动生成前端项目组件的方法详解
- 利用同步机制实现读写锁的四种方法
- 利用async和await异步操作解决node.js里面fs模块异步读写,同步结果的问题
- 利用node.js实现反向代理的方法详解
- Node.js读写文件之批量替换图片的实现方法
- 利用Nginx实现反向代理Node.js的方法详解
- 利用Node.js+Koa框架实现前后端交互的方法
- node.js中实现同步操作的3种实现方法
- Node.js读写文件之批量替换图片的实现方法
- node.js中实现同步操作的3种实现方法
- node.js中实现同步操作的3种实现方法
- Node.js利用Net模块实现多人命令行聊天室的方法
- 利用Node.js实现模拟Session验证的登陆
- 利用forever在Linux上实现Node.js项目自启动
- 一种利用js实现的仿淘宝商品评价功能的方法
- 关于利用js实现css切换布局视图的方法
- Xilium.CefGlue利用XHR实现Js调用c#方法
- [转]Browserify —— 利用Node.js实现JS模块化加载