Node 集群部署

Question

进程间通信和 WebWorker 类似，使用主从模式来处理，主进程负责分配和调度任务，工作进程负责处理任务。

master.js 文件

const fork = require('child_process').fork;
const cpus = require('os').cpus();
const http = require('http')

const list = []
for (let i = 0; i < cpus.length; i++) {
  const child = fork('./worker.js')
  list.push(child)
}

const server = http.createServer((req, res) => {
  res.end('handle by parent')
})

server.listen(8080, () => {
  list.forEach(child => {
    child.send('server', server)
  })
  server.close()
})

worker.js 文件

const http = require('http')
const process = require('process')

const server = http.createServer(
  (req, res) => {
    res.writeHead(200, {
      'Content-Type': 'text/plain',
    })
    res.end(`handle by child ${process.pid}`)
  }
)


process.on('message', (m, tcp) => {
  if (m === 'server') {
    // 建立新的 TCP 流时会触发此事件
    tcp.on('connection', socket => {
      // 让工作进程去处理连接请求
      server.emit('connection', socket)
    })
  }
})