node.js 深入 5 fs对文件的操作，创建删除

Posted 2022-01-03 lin-fighting

首先要学习二叉搜索树的实现，可以看这篇文章二叉搜索树

fs对目录的操作

需掌握的api:

• fs.mkdir, 异步创建文件夹，如果存在报错
• fs.mkdirSync, 同步创建目录 如果存在报错
• fs.existSync, 判断文件/文件夹是否存在
• fs.stat 判断文件/文件夹的状态，不存在报错
• fs.rmdir 异步删除文件夹,文件夹下有儿子报错
• fs.rmdirSync 同步删除文件夹
• fs.readdir 读取文件夹下的儿子，读取文件报错
• fs.unlink 删除文件
• fs.rename 重命名文件

创建目录

只能一层一层创建，而且当D存在的时候会报错。我们实现自己的Mkfir方法，使其可以跨层创建并且文件已存在也不会报错。
思路：通过递归，先一层一层创建出来，然后判断如果存在就不创建，继续递归。

实现自己的Mkdir方法，递归执行创建，通过fs.stat来判断是否创建还是跳过。

创建成功。
不过这种写法不够雅观，是通过回调函数的，可以通过promise来改写。

node11之后，不用通过util.promisfy来改写fs的方法了。
这次不用递归了，同步最好使用循环，使用async使mkdir函数放回一个promise，然后await fs.mkdir同步执行，等待完成后返回success。如果mkdir中报错了，会被catch捕获到。

使用async+await的方式比回调简洁很多。

删除目录/文件夹/文件

fs.rmidr

删除文件夹，异步判断删除文件夹 但是只要文件夹不为空，就不能删掉， 而且删除的文件/文件夹不存在也会报错


fs.readdir 异步读取目录/文件夹中的儿子，只能读儿子，不存在会报错，不能读取文件

fs.unlink(fs.rname)删除文件，是文件，不是文件夹。
现在有个需求，判断删除a。那么我们需要先判断a是文件还是文件夹，然后再调用对应的方法，否则会报错

通过stat判断文件状态，提供isFile和isDirectory来判断是否文件或者文件夹，调用fs.unlink或者fs.rmdir。

封装删除方法

封装删除方法，即使删除文件夹并且文件夹下面有儿子，也直接删除。
思路就是：目录的结构跟树结构很像，必须删除所有的儿子才能删除文件夹。通过递归遍历删除所有的儿子，
如图就是我们应该做的删除顺序。

如图，思路可能有点绕。step的递归是通过回调来执行的。而rmdir本身也会递归。具体思路就是:

• 1 先通过fs.stat判断删除文件还是文件夹，如果使文件，就直接删除，调用回调，这个调用回调很关键。
• 2 如果是文件夹，就通过readdir获取文件夹下的所有目录，拼接起来，然后搞了索引，指向指向当前要被删除的儿子。
• 3 接着编写一个step函数用来判断索引是否等于儿子数组的长度，来判断儿子是否清空，不是的话执行rmdir删除第一个儿子，因为不知道儿子是文件还是文件夹所以继续递归调用rmdir，并让索引++。
• 4 step函数必须作为rmdir的回调，因为step是用来清空儿子的，只有通过回调调用step，让其删除完所有儿子，才会删除当前的文件夹，并且调用cb退出。
• 这里的难点主要是rmdir的递归以及step的回调调用，rmdir用来删除文件/文件夹，而step用来删除文件夹下的所有儿子。
• 这种方式叫做串行，效率较低。

并行删除

两棵树同时开始删。

这里i从递归调用rmidr和step变成了循环递归调用rmdir。
主要思路就是dirs同时并发删除，删除成功后触发回调，index++，当index等于当前长度之后，就表示儿子删除完毕，直接删除文件夹就好。



删除成功，这是并发与串行的区别。

转换成async await

换成同步代码

关键就是promise.all这个，他会并发执行dirs里面每个promise，里面的值又去调用syncRmdir，反复调用，直到最底层的文件夹被被删除，然后返回success，以此类推，到最后最外层的promise返回success，继续往下走执行await fsp.rmdir删除文件夹。因为async函数返回的就是一个Promise了。所以promise.all里面的每个值都是promise。




删除成 功。

总结：

可以自己通过回调函数的形式，串行或者并发删除子文件，最后再成功删除文件夹。也可以通过promise，async+await的形式通过promise.all，递归调用，同步删除所有子文件之后再去删除文件夹。

阶段性总结

流

流是用来解决大文件读取问题的，不像readFile，流可以指定读取的位置和读取的大小，客户端发送给服务端的数据都是一段段，接受客户端的数据，也是用流的方式。

流的模式

可写流：rs.on('data) rs.on(‘end’) push(数据）发送数据触发data事件
可写流： ws.wirte() ws.end() 只能sting|buffer ，指定写入内容的位置，将内容分开写入
双工流：tcp，基于net模块包装的tcp双工流，能读能写。socket.write socket.end socket.on(‘data’)
转化流： transform模式

pipe管道

pipe: 可以将读取到的内容，发送给写入，如rs.pipe(ws)
管道实现的思想：靠的是发布订阅模式，读取一段内容之后就发送给写入流。写入使多个异步并发，可以实现异步顺序造队列，实现按顺序依次执行，保证每次只有一个fs.write在执行。

文件操作

目录的结构跟树结构很相似。
fs.mkdir
fs.rmdir
fs.stat stateObj.isDirectory() stateObj.isFile()
fs.readdir
fs.unlink
fs.existSync