1const cluster = require('cluster');
2const http = require('http');
3const numCPUs = require('os').cpus().length;
4
5if (cluster.isMaster) {
6  console.log(`Master ${process.pid} is running`);
7
8  // Fork workers.
9  for (let i = 0; i < numCPUs; i++) {
10    cluster.fork();
11  }
12
13  cluster.on('exit', (worker, code, signal) => {
14    console.log(`worker ${worker.process.pid} died`);
15  });
16} else {
17  // Workers can share any TCP connection
18  // In this case it is an HTTP server
19  http.createServer((req, res) => {
20    res.writeHead(200);
21    res.end('hello world\n');
22  }).listen(8000);
23
24  console.log(`Worker ${process.pid} started`);
25}

1import http, { Server } from 'http'
2import cluster, { Worker } from 'cluster'
3import { cpus, CpuInfo } from 'os'
4import consola from 'consola'
5import chalk from 'chalk'
6import app from './src/app'
7
8const coreThread: CpuInfo[] = cpus()
9
10if (cluster.isMaster) {
11	for (let i = 0; i < coreThread.length; i++) {
12		cluster.fork()
13	}
14
15	const workersTread: any = []
16	for (const id in cluster.workers) {
17		workersTread.push(id)
18	}
19
20	workersTread.forEach(
21		async (pid: number, _: number): Promise<void> => {
22			await cluster.workers[pid].send({
23				from: 'isMaster',
24				type: 'SIGKILL',
25				message: 'cleanup is worker dead and change to new worker'
26			})
27		}
28	)
29
30	if (process.env.NODE_ENV !== 'production') {
31		cluster.on('online', (worker: Worker): void => {
32			if (worker.isConnected()) {
33				console.info(`${chalk.greenBright('worker active pid')}: ${worker.process.pid}`)
34			}
35		})
36
37		cluster.on('exit', (worker: Worker, code: number, signal: string): void => {
38			if (worker.isDead()) {
39				console.info(`${chalk.redBright('worker dead pid')}: ${worker.process.pid}`)
40			}
41			cluster.fork()
42		})
43	}
44} else {
45	const server = http.createServer(app) as Server
46	const host: any = process.env.HOST
47	const port: any = process.env.PORT
48	server.listen(port, host, (): void => consola.success(`server is running on ${port}`))
49}