缓冲区
当浏览器向服务器请求数据后,数据先被加载到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. 保存,关闭文件
同步的文件写入
-
打开文件
var fd = fs.openSync(path, flags[, mode])
-
path
:要打开的文件路径 -
flags
:打开文件要做的操作的类型,和C语言类似 - 此方法会返回一个文件的描述符作为结果,可以通过该描述符对文件进行操作
-
-
写入内容
fs.writeSync(fd, string[, position[, encoding]])
-
fd
:需要写入的文件的描述符 -
string
:要写入的内容
-
-
关闭文件
fs.closeSync(fd)
异步的文件写入
-
打开文件
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 - 描述符
-
- 回调函数有两个参数
-
写入内容
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) } })
-
-
关闭文件,异步的关闭也要在循环内写,不能写在全局
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])
流式文件写入
上面提到的文件写入的方式,都是一次性的将要写入的内容直接保存到文件中,意味着当进行写入之前,要将所有要写入的内容准备好,那么如果文件太大的话,将会非常的占用内存
流式文件写入就是一种给大文件写入的解决方案,是一种持续写入的方案
-
创建可写流
fs.createWriteStream(path[, options])
var ws = fs.createWriteStream("hello.txt")
-
通过可写流写入文件
ws.write("通过可写流进行写入")
-
可以通过监听流的open和close事件来监听流是否被打开
ws.once("open", function(){ console.log("流打开了") })
-
-
关闭流
ws.end()
简单文件读取
也分成异步和同步
-
异步的
fs.readFile("htllo.txt", function(err, data){ if(!err){ console.log(data.toString()) }else{ ... } })
流式文件读取
适用于大文件的读取,可以分多次将文件读取到内存中
-
创建可读流
var rs = fs.createReadStream("hello.txt")
-
监听流
rs.once("open", function(){ console.log("可读流打开") }) rs.once("close", function(){ console.log("可读流关闭") })
-
读取可读流的数据,要为可读流绑定一个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)