大熊君大话NodeJS之------FS文件模块

时间 2019-12-13

标签大话 nodejs 文件模块繁體版

原文原文链接

一，开篇分析css

文件系统模块是一个简单包装的标准 POSIX 文件 I/O 操做方法集。能够经过调用 require("fs") 来获取该模块。文件系统模块中的全部方法均有异步和同步版本。html

（1），文件系统模块中的异步方法须要一个完成时的回调函数做为最后一个传入形参。算法

（2），回调函数的构成由调用的异步方法所决定，一般状况下回调函数的第一个形参为返回的错误信息。小程序

（3），若是异步操做执行正确并返回，该错误形参则为null或者undefined。若是使用的是同步版本的操做方法，一旦出现错误，会以一般的抛出错误的形式返回错误。api

（4），能够用try和catch等语句来拦截错误并使程序继续进行。缓存

咱们先看一个简单的例子，读取文件（"bb.txt"）:并发

（1），创建文件"bb.txt“，以下内容（”你们好，我是大雄君！(*^__^*) 嘻嘻……“）。异步

（2），读取文件操做以下代码：函数

1 var fs = require("fs") ;
2 fs.readFile("bb.txt","utf8",function (error,data){
3     if(error) throw error ;
4     console.log(data) ;
5 }) ;

运行结果：post

这里要注意的是：读取文件必定要设置编码，不然默认是 ”buffer“ 形式出现。

再看没设置的运行效果，区别仍是很明显的。以下：

再来一个写操做，以下：

1 var fs = require("fs") ;
2 var txt = "你们要好好学习NodeJS啊！！！" ;
3 //写入文件
4 fs.writeFile("bb.txt",txt,function (err) {
5     if (err) throw err ;
6     console.log("File Saved !"); //文件被保存
7 }) ;

运行结果：

在列举一些经常使用的实例：

// 删除文件
fs.unlink('bb.txt', function(){
 console.log('success') ;
}) ;

// 修改文件名称
fs.rename('bb.txt','bigbear.txt',function(err){
 console.log('rename success') ;
});

 // 查看文件状态
fs.stat('bb.txt', function(err, stat){
  console.log(stat);
});

// 判断文件是否存在
fs.exists('bb.txt', function( exists ){
    console.log( exists ) ;
}) ;

二，Fs与Stream之间的联系

"Stream" 具备异步的特性。我么能够将一个文件或一段内容分为未知个制定大小的 "chunk" 去读取，每读取到一个 "chunk" 咱们就将他输出。直到文件读完。这就像 "http1.1" 种支持的 "Transfer-Encoding: chunked" 那样。 ("chunk"能够以任何的形式存在，NodeJS默认是以 "Buffer" 的形式存在，这样更高效)。NodeJS中的"Stream"具有Unix系统上的一个超级特性就是 ("pipe" ------ 管道)。

还记得 “Http模块那篇” 第一个NodeJS程序， "Hello,大熊！" 吗？咱们基于那个小程序作一下修改，以下代码：

（1），创建“bb.html”

 1 <html>
 2     <head>
 3         <style type="text/css">
 4             div {
 5                 　　margin-top: 50px;
 6                　　 width: 100%; 
 7                   　margin: 0px;
 8                 　　height:120px;
 9                 　　line-height:120px;
10                    color:#fff;
11                    font-size:22px;
12                    background:#ff9900;
13                 　 text-align: center;
14             }
15         </style>
16     </head>
17     <body>
18         <div>Hello,大熊！</div>
19     </body>
20 </html>

（2），修改以前的程序以下：

 1 var http = require('http') ;
 2 var fs = require("fs") ;
 3 var server = http.createServer(function(req,res){
 4     fs.readFile("bb.html","utf-8", function(err, data){
 5       if(err) {
 6           res.writeHead(500, {'Context-Type': 'text/plain'});
 7           res.end('specify file not exists! or server error!');
 8       }
 9       else{
10         res.writeHead(200, {'Context-Type': 'text/html'});
11         res.write(data);
12         res.end();
13       }
14   })
15 }) ;
16 server.listen(8888) ;
17 console.log("http server running on port 8888 ...") ;

如下是运行结果：

如今咱们须要思考一下，若是咱们要发送的不是一个单纯的文本文件而是超媒体文件好比说 Google 2014 IO 大会 的全程高清视频文件。mp4 格式。长度2个多小时1080p。

