【nodejs】缓冲与文件系统

缓冲区

  • 当浏览器向服务器请求数据后,数据先被加载到buffer中,再被浏览器读取;浏览器向服务器上传数据,也是先加载到buffer中,再给服务器。buffer是一个用于过度的中间地带

  • buffer的结构和数组很像,操作的方法也和数组类似

  • 数组不能存储二进制文件,buffer专门用于存储二进制数据

  • 使用buffer不需要引入模块

    var str = "哈库那马塔塔"
    
    //将str保存到buffer中
    var buf = Buffer.from(str)
    console.log(buf) //此处会打印出str的二进制格式,但是是以十六进制去显示
    console.log(buf.toString()) //调用toString方法,转化为字符串
    
  • 可以创建一个指定大小的buffer

    var buf2 = new Buffer(1024) //指定大小为1024byte,即1kb,但是最好别用这个方法
    
    var buf = Buffer.alloc(1024) //直接使用这种方法创建1kb的buffer
    
  • 可以通过索引,去操作buffer中的元素

    buf2[0] = 0
    buf2[1] = 255
    
  • buffer的大小一旦确定,便不能修改,因为buffer操作实际上是对底层的内存的直接操作

文件系统(fs)

  • node中用于操作系统中文件的模块。在node中,与文件系统的交互是非常重要的,服务器的本质就是将本地的文件发送给远程的客户端

  • fs模块提供了打开、读取、写入文件,以及与文件交互等API

  • 使用fs模块需要对其先进行加载,直接引入,不需要下载

    const fs = require("fs")
    
  • fs模块中所有的操作都可以选择是同步的还是异步的

    • 同步文件系统有可能会阻塞程序的正常执行,因为除非操作完毕,否则代码就会卡在那里
    • 异步文件系统不会阻塞成语的执行,在操作完成后,通过回调函数将结果返回

文件写入

文件的写入一般分为三步:

1. 打开文件
2. 向文件中写入内容
3. 保存,关闭文件

同步的文件写入

  1. 打开文件

    var fd = fs.openSync(path, flags[, mode])
    
    • path:要打开的文件路径
    • flags:打开文件要做的操作的类型,和C语言类似
    • 此方法会返回一个文件的描述符作为结果,可以通过该描述符对文件进行操作
  2. 写入内容

    fs.writeSync(fd, string[, position[, encoding]])
    
    • fd:需要写入的文件的描述符
    • string:要写入的内容
  3. 关闭文件

    fs.closeSync(fd)
    

异步的文件写入

  1. 打开文件

    fs.open(path, flags[, mode], callback)
    
    • callback:回调函数

    • 异步的open返回值为undefined,异步的结果都是通过回调函数的参数进行返回的

      fs.open("hello.txt", "r", function(err, fd){
         if(!err){
             console.log(fd)
         }else{
             console.log(err)
         }
      })
      
      • 回调函数有两个参数
        • err:错误对象,如果没有错误则为null
        • 描述符
  2. 写入内容

    fs.write(fd, string[, position[, encoding]], callback)
    
    • 异步写入的写入操作不能在全局执行,因为读取文件已经是异步的了。要写在打开文件成功的循环内

      fs.open("hello.txt", "r", function(err, fd){
         if(!err){ //没有出错,进行写入
             fs.write(fd, "异步写入", function(err){
                 if(!err){
                     console.log("写入成功")
                 }
             })
         }else{
             console.log(err)
         }
      })
      
  3. 关闭文件,异步的关闭也要在循环内写,不能写在全局

    fs.open("hello.txt", "r", function(err, fd){
     if(!err){ //没有出错,进行写入
         fs.write(fd, "异步写入", function(err){
             if(!err){
                 console.log("写入成功")
             }
             //关闭文件
             fs.close(fd, function(err){
                 if(!err){
                     console.log("关闭成功")
                 }
             })
         })
     }else{
         console.log(err)
     }
    })
    

简单文件写入

实际开发中,纯粹的同步写入和西部写入要么写起来很麻烦,要么可能会出现程序阻塞。下面是简单写入方法,也分成同步和异步,是node提供的一个语法糖

  • 异步的简单文件写入

    fs.writeFile(file, data[, options], callback)
    
    • file:要操作的文件路径
    • data:要写入的数据
    var fs = require("fs")
    fs.writeFile("hello.txt", "简单文件写入的内容", function(err){
      if(!err){
          console.log("简单写入成功")
      }
    }) n
    
  • 同步的简单文件写入

    fs.writeFileSync(file, data[, options])
    

流式文件写入

  • 上面提到的文件写入的方式,都是一次性的将要写入的内容直接保存到文件中,意味着当进行写入之前,要将所有要写入的内容准备好,那么如果文件太大的话,将会非常的占用内存

  • 流式文件写入就是一种给大文件写入的解决方案,是一种持续写入的方案

  1. 创建可写流

    fs.createWriteStream(path[, options])
    
    var ws = fs.createWriteStream("hello.txt")
    
  2. 通过可写流写入文件

    ws.write("通过可写流进行写入")
    
    • 可以通过监听流的open和close事件来监听流是否被打开

      ws.once("open", function(){
         console.log("流打开了")
      })
      
  3. 关闭流

    ws.end()
    

简单文件读取

也分成异步和同步

  • 异步的

    fs.readFile("htllo.txt", function(err, data){
      if(!err){
          console.log(data.toString())
      }else{
          ...
      }
    })
    

流式文件读取

适用于大文件的读取,可以分多次将文件读取到内存中

  1. 创建可读流

    var rs = fs.createReadStream("hello.txt")
    
  2. 监听流

    rs.once("open", function(){
     console.log("可读流打开")
    })
    rs.once("close", function(){
     console.log("可读流关闭")
    })
    
  3. 读取可读流的数据,要为可读流绑定一个data事件。当data绑定完毕,会自动开始读取数据,数据通过data返回

    rs.on("data", function(data){
     console.log(data)
    })
    

pipe()方法

可以直接将可读流中的内容直接输出到可写流

var rs = fs.createReadStream("hello.txt")
var ws = fs.createWriteStream("aaaa.txt")
rs.pipe(ws)
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容