javascript - Node.js动态扩展管道流

我想对node.js系统进行基准测试。

因此，我创建了一个小程序，可以加密和压缩文件（我希望该应用程序占用大量CPU资源）。我认为重复多次加密过程是有意义的。但是，每当我动态传输流时，程序都会在完成之前退出。有没有办法我可以等到流完成？

我的代码如下所示：

            var readStream = fstream.Reader(sourcePath);
            var writeStream = fs.createWriteStream(sourcePath + '.tar.gz');

            var stream = readStream.on('error', function (e) {
                    handleError(e, errorMessageReadFile);
                })
                .pipe(tar.Pack()).on('error', function (e) {
                    handleError(e, errorMessageTarPack);
                });

            for (i = 0; i < algorithmCount; i++) {
                stream = stream.pipe(encryptStream).on('error', function (e) {
                    handleError(e, errorMessageEncrypt);
                });
                console.log("enc");
            }

            stream.pipe(gzip).on('error', function (e) {
                    handleError(e, errorMessageCompress);
                })
                .pipe(writeStream).on('error', function (e) {
                    handleError(e, errorMessageWriteFile);
                })
                .on('finish', function () {
                    console.log('done');
                });

最佳答案

这可能是一个问题：

for (i = 0; i < algorithmCount; i++) {
    stream = stream.pipe(encryptStream);
}

记住那个.pipe returns the stream you're piping into。换句话说：stream.pipe(encryptStream)返回encryptStream。第一次迭代就很好：stream最初是tar.Pack()流，因此可以通过管道传输到encryptStream中。但是，第二次迭代将把现在等于stream的encryptStream传递给自身。

您可能想为每次迭代创建一个新的中间加密流，例如就像是：

for (i = 0; i < algorithmCount; i++) {
    stream = stream.pipe(createEncryptStream());
}

关于javascript - Node.js动态扩展管道流，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/38624252/