如何正确应对Node.js管道中的错误事件？

Question

我在努力理解错误处理是如何在Node.js流管道内工作的，最后我用一个简单的游乐场进行了实验，这让事情变得非常清楚。

我将此作为一个自我回答的问题发布。也许有人觉得这很有帮助：）

Answer 1

让我们创建三个连接到管道中的命名直通流，并观察各个事件。

var stream = require('stream');

function observedStream(name) {
  var s = new stream.PassThrough({objectMode: true});

  s.on('error', function(err) { console.log(name + ': ' + err); });
  s.on('data', function(data) { console.log(name + ': ' + data); });
  s.on('finish', function() { console.log(name + ': FINISH'); });
  s.on('end', function() { console.log(name + ': END'); });
  s.on('close', function() { console.log(name + ': CLOSE'); });
  s.on('unpipe', function() { console.log(name + ': UNPIPE'); });

  return s;
}

var s1 = observedStream('S1'),
    s2 = observedStream('S2'),
    s3 = observedStream('S3');

s1.pipe(s2).pipe(s3);

写入管道是很简单的。我们只需从每个strem获取一个数据事件。

s1.write('Hello');
// S1: Hello
// S2: Hello
// S3: Hello

让我们看看当我们结束流时会发生什么？那里也没有惊喜。

s1.end();
// S1: FINISH
// S1: END
// S2: FINISH
// S2: UNPIPE
// S2: END
// S3: FINISH
// S3: UNPIPE
// S3: END

让我们尝试发出一个错误（显然，如果调用上面的s1.end（），则需要首先重新创建管道）。

s1.emit('error', new Error('bazinga'));
// S1: Error: bazinga

注意这里没有发生其他事情。你可以继续给S1写信，就像什么都没发生一样。管道没有关闭。

事情变得更有趣，当有一个错误"中流"：）

s2.emit('error', new Error('bazinga'));
// S2: UNPIPE
// S2: ERROR

请注意该节点。js自动将S1流从S2中取消管道连接，但不执行其他操作。即，S1流仍然等待有人读取其数据，S2流仍然通过管道传输到S3，并且可以（理论上）发送数据。

这是您需要在代码中处理的事情！一个选项是在S1和S2上调用end（）方法。另一种方法是使用pipe（）方法重新连接S1和S2。这两种方法似乎都有效，但这取决于您的特定使用场景。

1. 本·纳德尔博客上的这篇文章给我指明了正确的方向。
2. 这个SO问题从一个稍微不同的角度解决了一个类似的问题。答案中也有一些好的建议。