集群化定时器框架架构图
2024-05-09 23:24:22 0 举报
该架构图展示了一个集群化消息服务的系统设计。核心内容包括:消息生产者、消息队列、消息消费者以及监控管理系统。消息生产者负责创建并发送消息,消息队列作为缓冲存储设备,存储并转发消息,消息消费者从队列中获取并处理消息。此外,监控管理系统负责监控整个系统的运行状况,确保消息服务的可靠性和高效性。整个系统采用集群化设计,提高了服务的可扩展性和容错性,以满足大规模、高并发的消息处理需求。
作者其他创作
大纲/内容
执行器推送消息时会随机选择一个调度中心服务,并且带标识名称发送,调度中心验证成功后进行消费操作
执行器执行消息完成,将成功推送消息到RabbitMq,调度中心监听消息并且执行对应的业务逻辑
调度中心支持创建任务启动任务修改任务执行任务停止任务删除任务
执行器服务
RabbitMq
MySQL
Redis
执行器支持启动任务回调修改任务回调执行任务回调停止任务回调删除任务回调故障转移错误消息回调
调度中心发起任务创建或者变更,推送消息到RabbitMq,调度中心监听消息并且执行对应的逻辑
调度中心推送消息时会随机选择一个执行器服务,并且带标识名称发送,执行器验证成功后进行消费操作
执行器心跳定时器(每5秒执行一次)在执行过程中会剔除失活的执行器,并且将失活执行器上的任务转移到正常的执行器上
调度中心服务
调度中心心跳定时器(每5秒执行一次)在执行过程中会剔除失活的调度中心
redis存储执行器注册表、调度中心注册表、执行器心跳(过期时间为7秒)、调度中心新心跳(过期时间为7秒)
0 条评论
下一页