它们之间有什么区别。溪流上的管道

Question

我发现了两种不同的方法来在节点中对流进行管道处理。js

众所周知的流的方法

https://nodejs.org/api/stream.html#stream_readable_pipe_destination_options

和流的独立功能

https://nodejs.org/api/stream.html#stream_stream_pipeline_streams_callback

我应该使用哪一种？这两者之间有什么好处？

Answer 1

pipeline是pipe的改进版本，它从节点开始添加到流模块中。JSV10

此外，管道接受任意数量的参数，最后一个参数是回调，用于知道管道何时结束或抛出错误。

使用管道：

mySourceStream.pipe(myStream).pipe(anotherStream)

使用管道：

mySourceStream.pipeline(myStream, anotherStream, err => {
  if (err) {
    console.log('There is an error')
  } else {
    console.log('pipeline successful')
  }
})

Answer 2

根据文件，他们都做同样的事情。但也有一些不同之处：

• . tube（）是Readable的方法，而管道是接受流到管道的stream的模块方法。
• 管道（）方法在管道完成时提供回调。
• 管道（）方法是自节点的10个版本以来添加的，而。

在我看来，使用pipeline（）。

示例。管道（）：

const fs = require('fs');
const r = fs.createReadStream('file.txt');
const z = zlib.createGzip();
const w = fs.createWriteStream('file.txt.gz');
r.pipe(z).pipe(w);

管道（）的示例：

const { pipeline } = require('stream');
const fs = require('fs');
const zlib = require('zlib');

pipeline(
  fs.createReadStream('archive.tar'),
  zlib.createGzip(),
  fs.createWriteStream('archive.tar.gz'),
  (err) => {
    if (err) {
      console.error('Pipeline failed.', err);
    } else {
      console.log('Pipeline succeeded.');
    }
  }
);

Answer 3

TL； DR-你最好使用管道

什么是管道？

来自文档：一种模块方法，用于在流之间传递错误并正确清理，并在管道完成时提供回调。

使用管道的动机是什么？

❌ 让我们看看下面的代码：

const { createReadStream } = require('fs');
const { createServer } = require('http');
const server = createServer(
  (req, res) => {
    createReadStream(__filename).pipe(res);
  }
);

server.listen(3000);

这里怎么了？如果响应将退出或客户端关闭连接，则读取流不会关闭或销毁，从而导致内存泄漏。

✅因此，如果您使用管道，它将关闭所有其他流，并确保没有内存泄漏。

const { createReadStream } = require('fs');
const { createServer } = require('http');
const { pipeline } = require('stream');

const server = createServer(
  (req, res) => {
    pipeline(
      createReadStream(__filename),
      res,
      err => {
        if (err)
          console.error('Pipeline failed.', err);
        else
          console.log('Pipeline succeeded.');
      }
    );
  }
);

server.listen(3000);