動態創建並流式傳輸到客戶端

Question

我正在使用NodeJs（w/express），我試圖將zip文件流式傳輸回客戶端。包含在zip中的文件不在文件系統中，而是動態創建。我想將文件內容傳輸到壓縮文件並將壓縮文件傳輸回客戶端。

I.E.我想在客戶端接收：

tmp.zip 
--> 1.txt 
--> 2.txt 
--> 3.txt 

凡1,2,3.txt是動態創建和流式傳輸到zip文件。這可能嗎？

Answer 1

Archiver有一個附加方法，可讓您將文本保存爲文件。要將這些數據「流式傳輸」給用戶，您可以簡單地通過管道連接到HTTP響應對象。

var Http = require('http'); 
var Archiver = require('archiver'); 

Http.createServer(function (request, response) { 
    // Tell the browser that this is a zip file. 
    response.writeHead(200, { 
     'Content-Type': 'application/zip', 
     'Content-disposition': 'attachment; filename=myFile.zip' 
    }); 

    var zip = Archiver('zip'); 

    // Send the file to the page output. 
    zip.pipe(response); 

    // Create zip with some files. Two dynamic, one static. Put #2 in a sub folder. 
    zip.append('Some text to go in file 1.', { name: '1.txt' }) 
     .append('Some text to go in file 2. I go in a folder!', { name: 'somefolder/2.txt' }) 
     .file('staticFiles/3.txt', { name: '3.txt' }) 
     .finalize(); 

}).listen(process.env.PORT); 

這將創建一個帶有兩個文本文件的zip文件。訪問此頁面的用戶將看到文件下載提示。與

Answer 2

是的，這是可能的。我建議看看Streams Playground以瞭解節點流如何工作。

核心zlib庫中的zip壓縮似乎不支持多個文件。如果你想使用tar-gzip，你可以使用node-tar來解決問題。但如果你想要ZIP，adm-zip看起來是最好的選擇。另一種可能性是node-archiver。

更新：

這example展示瞭如何使用歸檔，支持流。只需將fs.createReadStream替換爲動態創建的數據流，並將output數據流傳輸至Express的res而不是fs.createWriteStream。

var fs = require('fs'); 

var archiver = require('archiver'); 

var output = fs.createWriteStream(__dirname + '/example-output.zip'); 
var archive = archiver('zip'); 

output.on('close', function() { 
    console.log('archiver has been finalized and the output file descriptor has closed.'); 
}); 

archive.on('error', function(err) { 
    throw err; 
}); 

archive.pipe(output); 

var file1 = __dirname + '/fixtures/file1.txt'; 
var file2 = __dirname + '/fixtures/file2.txt'; 

archive 
    .append(fs.createReadStream(file1), { name: 'file1.txt' }) 
    .append(fs.createReadStream(file2), { name: 'file2.txt' }); 

archive.finalize(function(err, bytes) { 
    if (err) { 
    throw err; 
    } 

    console.log(bytes + ' total bytes'); 
}); 

Answer 3

解決方案：express.js，wait.for，拉鍊流

app.get('/api/box/:box/:key/download', function (req, res) { 

    var wait = require('wait.for'); 

    var items = wait.for(function (next) { 
     BoxItem.find({box: req.Box}).exec(next) 
    }); 

    res.set('Content-Type', 'application/zip'); 
    res.set('Content-Disposition', 'attachment; filename=' + req.Box.id + '.zip'); 

    var ZipStream = require('zip-stream'); 
    var zip = new ZipStream(); 

    zip.on('error', function (err) { 
     throw err; 
    }); 

    zip.pipe(res); 

    items.forEach(function (item) { 

     wait.for(function (next) { 

      var path = storage.getItemPath(req.Box, item); 
      var source = require('fs').createReadStream(path); 

      zip.entry(source, { name: item.name }, next); 
     }) 

    }); 

    zip.finalize(); 

});