如何构建延迟任务调度系统（三）：架构设计

功能设计

系统功能 ：
延迟任务调度系统整合了统一的任务操作接口，并为各业务方向用户提供便捷的服务入口。各业务方向可基于此接口发起任务申请、取消当前运行中的任务以及查看当前的任务运行状态等操作功能。
调度服务作为底层应用体系的重要组成部分，在设计之初便采用了基于消息队列（MQ）的技术实现解耦机制，并将所有触发的延迟任务通过消息的形式发送至相应的消费节点。系统将所有触发的延迟任务通过消息的形式发送至相应的消费节点，并由消费节点根据策略进行流量管理。
为了确保服务端节点在服务重启后能够快速恢复在线状态，在整个系统的架构设计过程中特别注重了对服务端节点容灾能力的预留与保障措施的设计与实现。

采用技术 ：elastic-job + db + delayQueue + mq

整体架构

业务调用方

• 当需要执行延迟任务时, 业务方会向延迟任务服务发起请求来处理相关操作。
• 当延迟任务被触发时, 系统会将其自动推送至MQ消息队列中, 并由相关业务方进行消费。
• 在消息处理完成之后, 业务方会通过延迟任务服务反馈相应的处理结果。