cluster模块实现多进程-让我的代理服务速度飞起来了

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‘)
});