Node.js 性能：集群模式与负载均衡

为什么需要集群模式

Node.js 采用单线程模型，这意味着默认情况下你的应用只能利用 CPU 的一个核心。当服务器拥有 8 核、16 核甚至更多核心时，剩余的计算资源只能闲置，白白浪费。

单线程的另一个隐患是稳定性。一旦某个未捕获的异常导致进程崩溃，整个应用将完全不可用。对于需要高可用的生产环境来说，这是无法接受的。

集群模式正是为解决这两个问题而生：它允许你创建多个 Worker 进程，将负载均匀分摊到所有 CPU 核心上，同时通过进程守护实现故障自愈。

使用原生 cluster 模块

Node.js 内置的 cluster 模块提供了创建多进程集群的能力。以下是一个完整的集群示例：

const cluster = require('cluster');
const os = require('os');

// 获取 CPU 核心数
const numCPUs = os.cpus().length;

// 判断当前是否是主进程
if (cluster.isMaster) {
    console.log(`主进程 ${process.pid} 正在启动`);

    // 根据 CPU 核心数创建 Worker 进程
    for (let i = 0; i < numCPUs; i++) {
        cluster.fork();
    }

    // 监听 Worker 进程退出事件，自动重启
    cluster.on('exit', (worker, code, signal) => {
        console.log(`Worker ${worker.process.pid} 已退出，正在重启...`);
        cluster.fork();
    });
} else {
    // Worker 进程运行实际的业务逻辑
    require('./app');
}

在这个示例中，主进程负责管理所有 Worker 进程，而每个 Worker 进程都独立运行完整的应用实例。当某个 Worker 意外退出时，主进程会立即创建一个新的进程来替补，从而保证服务不中断。

负载均衡策略详解

集群模式下，负载如何在多个 Worker 之间分配，直接决定了整体性能表现。Node.js 提供了两种负载均衡策略，适用场景截然不同。

轮询策略（Round-Robin）

这是默认策略，主进程按顺序将新连接依次分配给各个 Worker。在连接分布均匀、每个请求处理时间相近的场景下表现优异。但如果某些请求耗时特别长（比如文件上传、数据库查询），轮询可能导致某些 Worker 负载过高而其他 Worker 空闲。

const cluster = require('cluster');
const os = require('os');

if (cluster.isMaster) {
    const numCPUs = os.cpus().length;

    // 启用轮询策略（默认行为）
    cluster.schedulingPolicy = cluster.SCHED_RR;

    for (let i = 0; i < numCPUs; i++) {
        cluster.fork();
    }
}

抢占式策略（None）

关闭自动轮询，由操作系统调度器决定将连接分配给哪个 Worker。Linux 内核使用完整的公平调度算法（ CFS），会根据各进程的负载情况动态分配。这种方式在单个请求处理时间差异极大的场景下表现更好，但对短连接场景可能不如轮询高效。

// 切换到抢占式调度
cluster.schedulingPolicy = cluster.SCHED_NONE;

使用 PM2 简化集群管理

手动管理集群需要编写大量样板代码，且缺乏进程监控、日志管理等生产环境必需的功能。PM2 是一个专为 Node.js 设计的进程管理器，它将集群模式的使用简化到了极致。

基础用法

启动集群模式只需一条命令：

pm2 start app.js -i 0

-i 0 参数表示根据 CPU 核心数自动创建对应数量的 Worker 进程。你也可以指定具体数字，如 -i 4 表示创建 4 个进程。

常用管理命令

查看所有进程状态：

pm2 list

查看实时日志：

pm2 logs

重启所有 Worker：

pm2 restart all

零停机重载（平滑重启）：

pm2 reload all

配置文件方式

对于复杂项目，推荐使用配置文件定义集群行为：

{
  "name": "my-app",
  "script": "app.js",
  "instances": "max",
  "exec_mode": "cluster",
  "env": {
    "NODE_ENV": "development"
  },
  "env_production": {
    "NODE_ENV": "production"
  }
}

