任务调度者
1.根据我们方案开启之后设置的源时间做为触发的规则
2.生产任务不是生调度事件产请求任务而是调度任务
3.生产任务的时候设置的源时间做为触发有缓冲,而且这里所以转达的任务都是最简单的我们几点几分需要去执行什么调度
4.调度任务池里面就是所有通知的内容
实例化适配器执行
1.有没有配置原平台调度前置条件
2.通过控制反转创建任务对应的适配器对象,执行适配器调度方法
适配器调度周期
1.给我们平台的变量选择器里面的动态值进行赋值
2.根据我们前台所配置的字段,然后转换成请求参数
3.根据么mongodb里面的原队列存储器向原队列里面写入了一条数据,同时也获取了一个任务ID
4.根据我们的任务ID生成请求任务
实例化适配器执行
1.执行我的一个个任务
2.根据任务id去找到我的任务
3.将请求参数返回给适配器对应的SDK
触发事件加工厂
1.判断是否存在加工厂
适配器处理响应-success
1.判断请求是否成功
2.确定我们所需要的数据Key
3遍历数据对象
4.将队列状态修改为已完成,若返回的数据不为空将进行翻页继续查询
适配器处理任务错误
请求失败则进入到异常搜集器
总结
平台可以分成三部分或者说是有三个事务,
总结:总的可以说我们平台可以分成三部分或者说看成三个事务
第一个事务:通知我们需要去调度
第二个事务:具体去执行调度的方法
第三个事务:执行一个个的请求任务
这三个事务不是依赖关系 不会说因为哪个事务没有执行而导致其他的事务不执行这三个事务分别都在做自己的事他们三个互不干扰