我一直在尝试在使用Node.js时写入文件,但没有成功。我该怎么做?
当前回答
fs.createWriteStream(路径[,选项])选项还可以包括开始选项,以允许在文件开头之后的某个位置写入数据。修改文件而不是替换文件可能需要r+标志模式而不是默认模式w。编码可以是Buffer接受的任何一种。如果autoClose在“error”或“finish”时设置为true(默认行为),文件描述符将自动关闭。如果autoClose为false,则即使出现错误,也不会关闭文件描述符。应用程序负责关闭它并确保没有文件描述符泄漏。与ReadStream一样,如果指定了fd,WriteStream将忽略路径参数并使用指定的文件描述符。这意味着不会发出“打开”事件。fd应该是阻塞的;应将非阻塞fds传递给net.Socket。如果options是字符串,则它指定编码。
看完这篇长文。你应该了解它的工作原理。因此,这里有一个createWriteStream()的示例。
/* The fs.createWriteStream() returns an (WritableStream {aka} internal.Writeable) and we want the encoding as 'utf'-8 */
/* The WriteableStream has the method write() */
fs.createWriteStream('out.txt', 'utf-8')
.write('hello world');
其他回答
目前有三种方法可以写入文件:
fs.write(fd,缓冲区,偏移量,长度,位置,回调)您需要等待回调,以确保缓冲区已写入磁盘。它没有缓冲。fs.writeFile(文件名,数据,[编码],回调)所有数据必须同时存储;不能执行顺序写入。fs.createWriteStream(路径,[options])创建WriteStream,这很方便,因为您不需要等待回调。但同样,它没有缓冲。
顾名思义,WriteStream就是一个流。根据定义,流是包含沿一个方向移动的数据的“缓冲区”(源► 目的地)。但可写流不一定是“缓冲”的。当您写n次时,流被“缓冲”,在时间n+1,流将缓冲区发送到内核(因为它已满,需要刷新)。
换句话说:“缓冲区”就是对象。它是否“被缓冲”是该对象的一个属性。
如果查看代码,WriteStream继承自可写的Stream对象。如果你注意,你会看到他们是如何刷新内容的;他们没有任何缓冲系统。
如果你写一个字符串,它会被转换成一个缓冲区,然后被发送到原生层并写入磁盘。在编写字符串时,它们不会填充任何缓冲区。因此,如果您这样做:
write("a")
write("b")
write("c")
你在做:
fs.write(new Buffer("a"))
fs.write(new Buffer("b"))
fs.write(new Buffer("c"))
这是对I/O层的三次调用。虽然您使用的是“缓冲区”,但数据没有缓冲。缓冲流将执行:fs.write(new Buffer(“abc”)),一次对I/O层的调用。
截至目前,Node.js v0.12(2015年6月2日发布的稳定版本)现在支持两个功能:软木塞()和解开()。似乎这些函数最终将允许您缓冲/刷新写调用。
例如,在Java中,有一些类提供缓冲流(BufferedOutputStream、BufferedWriter…)。如果您写入三个字节,这些字节将存储在缓冲区(内存)中,而不是仅为三个字节执行I/O调用。当缓冲区已满时,内容将被刷新并保存到磁盘。这提高了性能。
我没有发现任何东西,只是记得应该如何进行磁盘访问。
好的,这很简单,因为Node有内置的功能,它叫做fs,代表文件系统,基本上,NodeJS文件系统模块。。。
因此,首先需要在server.js文件中使用它,如下所示:
var fs = require('fs');
fs有几种方法可以写入文件,但我的首选方法是使用appendFile,这将把内容附加到文件中,如果文件不存在,将创建一个,代码如下:
fs.appendFile('myFile.txt', 'Hi Ali!', function (err) {
if (err) throw err;
console.log('Thanks, It\'s saved to the file!');
});
var fs = require('fs');
fs.writeFile(path + "\\message.txt", "Hello", function(err){
if (err) throw err;
console.log("success");
});
例如:读取文件并写入另一个文件:
var fs = require('fs');
var path = process.cwd();
fs.readFile(path+"\\from.txt",function(err,data)
{
if(err)
console.log(err)
else
{
fs.writeFile(path+"\\to.text",function(erro){
if(erro)
console.log("error : "+erro);
else
console.log("success");
});
}
});
以下是如何从本地读取csv文件并将csv文件写入本地的示例。
var csvjson = require('csvjson'),
fs = require('fs'),
mongodb = require('mongodb'),
MongoClient = mongodb.MongoClient,
mongoDSN = 'mongodb://localhost:27017/test',
collection;
function uploadcsvModule(){
var data = fs.readFileSync( '/home/limitless/Downloads/orders_sample.csv', { encoding : 'utf8'});
var importOptions = {
delimiter : ',', // optional
quote : '"' // optional
},ExportOptions = {
delimiter : ",",
wrap : false
}
var myobj = csvjson.toSchemaObject(data, importOptions)
var exportArr = [], importArr = [];
myobj.forEach(d=>{
if(d.orderId==undefined || d.orderId=='') {
exportArr.push(d)
} else {
importArr.push(d)
}
})
var csv = csvjson.toCSV(exportArr, ExportOptions);
MongoClient.connect(mongoDSN, function(error, db) {
collection = db.collection("orders")
collection.insertMany(importArr, function(err,result){
fs.writeFile('/home/limitless/Downloads/orders_sample1.csv', csv, { encoding : 'utf8'});
db.close();
});
})
}
uploadcsvModule()
您可以使用库简易文件管理器
首先从npm安装npm安装简易文件管理器
上载和删除文件的示例
var filemanager = require('easy-file-manager')
var path = "/public"
var filename = "test.jpg"
var data; // buffered image
filemanager.upload(path,filename,data,function(err){
if (err) console.log(err);
});
filemanager.remove(path,"aa,filename,function(isSuccess){
if (err) console.log(err);
});