如何解决尝试写入新文件之前,无法完成文件的读取和处理与承诺有关的
真的挣扎在这里和刚刚失去了在这一点上。除非我尝试使用SEEM,否则它很简单。我提供的简化代码不包含使事情简单的承诺。在放弃几个月后,我又回到了这一点。这个小脚本逐行读取目录中的文件,并将所有这些行添加到数组中。一旦结束,我想将所有这些文件写入新文件。
当然,问题是在allTheLines数组中充满了从目录文件读取的行之前,将调用writeallLinesToFile。该数组完全为空,读取文件中的任何内容均未写入新文件中。
我对此进行了很多尝试,并且在这种尝试中弄乱了我的真实代码。有人可以把我推过来吗?
var allTheLines = [];
function processFile(inputFile) {
var fs = require('fs');
var readline = require('readline');
var instream = fs.createReadStream(inputFile);
var outstream = new (require('stream'))();
var rl = readline.createInterface(instream,outstream);
// when you get a line,do this
rl.on('line',function (line) {
// console.log("pushing: ",line);
allTheLines.push(line);
});
// when there are no more lines do this
rl.on('close',function (line) {
console.log('...end of a file');
});
}
function writeallLinesToFile() {
var fs = require('fs');
for (var i = 0; i < allTheLines.length; i++) {
console.log("line: : ",allTheLines[i]);
fs.appendFile('./allTheLines.html',allTheLines[i] + '\n',function (err) {
if (err) throw err;
});
};
console.log("Done writing.");
}
// ***************************************
// Execution Starts Here
// ***************************************
var fs = require('fs');
fs.readdir('./filesToRead',(err,files) => {
for (var i = 0; i < files.length; i++) {
processFile('./filesToRead/' + files[i]);
console.log('file#: ',i);
};
console.log('Done processing files.');
writeallLinesToFile();
});
解决方法
这是我对此的快速解决方案,您可以从这里获取并对其进行改进,以使其适合您的需求。
我相信您忘记的最重要的事情是,当我们使用事件发射器时,我们应该知道它们是异步代码而不是同步的,这就是为什么 writeAllLinesToFile 具有空数组的原因,因为它以前被调用过 rl.on('line',....)已经完成了工作,要赶上它很棘手;)
希望这将帮助您了解Promises的工作原理,并始终仔细考虑异步代码。
var fs = require('fs');
var readline = require('readline');
var path = require('path');
var stream = require('stream');
function processFile(inputFile) {
var instream = fs.createReadStream(inputFile);
var outstream = new stream();
var rl = readline.createInterface(instream,outstream);
var allTheLines = [];
// when you get a line,do this
rl.on('line',function (line) {
allTheLines.push(line);
}).on('close',function () {
writeAllLinesToFile(allTheLines);
});
}
function writeAllLinesToFile(lines) {
for (var i = 0; i < lines.length; i++) {
fs.appendFile(path.join(__dirname,'allTheLines.html'),lines[i] + '\n',function (err) {
if (err) throw err;
});
};
console.log("Done writing.");
}
// ***************************************
// Execution Starts Here
// ***************************************
fs.readdir(path.join(__dirname,'filesToRead'),(err,files) => {
if (err) throw err;
for (var i = 0; i < files.length; i++) {
processFile(path.join(__dirname,'filesToRead',files[i]));
};
console.log('Done processing files.');
});
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。