Node.js中readline异步读大文件如何同步解析返回全局结果

你拿不到结果的核心原因非常直接：readline的流式读取是异步非阻塞逻辑，你在函数里初始化数组、创建readline实例后如果直接同步返回，此时行读取流程还在后台执行，line/close事件完全没触发，数组自然还没完成填充；返回的Promise一直处于pending状态，本质是你没有在close事件（即所有行读取完成的节点）把填充好的结果数组resolve出去。
JS/TS 中不存在同步获取异步IO结果的黑科技，你不需要强行"把值从回调作用域掏到全局"，只要用Promise把异步流程封装规范，调用方用原生await语法就能拿到最终结果，完全满足全局使用的需求。

实现时注意几个要点：

• 解析结果数组存在函数作用域内，不要挂全局变量，避免多次调用、并发解析时的状态污染
• 所有流式逻辑包裹在Promise中，逐行处理逻辑写在line事件回调里，读取完成在close事件中resolve结果
• 必须加error事件监听，文件不存在、权限不足时及时reject，避免Promise永久pending
• 配置crlfDelay: Infinity兼容Windows/macOS/Linux不同系统的换行符格式，避免行内容解析错乱

import * as fs from 'node:fs';
import * as readline from 'node:readline';

/**
 * 流式逐行解析GEO gds格式文本文件
 * @param filePath 待解析文件的绝对/相对路径
 * @returns 逐行处理完成后的结果数组
 */
export async function streamParseGEOgds(filePath: string): Promise<string[]> {
  const parseResult: string[] = [];
  // 适配你提到的"首尾空行作为分隔标识"的解析规则
  let isInValidSegment = false;

  const rl = readline.createInterface({
    input: fs.createReadStream(filePath, { encoding: 'utf8' }),
    crlfDelay: Infinity
  });

  return new Promise((resolve, reject) => {
    // 逐行处理逻辑，替换成你实际的.replace等处理规则即可
    rl.on('line', (rawLine) => {
      const trimmedLine = rawLine.trim();
      // 空行切换有效段标记
      if (trimmedLine === '') {
        isInValidSegment = !isInValidSegment;
        return;
      }
      if (!isInValidSegment) return;

      // 示例文本处理：将多个连续空白替换为制表符，替换为你的实际逻辑
      const processedLine = trimmedLine.replace(/\s+/g, '\t');
      parseResult.push(processedLine);
    });

    // 所有行读取完成，返回结果
    rl.on('close', () => {
      resolve(parseResult);
    });

    // 读取异常直接抛出错误
    rl.on('error', (err) => {
      reject(err);
    });
  });
}

只要你的Node.js版本在14.8以上，配合正确的TS配置，直接用顶层await就可以在模块全局作用域拿到解析完成的数组，不需要嵌套回调：

// 模块顶层直接await，拿到的结果就是全局可用的
const globalGeoResult = await streamParseGEOgds('./your-sample.gds');

// 后续所有逻辑直接使用globalGeoResult即可
console.log('解析完成，总条目数：', globalGeoResult.length);

如果你的项目暂时不支持顶层await，也可以用.then()包裹依赖解析结果的逻辑：

streamParseGEOgds('./your-sample.gds')
  .then((globalGeoResult) => {
    // 所有依赖解析结果的逻辑写在这里
    console.log(globalGeoResult);
  })
  .catch((err) => {
    console.error('GEO文件解析失败：', err);
  });

如果要使用顶层await，确保tsconfig.json中做如下配置，避免编译报错：

{
  "compilerOptions": {
    "target": "ES2022",
    "module": "NodeNext",
    "moduleResolution": "NodeNext"
  }
}

• 不要为了拿结果把解析数组挂到globalThis或者模块顶层变量：多次调用解析函数、并发解析多个文件时会出现结果互相覆盖的问题，完全无法复用
• 不要为了拿结果改用fs.readFileSync同步读取全量文件：大文件会直接占满进程内存，完全丢失流式读取低内存占用的优势
• 不要强行写轮询判断数组长度的逻辑来"等结果"：用Promise+await是JS原生处理异步流程的标准方案，轮询只会浪费性能、引入时序bug

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