同步逐行读取文件流

Question

我正在查看 nodejs readline 模块文档的任务，我必须逐行读取一个非常大的文件，它看起来不错。但是对于我的特定任务，我需要它来同步读取行，即。无论如何，不​​能在第 4 行之前读取第 5 行，并且由于节点的性质，我只想确认此代码对于该用法是否安全 -

const readline = require('readline');
const fs = require('fs');

const rl = readline.createInterface({
  input: fs.createReadStream('sample.txt')
});

rl.on('line', (line) => {
  console.log(`Line from file: ${line}`);
});

如果没有，我应该使用/做什么？目前它对我有用，但我不知道它是否适用于大行，下一行的解析速度比前一行等快。

Answer 1

我非常怀疑稍后触发的回调是否可能比另一个回调更早执行。 基本上是指event loop和进程的栈。

不过，为了保证我可以建议实现类似于 async/queue 的东西，但能够动态推送回调。

假设你会有这样的东西：

const Queue = require('./my-queue')
const queue = new Queue()

function addLineToQueue(line) {
  queue.push(function() {
    // do some job with line
    console.log(`Line: "${line}" was successfully processed!`)
  })
}

您将修改您的代码：

rl.on('line', (line) => {
  addLineToQueue(line)
  console.log(`Added line to queue: ${line}`)
})

并确保您的队列实现应该从它有任何要执行的任务开始。这样回调的顺序将得到保证。但对我来说，它看起来有点开销。