클러스터 모듈을 사용하여 Node.js 확장-JS 튜토리얼-php.cn

클러스터 모듈을 사용하여 Node.js 확장

DDD

풀어 주다： 2024-09-19 22:30:03

원래의

930명이 탐색했습니다.

Scaling Node.js with the Cluster Module

클러스터 모듈을 사용하면 Node.js가 멀티 코어 시스템을 활용하여 앱 성능을 향상할 수 있습니다. 효과적으로 사용하는 방법을 살펴보겠습니다.

왜 클러스터인가?

모든 CPU 코어 활용
앱 반응성 향상
인원 중복화를 통한 신뢰성 증대

기본 사용법

const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length;

if (cluster.isMaster) {
  console.log(`Master ${process.pid} is running`);

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

  cluster.on('exit', (worker, code, signal) => {
    console.log(`Worker ${worker.process.pid} died`);
  });
} else {
  // Workers can share any TCP connection
  http.createServer((req, res) => {
    res.writeHead(200);
    res.end('Hello World\n');
  }).listen(8000);

  console.log(`Worker ${process.pid} started`);
}

로그인 후 복사

로드 밸런싱

Node.js는 라운드 로빈 접근 방식을 사용하여 로드 밸런싱을 자동으로 처리합니다.

프로세스 간 통신(IPC)

if (cluster.isMaster) {
  const worker = cluster.fork();
  worker.send('Hi there');
} else {
  process.on('message', (msg) => {
    console.log('Message from master:', msg);
  });
}

로그인 후 복사

다운타임 없는 재시작

if (cluster.isMaster) {
  cluster.on('exit', (worker, code, signal) => {
    if (!worker.exitedAfterDisconnect) {
      console.log('Worker crashed. Starting a new worker');
      cluster.fork();
    }
  });

  process.on('SIGUSR2', () => {
    const workers = Object.values(cluster.workers);
    const restartWorker = (workerIndex) => {
      const worker = workers[workerIndex];
      if (!worker) return;

      worker.on('exit', () => {
        if (!worker.exitedAfterDisconnect) return;
        console.log(`Exited process ${worker.process.pid}`);
        cluster.fork().on('listening', () => {
          restartWorker(workerIndex + 1);
        });
      });

      worker.disconnect();
    };

    restartWorker(0);
  });
}

로그인 후 복사