事件驱动与非阻塞 I/O 模型

Node.js 的底层架构就像一个「一人指挥，千人协作」的高效团队，其核心秘密就是事件驱动与非阻塞 I/O。它让一个进程能够高效地处理海量并发任务。以 V8 引擎（执行 JavaScript 代码）和 libuv 库（处理底层 I/O 与事件循环）为两大基石。

核心概念

• 事件驱动：这是一种程序设计范式，程序的执行流程由外部事件（如用户请求、文件读取完成）来决定。Node.js 启动后，会初始化一个事件循环，并注册各类事件的回调函数。
• 非阻塞 I/O：传统 I/O 操作（如读取文件、查询数据库）会「阻塞」线程，直到操作完成才能执行后续代码。Node.js 中的所有 I/O 操作（网络请求、文件读写等）都是非阻塞的，发起操作后立即返回，不会等待结果，避免主线程被「卡住」。

一、libuv：Node.js 的「动力核心」

Node.js 看似单线程，但底层依赖 libuv 提供强大的多线程支持。libuv 使用线程池来处理无法异步执行的任务（如文件 I/O、DNS 查找）。线程池默认大小为 4，可通过 UV_THREADPOOL_SIZE 环境变量调整。除文件 I/O 外，Node.js 将 CPU 密集型任务（加密、压缩、DNS 解析）也委托给 libuv 线程池，防止阻塞主线程。

# 调整 libuv 线程池大小（需在进程启动前设置）
UV_THREADPOOL_SIZE=8 node server.js

// 演示：文件 I/O 走线程池，彼此并行，不阻塞主线程
const fs = require("fs");

console.log("开始读取文件");
fs.readFile("./big-file-1.txt", () => console.log("文件1读完"));
fs.readFile("./big-file-2.txt", () => console.log("文件2读完"));
console.log("已发起两个读取请求，主线程继续执行其他代码");

二、事件循环：非阻塞 I/O 的「调度中心」

Node.js 中，用户编写的所有 JavaScript 回调函数都运行在单一线程上，这个线程就是事件循环自身。事件循环使其执行完一个简单任务后不用干等耗时 I/O，而是通过多个阶段来调度任务。它按顺序执行 timers、pending callbacks、idle/prepare、poll、check、close callbacks。特别关键的 poll 阶段会检索新的 I/O 事件，并执行 I/O 相关回调。

setTimeout(() => console.log("timer"), 0);
setImmediate(() => console.log("immediate"));

fs.readFile(__filename, () => {
  // 在 I/O 回调内部，setImmediate 一定先于 setTimeout 执行（顺序更确定）
  setTimeout(() => console.log("inner timer"), 0);
  setImmediate(() => console.log("inner immediate"));
});

微任务（process.nextTick / Promise） 会在每个阶段之间被清空执行，process.nextTick 的优先级高于 Promise 的 .then 回调：

process.nextTick(() => console.log("nextTick"));
Promise.resolve().then(() => console.log("promise"));
console.log("同步代码");
// 输出顺序：同步代码 → nextTick → promise

三、「单线程」与「多线程」的真相：并发 vs 并行

理解 Node.js 如何处理并发，关键要分清并发（同时处理多件事）和并行（同时做多件事）。Node.js 利用其单线程事件循环模型处理请求，实现高并发。这种设计避免了多线程编程中的死锁、资源竞争等问题，极大简化了并发编程的复杂性。

CPU 密集型任务（如同步的大循环计算）不会被自动分流到线程池，会直接阻塞事件循环，此时应显式使用 Worker Threads：

// worker.js
const { parentPort, workerData } = require("worker_threads");
parentPort.postMessage(heavyCompute(workerData));

// main.js
const { Worker } = require("worker_threads");
const worker = new Worker("./worker.js", { workerData: input });
worker.on("message", (result) => console.log("计算结果", result));

四、EventEmitter：事件驱动编程的基础 API

Node.js 大量内置模块（http.Server、fs.ReadStream、net.Socket）都继承自 EventEmitter，也可以自己实现基于事件的模块：

const { EventEmitter } = require("events");

class OrderService extends EventEmitter {
  createOrder(order) {
    // 业务逻辑完成后发出事件，通知所有关心「订单创建」的模块
    this.emit("order:created", order);
  }
}

const orders = new OrderService();

orders.on("order:created", (order) => {
  console.log("发送下单通知", order.id);
});
orders.once("order:created", (order) => {
  console.log("只统计一次首单事件", order.id); // once：只触发一次后自动移除监听
});

orders.createOrder({ id: "1001" });

• on：注册持续监听；once：只监听一次；off/removeListener：移除监听，避免内存泄漏。
• 默认单个事件最多 10 个监听器，超过会打印警告，可通过 emitter.setMaxListeners(n) 调整（提示可能存在监听器泄漏）。
• 建议为错误事件统一监听 'error'，否则未处理的 error 事件会直接抛出并可能导致进程崩溃。

orders.on("error", (err) => console.error("订单服务出错：", err));

五、总结：Node.js 架构的多线程协作模型

最佳实践

• CPU 密集型逻辑（图片处理、加密、复杂计算）迁移到 Worker Threads 或独立进程，避免阻塞事件循环导致所有请求延迟。
• 自定义 EventEmitter 子类务必监听 'error' 事件，防止未捕获错误使进程崩溃。
• 大量文件/网络 I/O 场景下，根据实测适当调整 UV_THREADPOOL_SIZE（默认 4 常成为高并发文件读写的瓶颈）。
• 用 async/await + Promise 包装回调式 API（util.promisify），减少深层回调嵌套，同时不改变其非阻塞本质。
• 排查性能问题时用 --prof、clinic.js 等工具分析事件循环阻塞点，而非凭感觉猜测。

常见坑

延伸阅读

• 事件循环 event-loop：更细粒度的阶段与微任务时序
• Bun / Deno / Node 对比：不同运行时的事件模型差异
• 核心模块 · stream：基于事件的流式处理

参考文献

以下链接在编写时均可正常访问：