Node.js 中写入流上的多次写入

Question

我一直在查看节点脏的代码，注意到当将大量数据写入文件时，原始程序员选择将写入分成几个组，并一次发出一个组的写入，但是他们全部作为一个循环的一部分同时发出，无需等待任何回调。对此我有三个问题。我有类似的问题需要解决。

1. 这在某种程度上更有效吗？我也应该捆绑写入吗？
2. 我应该如何选择最佳的捆绑尺寸？为什么不只写一组呢？
3. 如果我在写入流上注册 on('drain') 事件，那么在所有同时发出的写入完成后，该事件是否只会发出一次？还是每次之后？ （我的猜测是前者）
4. 如果 on('error') 被发出，('drain') 事件也会被发出吗？或者它们是相互排斥的？

谢谢

Answer 1

这在某种程度上是否更有效？
我也应该捆绑写入吗？

进行许多小写入是低效的。发送写命令会产生开销。因此只写入 5 个字节而不是 1000 个字节会更昂贵。

我应该如何选择最佳的捆绑包
尺寸？为什么不只写一组呢？

最佳尺寸对我来说听起来像是一门黑魔法。我认为不把它写成一篇大文章是有充分理由的。可能要早一点开始写。早一点开始效率会更高一些。

如果我注册了 on('drain') 事件
在写入流上，它会被发出吗
全部同时进行后仅一次
发出的写入已完成？或者之后
每个？ （我的猜测是前者）

当写入队列中的所有内容都完成写入时，Drain 会触发。因此，只要您追加到写入队列的速度比写入队列的速度快，它就应该只触发一次。你需要一个非常好的系统来处理这样的边缘情况。

如果 on('error') 被发出，将会
('drain') 事件也会被发出吗？
或者它们是相互排斥的？

即使它被发出，在“drain”中进行错误处理也是没有意义的。如果发生错误，我总是假设整个写入操作已失败，并且不会尝试在写入过程中恢复。

Answer 2

对于4.如果 on('error') 被触发，('drain') 事件也会被触发吗？或者它们是相互排斥的？

您担心它，因为您不想在应用程序中正确维护状态。所以，也许你可以使用一个方便的函数：

function not_if(proc, veto_inner) {
  var vetoed = false;
  return {
    proc: function() {
      if (!vetoed) { return proc.apply(null, arguments); }
    }, 
    vetoer: function() {
      if (!vetoed) {
        vetoed = true;
        veto_inner.apply(null, arguments);
    }
  };
}

现在，你可以将“error”处理程序设置为 vetoer，将“drain”处理程序设置为“proc”，而不用担心在调用“error”之后调用“drain”。