nodejs操作文件和数据流

来源：cnblogs　　作者：爱敲代码的飞天猪li　　时间：2019/1/16 9:18:50　　对本文有异议

前言

　　node中有一组流api，它们可以像处理网络流一样处理文件。流api用起来非常方便，本节学习介绍文件处理基础和流的概念。

1 //提取路径组成部分2 var path=require('path');3 path.dirname('/foo/bar/dd/a1.txt');//获取文件路径的目录 => /foo/bar/dd4 path.basename('/foo/bar/dd/a1.txt');//获取文件名 => a1.txt5 path.basename('/foo/bar/dd/a1.txt','.txt');//获取不包含文件类型的文件名 => a16 path.extname('/foo/bar/dd/a1.txt','.txt');//获取文件扩展类型 =>.txt

1.5. 判断路径是否存在

使用path.exists()函数判断路径是否存在，0.8版本以后使用fs.exists()函数代替，只需将导入模块替换为fs即可。

1 //判断路径是否存在2 var path=require('path');3 path.exists('/foo/bar/dd',function(exists){4     console.log('是否存在：',exists);5 })

2. fs模块简介

fs核心模块内置查询文件信息和打开/读写/关闭文件操作

查询文件信息

使用fs.stat()函数查询文件特征，例如大小、创建时间、权限等

//查询文件信息var fs=require('fs');
fs.stat('/foo/bar/dd',function(stats){
    console.log(stats);//打印出文件信息stats.isFile();//判断是否文件stats.isDirectory();//判断是否目录stats.isSocket();//判断是否UNIX套接字//...});

打开/读写/关闭文件

 1 var fs=require('fs'); 2 //打开文件，‘r’表示模式类型 3 fs.open('/foo/bar/dd/a1.txt','r',function(err,fd){ 4     //获取文件描述符 fd 5 }); 6  7 //读取文件 8 fs.open('/foo/bar/dd/a1.txt','r',function(err,fd){ 9     if(err){10         throw err;11     }12     var readbuffer=new Buffer(1024),//设置缓冲区13         bufferOffset=0,14         filePosition=100,//从100字节开始15         bufferLength=readbuffer.length;//读取随后的1024字节数据;16         fs.read(fd,readbuffer,bufferOffset,bufferLength,filePosition,17             function (err, readBytes){18                 if(err){19                     throw err;20                 }21                 if(readBytes>0){22                     console.log(readbuffer.slice(0,readBytes));//获取读入缓冲区的字节数23                 }24             });25 });26 27 //写入文件28 fs.open('/foo/bar/dd/a1.txt','a',function(err,fd){29     if(err){30         throw err;31     }32     var writebuffer=new Buffer('准备写入缓冲区的数据'),//设置缓冲区33         bufferPosition=0,//写入起始位置34         filePosition=null,//从文件什么位置开始写 35         bufferLength=readbuffer.length;//长度36         fs.write(fd,writebuffer,bufferPosition,bufferLength,filePosition,37             function (err, write){38                 if(err){39                     throw err;40                 }41                 console.log('write bytes:',write);//获取读入缓冲区的字节数42             });43 });44 45 //关闭文件46 fs.open('/foo/bar/dd/a1.txt','a',function(err,fd){47     if(err){48         throw err;49     }50     //write...51     //close52     fs.close(fd,function(){53         //...54     })55 });

View Code

文件模式类型：

r——数据流的位置从起始处打开文件读取

r+——数据流的位置从起始处打开文件读写

w——如果文件存在则清零，不存在则创建文件并写入数据，数据流的位置从文件起始处

w+——打开文件进行读写，如果文件存在则清零，不存在则创建文件并写入数据，数据流的位置从文件起始处

a——打开文件写入数据，如果文件存在则清零，不存在则创建文件，数据流的位置从文件结尾处，写操作都将追加到文件后面

a+——打开文件读写数据，如果文件存在则清零，不存在则创建文件，数据流的位置从文件结尾处，写操作都将追加到文件后面

需要注意，在读写文件操作回调函数执行之后，不要使用提供的缓冲区，不然可能会导致读写数据不完整。

3. 操作流

流是由几个node对象实现的抽象概念，创建或读取流的方式取决于使用流的类型，流的特性包含可读流和可写流，通过监听data事件，在流每次提交数据时，都能够得到通知。

3.1. 创建文件系统流

 1 var fs=require('fs'); 2 //根据文件路径创建一个可读流 3 fs.createReadStream('/foo/bar/file'); 4  5 fs.open('/foo/bar/file','r',function(err,fd){ 6     fs.createReadStream(null,{fd:fd,encoding:'utf8'}); 7     fs.on('data',function(data){ 8         console.log('data:',data); 9     });10 });11 12 //创建可写流13 fs.createWriteStream('/foo/bar/file');14 15 fs.createWriteStream('/foo/bar/file',option);16 //option表示第二个参数，默认值为{flags:'w',encoding:null,mode:0666}

可以指定createReadStream和createWriteStream函数的第二个参数，用来设置文件的起始结束位置、编码格式等等，参数选项如下所示：

encoding——data事件发送的编码格式
fd——如果已经有一个打开文件描述符则可以传入该参数选项
bufferSize——要被读取的每个文件块大小，单位是字节，默认64kb
start——设置文件中第一个被读取的字节位置，用来限制读取数据范围
end——与start相反
flags——表示用于打开文件的模式类型
mode——指定要打开文件的权限

4. 慢客户端问题

当客户端的网络连接速度较慢时，可写流也就慢速，可读流会快速产生data事件并监听，数据被发送到可写流，导致node不得不缓存数据导致缓冲区被快速填满。

一般情况可以通过暂停数据生产者来避免这个问题：

 1 var http=require('http'); 2 var fs=require('fs'); 3 http.createServer(function(req,res){ 4     var rs= fs.createReadStream('/foo/bar/file'); 5  6     rs.on('data',function(data){ 7         if(!res.write(data)){ 8             rs.pause();//暂停可读流 9         }10     });11 12     rs.on('drain',function(){13         rs.resume();//恢复可读流14     });15 16     rs.on('end',function(){17         res.end();//结束操作18     });19 20 }).listen('8080');

View Code

扩展：使用pipe函数操作上述暂停/恢复操作

 1 var http=require('http'); 2 var fs=require('fs'); 3 http.createServer(function(req,res){ 4     var rs= fs.createReadStream('/foo/bar/file'); 5     rs.pipe(res);//由传输源调用并接受目标可写流作为参数 6 }).listen('8080'); 7  8 http.createServer(function(req,res){ 9     var rs= fs.createReadStream('/foo/bar/file');10     //默认情况下end()在可读流结束时在可写流上被调用，设置第二个参数end选项为false表示不让pipe函数进行end操作11     rs.pipe(res,{end:false});12 13     rs.on('end',function(){14         res.write('endend~~');15         res.end();//结束操作16     });17 }).listen('8080');