大概4个多GB。已知 "readFile" 的工做方式是将文件读取到内存。那么这么大一个文件显然是不能这么作的。那该怎么办呢？是以后就须要使用 stream 的来作。那么是这样的。

代码以下像这样：

fs.createReadStream(__dirname + '/vedio.mp4').pipe(res) ;

总结一下：

这些代码能够实现须要的功能，可是服务在发送文件数据以前须要缓存整个文件数据到内存，若是"bb.html"文件很
大而且并发量很大的话，会浪费不少内存。由于用户须要等到整个文件缓存到内存才能接受的文件数据，这样致使
用户体验至关很差。不过还好 "(req, res)" 两个参数都是Stream，这样咱们能够用fs.createReadStream()代替"fs.readFile()"。

三，实例赏心

来一个文件上传的小栗子：

（1），创建“server.js”

 1 var http = require('http');
 2 var url = require('url');
 3 function start(route, handler) {
 4     function onRequest (request, response) {
 5         var pathname = url.parse(request.url).pathname;
 6         // 路由到相应的业务逻辑
 7         route (pathname, handler, response, request);
 8     }
 9     http.createServer(onRequest).listen(3000);
10     console.log('server is starting');
11 }
12 exports.start = start;

（2），创建“route.js”

 1 function route (pathname, handler, response, request) {
 2     console.log('about to route a request for ' + pathname);
 3     if (typeof handler[pathname] === 'function') {
 4         return handler[pathname](response, request);
 5     } else {
 6         console.log('no request handler found for ' + pathname);
 7         response.writeHead(404, {'Content-Type': 'text/html'});
 8         response.write('404 Not Found!');
 9         response.end();
10     }
11 }
12 exports.route = route;

（3），创建“requestHandler.js”

 1 var querystring = require('querystring'),
 2     fs = require('fs'),
 3     formidable = require('formidable');
 4 
 5 function start (response, request) {
 6     console.log('start module');
 7 
 8   var body = '<html>'+
 9       '<head>'+
10       '<meta http-equiv="Content-Type" '+
11       'content="text/html; charset=UTF-8" />'+
12       '</head>'+
13       '<body>'+
14       '<form action="/upload" enctype="multipart/form-data" method="post">'+
15       '<input type="file" name="upload" multiple="multiple">'+
16       '<input type="submit" value="Submit text" />'+
17       '</form>'+
18       '</body>'+
19       '</html>';
20 
21     response.writeHead(200, {'Content-Type': 'text/html'});
22     response.write(body);
23     response.end();
24 }
25 
26 function upload (response, request) {
27     console.log('upload module');
28     var form = new formidable.IncomingForm();
29     form.parse(request, function (error, fields, files) {
30         fs.renameSync(files.upload.path, '/tmp/test.png');
31         response.writeHead(200, {'Content-Type': 'text/html'});
32         response.write('You\'ve sent: <br />');
33         response.write('<img src="/show" />');
34         response.end();
35     });
36 }
37 
38 function show (response, request) {
39     console.log('show module');
40     fs.readFile ('/tmp/test.png', 'binary', function (error, file) {
41         if (error) {
42             response.writeHead(200, {'Content-Type': 'text/html'});
43             response.write(error);
44             response.end();
45         } else {
46             response.writeHead(200, {'Content-Type': 'image/png'});
47             response.write(file, 'binary');
48             response.end();
49 
50         }
51     });
52 }
53 
54 exports.start = start;
55 exports.upload = upload;
56 exports.show= show;

（4），创建“index.js”

 1 var server = require('./server');
 2 var router = require('./router');
 3 var requestHandler = require('./requestHandler');
 4 var formidable = require('formidable'); // require路径搜索算法？？
 5 var handler = {};
 6 handler['/'] = requestHandler.start;
 7 handler['/start'] = requestHandler.start;
 8 handler['/upload'] = requestHandler.upload;
 9 handler['/show'] = requestHandler.show;
10 server.start(router.route, handler);

四，总结一下

（1），理解 "Fs与Stream之间的联系" 。

（2），熟练使用 "FS" 相关的api。

（3），注意细节的把控，好比：文件操做api同步方式与异步方式之间的处理细节。

（4），最后强调：理解文件上传例子中的代码组织方式，不断重构，不断总结。

　　　　　　　　　　 哈哈哈，本篇结束，未完待续，但愿和你们多多交流够沟通，共同进步。。。。。。呼呼呼……(*^__^*)