Node.js中fs.createReadStream为何无法更新外部变量值

这是Node.js异步非阻塞执行模型的正常表现，和流本身的逻辑无关：

• fs.createReadStream创建读取流、绑定pipe、注册data/close事件监听的操作都是同步执行的，但这些动作仅完成了任务初始化和事件回调注册，不会阻塞后续同步代码运行，实际的文件读取、CSV解析、事件触发都属于异步任务，会被放到事件循环队列中等待当前所有同步代码执行完毕后才会启动。
• 你写在流逻辑外部的console.log(results)属于同步代码，执行时机早于所有流相关的异步回调：这时候流还没开始读取数据，data事件从未触发，数组没有被推入任何内容，打印结果自然是空数组。
• 等全部同步代码执行完成后，事件循环才会调度执行流的异步任务：逐块读取文件、解析CSV内容、触发data事件往数组写入数据，直到所有数据处理完毕触发close事件时，数组已经完成填充，所以回调内的打印可以拿到完整的5000行数据。

另外你代码里存在变量名笔误：声明的数组变量是result，打印时写的是results（多了末尾的s），实际运行会抛出未定义引用错误，需要修正。

• 所有依赖CSV读取结果的业务逻辑，统一放到流的end事件（流处理完成的标准事件，比close更语义化）回调中执行。
• 将流处理逻辑包装为Promise，结合async/await以更直观的同步写法获取结果，参考代码：

const fs = require('fs')
const csv = require('csv-parser') // 对应你使用的csv解析库

async function loadCsvData(filePath) {
  const result = []
  return new Promise((resolve, reject) => {
    fs.createReadStream(filePath)
      .pipe(csv())
      .on('data', (row) => result.push(row))
      .on('end', () => resolve(result))
      .on('error', (err) => reject(err))
  })
}

// 使用示例
const csvData = await loadCsvData('your/file/path.csv')
console.log(csvData) // 此处可拿到完整解析结果

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