如何在Node.js中一次将一个可读流传输到两个可写流中？

Question

目标是：

1. 创建文件读取流。
2. 用管道将其压缩到gzip（zlib.createGzip()）
3. 然后将zlib输出的读取流通过管道传输到：

1）HTTP response对象

2） 和 可写文件流，以保存压缩后的输出。

现在我可以降到3.1了：

var gzip = zlib.createGzip(),
    sourceFileStream = fs.createReadStream(sourceFilePath),
    targetFileStream = fs.createWriteStream(targetFilePath);

response.setHeader('Content-Encoding', 'gzip');

sourceFileStream.pipe(gzip).pipe(response);

…效果很好，但是我还需要 将压缩后的数据保存到文件中， 这样我就不需要每次都进行zip压缩，并且能够直接将压缩后的数据作为响应流化。

那么，如何在Node中一次将一个可读流传送到两个可写流中？

将sourceFileStream.pipe(gzip).pipe(response).pipe(targetFileStream);在节点0.8.4工作？

Answer 1

我发现zlib返回了一个可读流，该流随后可通过管道传递到多个其他流中。因此，我执行以下操作来解决上述问题：

var sourceFileStream = fs.createReadStream(sourceFile);
// Even though we could chain like
// sourceFileStream.pipe(zlib.createGzip()).pipe(response);
// we need a stream with a gzipped data to pipe to two
// other streams.
var gzip = sourceFileStream.pipe(zlib.createGzip());

// This will pipe the gzipped data to response object
// and automatically close the response object.
gzip.pipe(response);

// Then I can pipe the gzipped data to a file.
gzip.pipe(fs.createWriteStream(targetFilePath));