开始学习节点群集获取错误

Question

   const cluster = require('cluster');
    const http = require('http');
    const numCPUs = 4;

    if (cluster.isMaster) {
      // Fork workers.
      for (var i = 0; i < numCPUs; i++) {
        cluster.fork();
      }
       cluster.on('online', function(worker) {
            console.log('Worker ' + worker.process.pid + ' is online');
        });

      cluster.on('exit', (worker, code, signal) => {
        console.log(`worker ${worker.process.pid} died`);
      });

    } else {
      // Workers can share any TCP connection
      // In this case it is an HTTP server
      http.createServer((req, res) => {
        res.writeHead(200);
        res.end('hello world\n');
      }).listen(8000);
    }

工人11056是在线工人11057是在线工人11058是在线工人11059是在线事件。JS:141抛ER；//未处理的“错误”事件^

错误：在object.exports._errnoException(util.js:870:11)在exports._exceptionWithHostPort(util.js:893:20)在cb(net.js:1302:16)在rr(cluster.js:594:14)在worker处绑定EADDRINUSE null:8000。(cluster.js:564:9)在进程中。(cluster.js:714:8)在emitTwo（events.js:92:20)在process.emit（events.js:172:7)在handleMessage(internal/child_process.js:689:10)在pipe.channel.onread(internal/child_process.js:440:11)events.js:141 throw er；//未处理的“错误”事件^

错误：在object.exports._errnoException(util.js:870:11)在exports._exceptionWithHostPort(util.js:893:20)在cb(net.js:1302:16)在rr(cluster.js:594:14)在worker处绑定EADDRINUSE null:8000。(cluster.js:564:9)在进程中。(cluster.js:714:8)在emitTwo（events.js:92:20)在process.emit（events.js:172:7)在handleMessage(internal/child_process.js:689:10)在pipe.channel.onread(internal/child_process.js:440:11)events.js:141 throw er；//未处理的“错误”事件^

错误：在object.exports._errnoException(util.js:870:11)在exports._exceptionWithHostPort(util.js:893:20)在cb(net.js:1302:16)在rr(cluster.js:594:14)在worker处绑定EADDRINUSE null:8000。(cluster.js:564:9)在进程中。(cluster.js:714:8)在emitTwo（events.js:92:20)在process.emit（events.js:172:7)在handleMessage(internal/child_process.js:689:10)在pipe.channel.onread(internal/child_process.js:440:11)

Answer 1

您是否在项目的其他地方启动服务器？

尝试将新的辅助创建拆分到一个单独的文件中。

Worker.JS

import express from 'express';
  http.createServer((req, res) => {
    res.writeHead(200);
    res.end('hello world\n');
  }).listen(8000);

const cluster = require('cluster');
const http = require('http');
const numCPUs = 4;

cluster.setupMaster({
  exec: __dirname + '/worker.js'
});

if (cluster.isMaster) {
  // Fork workers.
  for (var i = 0; i < numCPUs; i++) {
     cluster.fork();
  }
  cluster.on('online', function(worker) {
     console.log('Worker ' + worker.process.pid + ' is online');
   });

  cluster.on('exit', (worker, code, signal) => {
    console.log(`worker ${worker.process.pid} died`);
   });
   return 1;
}