节点读取流：流何时发生？

Question

这是一个代码示例，与您从网上或文档中获得的内容没有太大区别：

var fs = require('fs');
var r = fs.createReadStream(process.argv[2], { encoding: 'utf8' });
r.on('data', function (chunk) {
    console.log("chunk: >>>" + chunk + "<<<");
});
r.on('end', function () {
    console.log("This is the end");
});

让我感到困惑的是：触发事件的流式传输何时发生？显然不是直接在读取流的构造上，因为它会在我们到达ons 之前完成，并且永远不会执行事件监听代码（确实如此，这完美地工作）。

让我担心的是：如果on 呼叫来得太晚，理论上是否有可能错过某个事件？

Answer 1

想到这一点的最简单方法是，您提供的所有代码都是阻塞的，因此在当前滴答结束之前，流上不会发生任何活动，正如 vkurchatkin 所解释的那样。只有当当前刻度的 JavaScript 执行完成时，才能开始流 IO。

var fs = require('fs');
var r = fs.createReadStream(process.argv[2], { encoding: 'utf8' });
// Stream created in paused state, JS code is blocking IO

// We're still in the current tick so no IO could have occured since the above lines
r.on('data', function (chunk) {
  console.log("chunk: >>>" + chunk + "<<<");
});

// We're still in the current tick so no IO could have occured since the above lines
r.on('end', function () {
  console.log("This is the end");
});

// We've left the current tick so the internal IO code will now execute and call the bound events if necessary

Answer 2

答案是否定的，在节点 0.10.x 及更高版本中是不可能的。创建流时，它会暂停，因此data 和end 事件都不能发出。当您添加data 侦听器（但不是end 侦听器）时，流会自动恢复。

还值得一提的是，在当前“tick”结束之前不会发生 IO，因此如果您在同一个 tick 中附加 data 侦听器始终是安全的，即使对于早期的节点版本也是如此。例如：

stream.resume();
stream.on('data', ...); // <- same tick, same javascript invocation = safe

stream.resume();
setImmediate(function () {
  stream.on('data', ...); // <- different tick, different javascript invocation = unsafe
});

这听起来可能令人困惑，但在 process.nextTick 回调中添加监听器也是安全的，因为它实际上是在任何 IO 回调之前的 CURRENT 滴答之后立即调用的（命名非常糟糕的情况）。