index.ts

import { initLog } from './utils/log';

require('dotenv').config();
require('elastic-apm-node').start({
  serverUrl: process.env['apm.serverUrl'],
  serviceName: process.env['apm.serviceName'],
  environment: process.env['apm.environment'],
  transactionSampleRate: parseInt(
    process.env['apm.transactionSampleRate'] || '1',
  ),
});
import 'heapdump';
import cluster from 'node:cluster';
import { Config } from './utils/config';
import { initCache } from './utils/cache';

process.setMaxListeners(1000); // 将限制提高到20个
initLog();
Config.load();
Config.watchFile();
initCache();

if (cluster.isPrimary) {
  console.log(`Master ${process.pid} is running`);
  const workers = +(process.env.WORKERS || 1);

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

  cluster.on('exit', (worker, code, signal) => {
    console.log(`worker ${worker.process.pid} died,sig: ${signal}`);
    console.log('Forking a new process...');
    cluster.fork(); // Fork a new process if a worker dies
  });
} else {
  require('./router').registerApp();
}
process.on('uncaughtException', (err) => {
  console.error('Uncaught exception:', err);
  setTimeout(() => process.exit(1), 5000); // It's up to you whether to exit here or not
});
process.on('unhandledRejection', (reason, promise) => {
  console.error('Unhandled rejection at ', promise, `reason: ${reason}`);
  setTimeout(() => process.exit(1), 5000); // It's up to you whether to exit here or not
});