2

我做了以下，玩了一下node.js。文件夹 zipfiles 中的文件被相应地压缩，一切似乎都正常。但是我在 cmd 上遇到错误，我不知道它来自哪里或如何解决它。

events.js:72
        throw er; // Unhandled 'error' event
              ^
Error: write after end
    at writeAfterEnd (_stream_writable.js:130:12)
    at Gzip.Writable.write (_stream_writable.js:178:5)
    at write (_stream_readable.js:583:24)
    at flow (_stream_readable.js:592:7)
    at ReadStream.pipeOnReadable (_stream_readable.js:624:5)
    at ReadStream.EventEmitter.emit (events.js:92:17)
    at emitReadable_ (_stream_readable.js:408:10)
    at emitReadable (_stream_readable.js:404:5)
    at readableAddChunk (_stream_readable.js:165:9)
    at ReadStream.Readable.push (_stream_readable.js:127:10)

这是我的脚本：

var zlib = require('zlib');
var gzip = zlib.createGzip();
var fs = require('fs');
var zip = {
    zipAll: function(dir){  
        //files to zip
        fs.readdir(dir, function(err, data){
            if(err) throw(err);
            var arrayValue = data.toString().split(',');

            //files with .gz at the end, needs to be excluded
                for(var i=0; i<arrayValue.length; i+=1){
                    console.log("Zipping following files: " + arrayValue[i]);
                    var input = fs.createReadStream('zipfiles/' + arrayValue[i]);
                    var output = fs.createWriteStream('zipfiles/input'+[i]+'.txt'+'.gz');
                    input.pipe(gzip).pipe(output);                  
                } 
        });
    }
};
zip.zipAll('zipfiles');

谢谢

4

1 回答 1

2

Gzip 对象对于多个文件的重用有点不稳定（afaik 未记录）。解决问题的最简单方法是对gzip每个文件使用单独的对象进行压缩，例如；

for(var i=0; i<arrayValue.length; i+=1){
    console.log("Zipping following files: " + arrayValue[i]);
    var input = fs.createReadStream('zipfiles/' + arrayValue[i]);
    var output = fs.createWriteStream('zipfiles/input'+[i]+'.txt'+'.gz');
    input.pipe(zlib.createGzip()).pipe(output);                  
}
于 2013-08-29T19:14:04.793 回答