高并发调度系统设计

事件类型

实例状态

查询

注册

notifyExecutorGenerateWaittingLog

主队列扩容业务

操作日志表

启动校验请求事件

暂停结果事件

启动校验请求事件处理器

备份队列扩容业务

执行结果事件

channel双向通信

暂停成功

实现

获取key

netty server

实例恢复结果事件处理器

实例触发事件

实例表

接收

消费

触发实例

待删除队列

外部缓存

外部缓存key赋值抽象

执行中

队列消费抽象

启动校验结果事件处理器

生成

netty client

1. 心跳（HART_BEAT）2. 实例触发请求（INSTANCE_TRIGGER_REQUEST）3. 实例触发结果（INSTANCE_TRIGGER_RESPONCE）4. 实例启动检查请求（INSTANCE_START_VERIFY_REQUEST）5. 实例启动检查结果（INSTANCE_START_VERIFY_RESPONCE）6. 实例执行器排队中（INSTANCE_EXE_BLOCKING）7. 取消队列排队请求（INSTANCE_CANCEL_BLOCKING_REQUEST）8. 取消队列排队请求结果（INSTANCE_CANCEL_BLOCKING_RESPONCE）9. 实例运行中（INSTANCE_RUNNING）10. 实例结束事件（INSTANCE_RESPONCE）11. 直接杀死实例执行（INSTANCE_STRICT_KILL_REQUEST）12. 通知杀死实例执行（INSTANCE_NOTIFY_KILL_REQUEST）13. 杀死实例结果（INSTANCE_KILL_RESPONCE）14. 暂停实例执行请求（INSTANCE_PAUSE_REQUEST）15. 暂停实例执行请求结果（INSTANCE_PAUSE_RESPONCE）16. 恢复实例执行请求（INSTANCE_RESUME_REQUEST）17. 恢复实例执行结果（INSTANCE_RESUME_RESPONCE）18. 实例操作日志回调事件（INSTANCE_OPT_LOGS_REQUEST）

事件生成业务

监控与预警

消费业务

通知杀死事件

事件处理器注册

1. 启动校验中2. 启动校验成功3. 启动校验失败

取消执行失败

恢复实例事件

反射调用注册的扩容方法

客户端通道管理器

创建与注册

实例暂停请求事件处理器

db

推送

杀死结果事件

备份队列

消费业务抽象

暂停实例事件

队列管理器

执行状态状态

客户端事件处理器

实例通知杀死结果事件处理器

1. 等待执行2. 执行中3. 执行失败4. 执行成功5. 超时杀死成功6. 超时杀死失败

执行结果异步推送模块

批量插入

execute()

客户端消息处理器

启动校验结果事件

生成数据

客户端推送业务

推送实例状态

执行

发送

1. 正在取消执行2. 取消执行成功3. 取消执行失败4. 停止中5. 停止成功6. 停止失败7. 暂停中8. 暂停成功9. 暂停失败10. 恢复中11. 恢复成功12. 恢复失败

待删除队列扩容业务

实例暂停结果事件处理器

暂停中

主队列数据恢复业务

主队列

触发

实例直接杀死请求事件处理器

调度执行器相关业务模块

实例操作日志同步事件处理器

启动校验状态

实例触发请求事件处理器

深拷贝

异步批量

分发消息

队列备份与删除抽象

删除队列消费业务

缓存对象

执行成功

外部缓存key赋值

服务端事件处理器

直接杀死事件

服务端通道管理器

调用

实例执行服务

停止中

手动操作状态

等待执行

扩容

业务对象

没删除的重新写入

执行失败

实例执行结果事件处理器

获取并注册

触发状态

备份队列消费业务

启动校验成功

执行事件

暂停失败

触发失败

超时杀死成功

操作日志同步事件

notifyExecutorUpdateLogStatus

暂停实例

取消执行成功

停止失败

服务端事件管理器

触发成功

启动校验请求

超时杀死失败

取消执行

待触发

删除

删除返回被删除的元素

停止实例

服务端消息处理器

停止成功

实例恢复请求事件处理器

恢复实例

1. 待触发2. 触发成功3. 触发失败

客户端事件管理器

调度系统相关业务模块

...

IJobHandler

服务端推送业务

取消执行中

推送待删除数据

实例状态管理模块

实例杀死结果事件处理器

启动校验失败