日期: 2021/12/14 天气：晴

    1. 'use strict';
    3. const cluster = require('cluster');
    4. const app = require('../app');
    5. const debug = require('debug')('pay-api:server');
    6. const http = require('http');
    8. // 可用CPU数量
    9. const workers = require('os').cpus().length;
    11. let server;
    13. const Application = {
    14.   start: function () {
    15.     if (cluster.isMaster) {
    16.       // 启动集群
    17.       for (let i = 0; i < workers; i++) {
    18.         cluster.fork();
    19.       }
    21.       cluster.on('listening', function (worker, address) {
    22.         console.log(`listening: worker ${worker.process.pid} ${address.port}`);
    23.       });
    25.       cluster.on('exit', function (worker, code, signal) {
    26.         console.log('worker %s died, restarting...', worker.process.pid);
    27.         cluster.fork();
    28.       });
    30.     } else {
    31.       // 启动线程
    33.       // 设置端口
    34.       let port = normalizePort(process.env.PORT || '3000');
    35.       app.set('port', port);
    37.       // 创建服务器
    38.       server = http.createServer(app);
    40.       // 监听端口
    41.       server.listen(port);
    42.       server.on('error', onError);
    43.       server.on('listening', onListening);
    45.     }
    46.   }
    47. };
    50. /**
    51.  *  序列化端口号
    52.  */
    54. function normalizePort (val) {
    55.   let port = parseInt(val, 10);
    57.   if (isNaN(port)) {
    58.     // named pipe
    59.     return val;
    60.   }
    62.   if (port >= 0) {
    63.     // port number
    64.     return port;
    65.   }
    67.   return false;
    68. }
    70. /**
    71.  *  错误处理
    72.  */
    74. function onError (error) {
    75.   if (error.syscall !== 'listen') {
    76.     throw error;
    77.   }
    78.   let bind = typeof port === 'string'
    79.     ? 'Pipe ' + port
    80.     : 'Port ' + port;
    82.   // handle specific listen errors with friendly messages
    83.   switch (error.code) {
    84.     case 'EACCES':
    85.       console.error(bind + ' requires elevated privileges');
    86.       process.exit(1);
    87.       break;
    88.     case 'EADDRINUSE':
    89.       console.error(bind + ' is already in use');
    90.       process.exit(1);
    91.       break;
    92.     default:
    93.       throw error;
    94.   }
    95. }
    97. /**
    98.  *  监听服务
    99.  */
    101. function onListening () {
    102.   let addr = server.address();
    103.   let bind = typeof addr === 'string'
    104.     ? 'pipe ' + addr
    105.     : 'port ' + addr.port;
    106.   debug('Listening on ' + bind);
    107. }
    109. Application.start();