Nodejs Stream结束后不更新文件答案

【问题标题】：Nodejs Stream doesn't update file after endNodejs Stream结束后不更新文件
【发布时间】：2016-06-17 10:14:20
【问题描述】：

我正在尝试使用流式传输将小文件合并到一个文件中。在我写入数据并调用streamWrite.end()后，文件大小仍然为0。当程序运行完成时，文件将被我写入的数据填充。

我的问题是：为什么我调用 writeStream.end() 后文件大小为 0 以及如何解决这个问题？

这是完整的代码

var fs = require('fs');

function createRandomJsonFiles(destPath,numOfFiles,minFileSize)
{
    for(var i=0;i<numOfFiles;i++){
        var tmp = {};
        tmp.k1 =  new Array(Math.floor(Math.random() * minFileSize) + minFileSize ).join( 'a' );
        fs.writeFileSync(destPath+'/testfile.'+i, JSON.stringify(tmp));
    }
}

createRandomJsonFiles("./testFiles/",1000,100); // create some files

var streamWrite  = fs.createWriteStream('write.tst');

var files = fs.readdirSync("./testFiles/");
for (var i = 0; i < files.length; ++i) { // merge the files to one file
    var inputPath = "./testFiles/" + files[i];
    var file_data = fs.readFileSync(inputPath).toString();
    var canContinue =  streamWrite.write(file_data); // write the chunk to the file system and close the stream
    if (!canContinue){
        streamWrite.emit('drain');
    }
}
streamWrite.end();
var chunkContent = fs.readFileSync('write.tst').toString();
console.log(chunkContent);

【问题讨论】：

这个解决方案没有帮助：stackoverflow.com/questions/18932488/…

标签： node.js

【解决方案1】：

问题在于end() 是异步的。考虑以下我用来测试的代码。

var fs = require("fs");

var stream1 = fs.createWriteStream("a");
stream1.write("hello");
stream1.end();
console.log(fs.readFileSync("a").toString());

var stream2 = fs.createWriteStream("b");
stream2.write("hello");
stream2.end(function() {
    console.log(fs.readFileSync("b").toString());
});

第一次不会打印，但第二次会打印hello。您应该将代码的最后 3 行更改为

streamWrite.end(function() {
    var chunkContent = fs.readFileSync('write.tst').toString();
    console.log(chunkContent);
});

【讨论】：