Node.js `Stream` 和块顺序

Question

Node.js streams 的顺序是否保留到并包括 'data' 事件？我相信它们是，this question 似乎也暗示至少 pipe 方法是连续的。

我希望保留块顺序，以便我可以在流结束之前调用一个对每个块进行操作的函数，即在读取流的一部分时，我希望缓冲的数据块由'data' 事件中的函数。

但是，当我运行以下代码时，我使用 Math.random 和 setTimeout 专门测试事件是否按顺序发生：

fs.createReadStream(filePath, { encoding: 'ascii' })
  .pipe(streamToEntry)
  .on('data', (chunk) => {
    setTimeout(() => { 
      console.log(chunk); 
    }, Math.random() * 1000)
  });

数据块可以乱序记录。

这是因为setTimeout() 还是因为'data' 事件不一定按顺序调用？即，应该只在pipe 方法中进行有序处理，还是我可以在最后按顺序处理数据？

Answer 1

您的data 事件保证按顺序发出。请参阅this answer 了解更多详细信息以及来自 node 源代码的一些 sn-ps，这表明您确实会按顺序获得您的 data 事件。

当您在data 回调中添加异步代码时会出现问题（setTimeout 是异步代码的一个示例）。在这种情况下，您的 data 回调不能保证按照它们被调用的顺序完成处理。

您需要做的是确保在您的data 回调返回时，您已经完全处理了您的数据。换句话说，您的回调代码需要是同步代码。

fs.createReadStream(filePath, { encoding: 'ascii' })
  .pipe(streamToEntry)
  .on('data', (chunk) => {
      // only synchronous code here
      console.log(chunk); 
  });

要使问题代码起作用，可以使用async/await：

fs.createReadStream(filePath, { encoding: 'ascii' })
  .pipe(streamToEntry)
  .on('data', async (chunk) => {
      // only synchronous code here
      await setTimeout(() => console.log(chunk), Math.random() * 1000); 
  });