f s 模块
fs.stat()
检测是文件还是目录
fs.stat('./html', (err,data) => { if(err) { console.log(err) return; } console.log(data); console.log(`是文件:${data.isFile()}`) console.log(`是目录:${data.isDirectory()}`); })
fs.mkdir()
创建目录
/* path 将要创建的目录路径 mode 目录权限 (读写权限) , 默认777 callback 回调, 传递异常参数err */ fs.mkdir('./css', (err) => { if(err) { console.log(err) return; } console.log('创建成功'); })
fs.writeFile()
创建并写入文件
/* filename (String) 文件名称 data (String | Buffer) 将要写入的内容 可以是字符串或buffer数据 options (Object) option数组对象,包含: 1.encoding (string) 可选值, 默认 'utf8',当 data 是 buffer时, 2.mode (Number) 文件读写权限, 默认值 438 3.flag (String) 默认值 'w' callback {function} 回调, 传递一个异步参数err */ fs.writeFile('./html/index.html', '你好nodejs', (err) => { if(err) { console.log(err) return; } console.log('创建写入文件成功'); }) // 注意 :: 当没有要写入的这个文件时创建文件并写入,如果这个文件已经存在了,写入的内容将覆盖原先的文件内容
fs.appendFile()
追加文件
fs.appendFile('./css/base.css', 'body{color:red}', (err) => { if(err) { console.log(err) return; } console.log('appendFile 成功'); }) //与writeFile() 功能相同, 不同的是 appendFile()是追加文件
fs.readFile()
读取文件
fs.readFile('./html/index.html', (err,data) => { if(err) { console.log(err) return; } console.log(data.toString()) //把Buffer 转化成string类型 })
fs.readdir()
读取目录
fs.readdir('./html', (err, data) => { if(err) { console.log(err) return; } console.log(data); })
fs.rename()
重命名
//原名 原路径 //现名 现路径 fs.rename('./css/aaa.css','./css/index.css', (err) => { if(err) { console.log(err) return; } console.log('重命名成功'); })
fs.rmdir
删除目录
fs.rmdir('./aaaa', (err) => { if(err) { console.log(err) return; } console.log('删除目录成功'); })
fs.unlink()
删除文件
fs.unlink('./aaaa/index.html', (err) => { if(err) { console.log(err) return } console.log('删除文件成功'); }) // 删除文件夹,首先要先删除文件夹里面的文件 (先 unlink 后 fs.rmdir)
案例:
创建 upload目录
const fs = require('fs') var path = './upload' fs.stat(path, (err, data) => { // err 没有这个文件 if(err) { mkdir(path) return; } //有这个文件时: 判断是文件类型还是目录类型 // 文件类型: 1.删除该文件,执行成功后,创建目录 if(!data.isDirectory) { fs.unlink(path, (err) => { if(!err) { mkdir(path) } else { console.log('请检测传入的数据是否正确'); } }) } }) function mkdir(file) { fs.mkdir(file, (err) => { if(err) { console.log(err) return; } console.log('创建目录成功'); }) }
wwwroot 文件夹下面有images css js 以及 indexedDB.html, 找出 wwwroot 目录下面的所有目录, 放到一个数组中
fs.readdir('./wwwroot', (err,data) => { if(err) { console.log(err) return; } console.log(data); }) // 解决异步问题 // 1. 改造for循环 2. node.js里面的新特性 async await const path = './wwwroot' const dirArr = [] fs.readdir(path,(err,data) => { if(err) { console.log(err) return; } // =============异步解决办法一================= (function getDir(i) { if(i == data.length) { console.log(dirArr) return; } fs.stat(path+'/'+data[i], (error,stats) => { if(stats.isDirectory()) { dirArr.push(data[i]) } getDir[i+1] }) })(0) // ==============这样写会出现异步================ //for(var i =0; i<data.length;i++) { // fs.stat(path+'/'+data[i], (error,stats) => { // if(stats.isDirectory()) { // dirArr.push(data[i]) // }) //} //console.log(dirArr) // ============================================ })
异步解决办法二
async await
async function test() { return new Promise((resolve, reject) => { setTimeout(function () { var name = '张三 222' resolve(name) },1000) }) } async function main() { var data = await test() console.log(data); }
async function isDir(path) { return new Promise((resolve, reject) => { fs.stat(path, (error, stats) => { if(error) { console.log(error) reject(error) return; } if(stats.isDirectory()) { resolve(true) } else { resolve(false) } }) }) } function main() { var path = './wwwroot' var dirArr = [] fs.readdir(path,async(err, data) => { if(err) { console.log(err); return } for(var i=0; i<data.length; i++) { if(await isDir(path + '/' + data[i])) { dirArr.push(data[i]) } } console.log(dirArr); }) } main()
从文件流中读取数据
fs.createReadStream
const fs = require('fs') var readStream = fs.createReadStream('./data/input.txt') var count = 0; var str = ''; readStream.on('data', (data) => { //监听 str += data count++ }) readStream.on('end', () => { //读取结束 console.log(str) console.log(count); }) readStream.on('error', (err) => { //报错 console.log(err); })
fs.createWriteStream
// 从文件流中读取数据 const fs = require('fs') var str = '' for(var i = 0; i < 503; i++) { str+='我是从数据库获取的数据, 我要保存起来\n' } var writeStream = fs.createWriteStream('./data/output.txt') writeStream.write(str); //写入数据了 //标记写入完成 writeStream.end() //标记写入完成 监听写入完成情况前必须标记写入完成 writeStream.on('finish', () => { console.log('写入完成'); })
readStream.pipe()
//管道流 用于复制文件 const fs = require('fs') var readStream = fs.createReadStream('./aaa.jpg') var writeStream = fs.createWriteStream('./data/aaa.jpg') readStream.pipe(writeStream)
静态资源方法
./module/routes.js 里面
const fs = require('fs') const path = require('path'); const url = require('url') // 私有方法 let getFileMime = function (extname) { // 方法一: // return new Promise((resolve, reject) => { // fs.readFile('./data/mime.json', (err,data) => { // if(err) { // console.log(err); // reject(err) // return; // } // let mimeObj = JSON.parse(data.toString()) // console.log(mimeObj[extname]); // resolve(mimeObj[extname]) // }) // }) // 方法二: var data = fs.readFileSync('./data/mime.json') //同步方法 let mimeObj = JSON.parse(data.toString()) return mimeObj[extname] } exports.static = function (req, res, staticPath) { // 1. 获取地址 // let pathname = req.url let pathname = url.parse(req.url).pathname pathname = pathname == '/' ? '/index.html' : pathname //获取后缀名 let extname = path.extname(pathname) // 2. 通过fs模块读取文件 if(pathname != '/favicon.ico') { fs.readFile('./'+ staticPath + pathname, (err,data) => { if(err) { res.writeHead(404, {'Content-Type': 'text/html;charset="utf-8"'}); res.end('404这个页面不存在') } let mime = getFileMime(extname) res.writeHead(200, {'Content-Type': ''+mime+';charset="utf-8"'}) res.end(data); }) } }
// 三元运算分的基本格式 : 条件?真结果:假结果 // 三元表达式是如何对应if…else语句的？ // 条件 ? 真结果 : 假结果 // if(条件){真结果}else{假结果} // 三元表达式的局限性 // 最后，大家注意，三元表达式在使用过程中不能使用break,continue等语句。否则…
./app03.js 里面
const http = require('http'); const routes = require('./module/routes') http.createServer(function (req,res) { routes.static(req, res, 'static') }).listen(3000); console.log('Server running at http://127.0.0.1:3000/');
路由
路由 是由一个 URL 和一个特定的 HTTP 方法组成的,涉及到应用如何响应客户端对某个网站节点的访问.
即 : 针对不同请求的URL, 处理不同的业务逻辑
http.createServer(function (req,res) { routes.static(req, res, 'static') let pathname = url.parse(req.url).pathname if(pathname == '/login') { res.writeHead(200, {'Content-Type': 'text/html;charset="utf-8"'}) res.end("执行登录") } else if(pathname == '/register') { res.writeHead(200, {'Content-Type': 'text/html;charset="utf-8"'}) res.end("执行注册") } else if(pathname == '/admin') { res.writeHead(200, {'Content-Type': 'text/html;charset="utf-8"'}) res.end("处理后的业务逻辑") } else { res.writeHead(404, {'Content-Type': 'text/html;charset="utf-8"'}) } }).listen(3000);
