如何从Node.js fs可读流中手动按需每次读取n行数据

要实现保持fs可读流打开状态、手动按需读取指定行数的需求，你可以借助Node.js的readline模块精准控制读取流程，避免自动持续读取的问题。以下是具体实现方案：

核心实现代码 #

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

// 创建文件可读流与readline接口，初始暂停自动读取
const rl = readline.createInterface({
  input: fs.createReadStream('target-file.txt'), // 替换为你的目标文件路径
  crlfDelay: Infinity, // 兼容所有换行符格式
  terminal: false
});
rl.pause(); // 初始状态暂停，避免自动读取

// 封装手动读取n行的函数
function readNLines(n) {
  return new Promise((resolve) => {
    const batch = [];
    let count = 0;

    // 监听行事件，收集数据
    const handleLine = (line) => {
      batch.push(line);
      count++;
      if (count >= n) {
        rl.removeListener('line', handleLine);
        rl.pause(); // 读完指定行数后暂停流
        resolve(batch);
      }
    };

    rl.on('line', handleLine);
    rl.resume(); // 触发本次读取
  });
}

// 使用示例
// 第一次读取5行
readNLines(5).then(lines => {
  console.log('读取的5行数据:', lines);
  // 模拟间隔一段时间后读取下一批
  setTimeout(() => {
    readNLines(3).then(nextLines => {
      console.log('读取的3行数据:', nextLines);
      // 不再需要时关闭流，释放资源
      rl.close();
    });
  }, 3000);
});

方案说明 #

• 初始化时调用rl.pause()让流处于暂停状态，不会自动触发读取。
• readNLines函数通过Promise封装读取逻辑：调用时恢复流，监听line事件收集指定行数，达到数量后立即暂停流并返回结果。
• 完全由你手动控制读取时机和每次读取的行数，流会保持打开状态直到你主动调用rl.close()。

注意事项 #

• 如果流已读取到文件末尾，调用readNLines会返回剩余的所有行（不足n行时返回实际剩余数量）。
• 不再使用流时务必调用rl.close()，避免文件描述符泄漏。

内容的提问来源于stack exchange，提问作者jiminssy