cluster.js

import cluster from "cluster"
import http from "http"
import { cpus } from "os"
import process from "process"
import { setupMaster } from "@socket.io/sticky"
import { start } from "./index.js"

const WORKERS_COUNT = 10

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

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

  cluster.on("exit", (worker) => {
    console.log(`Worker ${worker.process.pid} died!`)
    cluster.fork()
  })

  const httpServer = http.createServer()
  setupMaster(httpServer, {
    loadBalancingMethod: "least-connection", // random, robin-robin
  })

  const PORT = process.env.PORT || 4000

  httpServer.listen(PORT, () => {
    console.log(`Server listening at port${PORT}`)
  })
} else {
  console.log(`Worker ${process.pid} started`)
  start()
}