Node.js 多进程:cluster、child_process 与 worker_threads 怎么选

import cluster from 'node:cluster'
import http from 'node:http'
import { availableParallelism } from 'node:os'

if (cluster.isPrimary) {
  // 主进程:按 CPU 核数 fork 出 worker
  const cpuCount = availableParallelism()
  console.log(`主进程启动,fork ${cpuCount} 个 worker`)

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

  // worker 意外退出就重启,保证服务不中断
  cluster.on('exit', (worker, code) => {
    console.log(`worker ${worker.process.pid} 退出(${code}),重启中`)
    cluster.fork()
  })
} else {
  // worker 进程:正常起 HTTP 服务,多个 worker 共享 3000 端口
  http
    .createServer((req, res) => {
      res.end(`处理者 PID: ${process.pid}`)
    })
    .listen(3000)
}

// ❌ 每个 worker 各有一份 loginAttempts,互相看不见
const loginAttempts = new Map()

app.post('/login', (req, res) => {
  // worker A 记的次数,worker B 根本不知道
  // 限流、计数器、session 全部失效
})

import { spawn, exec, execFile, fork } from 'node:child_process'

// spawn:流式输出,适合大量/持续的输出(如 ffmpeg、长任务)
const ls = spawn('ls', ['-lh', '/usr'])
ls.stdout.on('data', (data) => console.log(`输出: ${data}`))

// exec:把输出一次性 buffer 起来给你,简单但有大小上限(maxBuffer)
exec('cat *.log | wc -l', (err, stdout) => {
  console.log(`行数: ${stdout}`)
})

// fork:专门用来跑另一个 Node 脚本,自带 IPC 通道,父子能发消息
const child = fork('./worker-task.js')
child.send({ task: 'compute', payload: [1, 2, 3] })
child.on('message', (result) => console.log('子进程算完了:', result))

import { Worker, isMainThread, parentPort, workerData } from 'node:worker_threads'

if (isMainThread) {
  // 主线程:把繁重计算丢给工作线程,自己继续响应请求
  const worker = new Worker(new URL(import.meta.url), {
    workerData: { n: 42 },
  })
  worker.on('message', (result) => console.log('计算结果:', result))
} else {
  // 工作线程:闷头算,不阻塞主线程的事件循环
  const result = heavyFib(workerData.n)
  parentPort.postMessage(result)
}

# cluster 模式,按 CPU 核数起进程
pm2 start app.js -i max --name my-app

# 平滑重载,不中断在途请求
pm2 reload my-app

# 内存超过阈值自动重启(防内存泄漏拖垮机器)
pm2 start app.js --max-memory-restart 500M