instances: "max" 会自动匹配 CPU 核心数，exec_mode: "cluster" 明确指定使用集群模式启动。

Nginx 作为负载均衡器

在生产环境中，更常见的架构是使用 Nginx 作为前端负载均衡器，后端运行多个 Node.js 实例。这种方式的优势在于 Nginx 具备更强的负载均衡算法、更丰富的健康检查机制，以及成熟的静态文件处理能力。

Nginx 配置示例

upstream node_cluster {
    least_conn;                    # 最少连接算法
    server 127.0.0.1:3000 weight=5;
    server 127.0.0.1:3001 weight=3;
    server 127.0.0.1:3002 weight=2;
    keepalive 64;                  # 保持连接池
}

server {
    listen 80;
    server_name example.com;

    location / {
        proxy_pass http://node_cluster;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection 'upgrade';
        proxy_set_header Host $host;
        proxy_cache_bypass $http_upgrade;
    }
}
```

`least_conn` 算法会将请求发送给当前连接数最少的 Worker，适合请求处理时间不均匀的场景。`keepalive` 参数让 Nginx 与后端保持长连接，避免频繁建立 TCP 连接的开销。

---

## 最佳实践建议

**合理设置 Worker 数量**。Worker 数量并非越多越好，通常设置为 CPU 核心数的 1-2 倍即可。过少的进程无法充分利用硬件资源，过多的进程则会增加上下文切换开销，反而降低性能。

**使用进程间通信实现状态同步**。各 Worker 进程内存独立，如果需要共享状态（如缓存、计数器），必须通过 `cluster` 模块的 IPC 机制或外部存储（如 Redis）来实现。

**为每个 Worker 配置独立的日志**。所有 Worker 共享同一个 stdout 会导致日志混杂，难以排查问题。建议在 Worker 内部自行管理日志文件路径。

**开启进程守护和监控**。无论是使用原生 cluster 模块还是 PM2，都要确保异常退出的 Worker 能被自动重启。配合性能监控工具（如 PM2 Plus、Clinic.js）持续观察各进程的负载情况。

**考虑无状态设计**。最理想的架构是将所有状态外置（存入数据库或缓存），让 Worker 本身完全无状态。这样任何 Worker 都能处理任何请求，极大简化故障转移和负载迁移的实现。

---

## 性能对比参考

| 方案 | 适用场景 | 优点 | 缺点 |
| :--- | :--- | :--- | :--- |
| 单进程 | 开发环境、流量极小 | 调试简单、资源占用低 | 无法利用多核、易单点故障 |
| 原生 cluster | 需要轻量级集群、无额外依赖 | 无需额外工具、代码可控 | 功能有限、缺少监控 |
| PM2 集群 | 追求快速部署、需要监控 | 上手简单、功能丰富 | 额外依赖、少量资源开销 |
| Nginx + 多实例 | 高流量生产环境 | 灵活可控、静态文件处理强 | 配置复杂、需要维护 Nginx |

---

## 完整示例：生产级集群配置

```javascript
// app.js
const http = require('http');
const process = require('process');

const server = http.createServer((req, res) => {
    // 模拟异步处理
    setTimeout(() => {
        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({
            pid: process.pid,
            timestamp: Date.now()
        }));
    }, Math.random() * 100);
});

const PORT = process.env.PORT || 3000;
server.listen(PORT, () => {
    console.log(`Worker ${process.pid} 正在监听端口 ${PORT}`);
});

# 使用 PM2 启动
pm2 start app.js -i max --name "node-api" --log-date-format "YYYY-MM-DD HH:mm:ss"

# 设置环境变量
pm2 start app.js -i max --env production

通过以上配置，你的 Node.js 应用将能够充分利用服务器的多核计算能力，在高并发场景下保持稳定的响应速度。