var cluster = require('cluster');

var http = require('http');

var numCPUs = require('os').cpus().length;

if (cluster.isMaster) {

  console.log('[master] ' + "start master...");

  for (var i = 0; i < numCPUs; i++) {

     cluster.fork();

  }

  cluster.on('listening', function (worker, address) {

    console.log('[master] ' + 'listening: worker' + worker.id + ',pid:' + worker.process.pid + ', Address:' + address.address + ":" + address.port);

  });

} else if (cluster.isWorker) {

   console.log('[worker] ' + "start worker ..." + cluster.worker.id);

  var num = 0;

  http.createServer(function (req, res) {

    num++;

    console.log('worker'+cluster.worker.id+":"+num);

    res.end('worker'+cluster.worker.id+',PID:'+process.pid);

  }).listen(3000);

}

var cluster = require('cluster');

var numCPUs = require('os').cpus().length;

if (cluster.isMaster) {

  console.log('[master] ' + "start master...");

  for (var i = 0; i < numCPUs; i++) {

     cluster.fork();

  }

  cluster.on('listening', function (worker, address) {

    console.log('[master] ' + 'listening: worker' + worker.id + ',pid:' + worker.process.pid + ', Address:' + address.address + ":" + address.port);

  });

} else if (cluster.isWorker) {

  require('app.js');

}

//app.js就是开启具体的业务逻辑了

//app.js具体内容

const net = require('net');

//自动创建socket

const server = net.createServer(function(socket) { //'connection' listener

  socket.on('end', function() {

    console.log('server disconnected');

  });

  socket.on('data', function() {

    socket.end('hello\r\n');

  });

});

//开启端口的监听

server.listen(8124, function() { //'listening' listener

  console.log('working')

});