- 简述
- 简单层级关系
- 路由(Router)
- 内置对象
- 配置(Config)
- 中间件(MiddleWare)
- 插件(Plugins)
- 常用对象关系模型(egg-sequelize)
- Worker和Agent
- 定时任务
前言
Worker 作为 Egg 中应用的一个具体实例，有效的解决了 nodejs 应用对 CPU 利用率不足的问题。在生产环境中，每一个 APP 都相当于是一个 Worker，他的表现大致如下：
image
Master（进程守护）
在这个多进程模型中，角色们都在履行着自己的职责。其中，Master 作为一个BOSS，主要负责启动或重启其他进程，以及负责进程之间的数据交互。
这样的设计结构中，我们创建了一组进程集群（cluster），并且共用一个端口号，由 Master 捕获请求参数，通过一定的负载均衡规则分发给被选中的 Worker，由 Worker 进行详细的业务处理。不过这里还有一个问题：每一个进程开启了一个web服务，那么进程端口号不会冲突吗？
在使用 node.js 的 cluster 模块 fork 子进程时，它会保证当前需要的端口仅由master进程内部的TCP服务器监听一次，而在创建子进程的过程中，重复监听的方法就会被干掉，因此也不会引发端口占用等问题。
而当某一个 Worker 在遇到未捕获的异常需要挂掉时，Master 则会首先再 fork 一个子进程，以保证运行过程中的 Worker 总数不变。然后待之前发生异常的 Worker 处理完当前手中的事务时，让其安心的成佛。
Agent （代理进程）
在这个多进程模型中，还可能产生这样一个问题：假设当前应用中有一个模块，需要每30分钟获取一次来自第三方接口的天气数据。对于集群中的所有应用而言，这样的数据实际上获取一次作为缓存即可，但在实际应用中，数据请求的次数却是 1n (worker进程数) 次。
我们能发现，在业务处理的过程中，会有一些依赖于每一个独立请求的业务处理过程，然而，也存在着一些并非强依赖某一个请求的业务。于是，Egg 提供了一个专门用于处理公共事务的独立进程——Agent*，来处理此类业务：
image
进程启动顺序：
- Master 启动后先 fork Agent 进程；
- Agent 初始化成功后，通过 IPC 通道通知 Master；
- Master 再 fork 多个 App Worker；
- App Worker 初始化成功，通知 Master；
- 所有的进程初始化成功后，Master 通知 Agent 和 Worker 应用启动成功；
自定义 Agent
我们可以在项目的根目录下创建自己的 agent.ts ，来实现自己的 Agent 逻辑：
// agent.ts
export default (agent) => {
// 在这里写初始化逻辑
// ...
// 也可以通过 messenger 对象发送消息给 App Worker
// 但需要等待 App Worker 启动成功后才能发送，不然很可能丢失
agent.messenger.on('egg-ready', () => {
const data = { ... };
agent.messenger.sendToApp('xxx_action', data);
});
};
而在项目根目录中的 app.ts 中，我们可以以监听事件的方式，接收 触发事件者 发送的参数：
// agent.ts
export default (app) => {
app.messenger.on('xxx_action', data => {
// worker 进程中监听消息传达事件并进行处理
});
};
进程之间通讯
进程之间的通讯主要分为以下几种：
- Master -> Worker/Agent
- Worker -> Agent
- Agent -> Worker
- Worker -> Other Worker
发送消息
| API | 描述 |
|---|---|
| app.messenger.broadcast(action, data) | 发送给所有的 agent / app 进程（包括自己） |
| app.messenger.sendToApp(action, data) | 发送给所有的 app 进程 - 在 app 上调用该方法会发送给自己和其他的 app 进程 - 在 agent 上调用该方法会发送给所有的 app 进程 |
| app.messenger.sendToAgent(action, data) | 发送给 agent 进程 - 在 app 上调用该方法会发送给 agent 进程 - 在 agent 上调用该方法会发送给 agent 自己 |
| agent.messenger.sendRandom(action, data) | - app 上没有该方法（现在 Egg 的实现是等同于 sentToAgent） - agent 会随机发送消息给一个 app 进程（由 master 来控制发送给谁） |
| app.messenger.sendTo(pid, action, data) | 发送给指定进程 |
接收消息
| API | 描述 |
|---|---|
| app.messenger.on(action, callback) | 注册相应事件监听器 |
| app.messenger.once(action, callback) | 只注册一次相应事件监听器 |
这是官方的一个 IPC + 定时任务 完成的示例：https://eggjs.org/zh-cn/core/cluster-and-ipc.html#ipc-实战
网友评论