多进程

多进程

node 中提供了 cluster 模块来创建多进程应用，这样可以避免单一进程挂了导致服务异常的情况。框架是通过 think-cluster 模块来运行多进程模型的。

多进程配置

可以配置 workers 指定子进程的数量，默认为 0（当前 cpu 的个数）

//src/config/config.js
module.exports = {
  workers: 0 // 可以根据实际情况修改，0 为 cpu 的个数
}

多进程模型

多进程模型下，Master 进程会根据 workers 的大小 fork 对应数量的 Worker 进程，由 Woker 进程来处理用户的请求。当 Worker 进程异常时会通知 Master 进程 Fork 一个新的 Worker 进程，并让当前 Worker 不再接收用户的请求。

进程间通信

多个 Worker 进程之间有时候需要进行通信，交换一些数据。但 Worker 进程之间并不能直接通信，而是需要借助 Master 进程来中转。

框架提供 think.messenger 来处理进程之间的通信，目前有下面几种方法：

• think.messenger.broadcast 将消息广播到所有 Worker 进程 //监听事件 src/bootstrap/worker.js think.messenger.on('test', data => { //所有进程都会捕获到该事件，包含当前的进程 } // src/controller/xxx.js //发送广播事件 think.messenger.broadcast('test', data

注：consume 和 map 方法需要 think-cluster 的版本 >=1.4.0。

自定义进程通信

有时候内置的一些通信方式还不能满足所有的需求，这时候可以自定义进程通信。由于 Master 进程执行时调用 src/bootstrap/master.js，Worker 进程执行时调用 src/bootstrap/worker.js，那么处理进程通信就比较简单。

// src/bootstrap/master.js
const cluster = require('cluster'
cluster.on('message', (worker, message) => {
  // 接收到特定的消息进程处理
  if(message && message.act === 'xxx'){

  }
})

// src/bootstrap/worker.js
process.send{act: 'xxxx', ...args} //发送数据到 Master 进程

常见问题

子进程如何通知主进程重启服务？

有时候做一些通用的系统，需要有自动更新的功能（如：博客系统的更新功能），代码更新后，需要重启服务才能使其生效，如果每次都要手工重启服务必然不方便。框架提供了 think-cluster-reload-workers 指令让子进程可以通知主进程重启服务，这样就不用手工重启服务了。如：

async upgrade() {
  await downloadCodeFromRemote( // 从远程下载更新包
  await unzipCode( // 解压缩代码
  await installDependencies( // 重新安装依赖，可能有新的依赖
  process.send('think-cluster-reload-workers' // 给主进程发送重启的指令
}