普元 EOS定时任务实现原理

普元平台的定时任务能力是通过开源的作业调度框架Quartz实现的。

一、定时任务的基本概念：

调度器：负责管理Quartz应用运行时环境，用于调度定时任务。
定时任务：按照某种时间规则，被调度的任务。

a、从有无状态来说，有以下两种：

有状态任务：每次执行的任务是同一个实例，不能被并行执行；如果该任务的执行时间超过下次触发的时刻，那么下次的触发将不会有作用。比如，一个有状态任务执行时间是5分钟，它的间隔时间是3分钟；如果正在执行的时候，下次触发时刻到达，则不会被执行。

无状态任务：每次执行任务都是一个新的实例，可以并行执行。

b、从执行的任务类型来说，有以下三种：

SCA服务任务：任务是一个SCA服务。

逻辑流任务：任务是一个逻辑流。

任意Java方法任务：任务是一个Java方法。

c、触发模式（触发器）：用于定义任务调度的时间规则，主要有下面两种：

固定时刻触发（简单触发器）：一般用于实现间隔固定的时间执行任务，以及重复多少次，如每 2 小时执行一次，重复执行 5 次。

日历周期触发（复杂触发器）：使用Unix 'cron-like'表达式来定义时间规则，即利用一个包含 7 个字段的表达式来表示时间调度方式。例如，"0 15 10 * * ? *" 表示每天的 10：15AM 执行任务。对于涉及到星期和月份的调度比较合适。

d、错失触发：定时任务如果错过触发而没有执行，比如系统停止；系统重启后，就会针对错失触发的定时任务进行处理，一般有两种错失触发策略（EOS_QRTZ_TRIGGERS表的MISFIRE_INSTR字段）：

立即重新触发：默认策略，立即执行一次定时任务，而不管错过几次。MISFIRE_INSTR字段值为1。

错过触发：下次触发时间到来，再触发执行定时任务。MISFIRE_INSTR字段值为2。

定时任务配置界面如下：

二、定时任务实现的基本原理：

单机模式

调度器启动一个调度线程，根据触发器进行轮询，如果触发时刻到达，分配一个执行线程，执行定时任务。其中调度器及其状态、触发器及其状态、定时任务及其状态信息都会持久化到数据库中，所以系统停止，不会丢失定时任务；系统重新启动，会重新定时触发。

集群模式

定时任务的集群，有负载均衡和故障切换的能力，可以给调度器带来高可用性和伸缩性。集群管理的实现是，集群上的每一个节点通过共享同一个数据库来工作的（Quartz通过启动两个维护线程来维护数据库状态实现集群管理，一个是检测节点状态线程，一个是恢复任务线程），通过数据库锁来实现并发控制（如果不是集群，使用内存锁进行并发控制）。下图是集群模式拓扑图：

负载均衡是自动完成的，集群的每个节点会尽快触发任务。当一个触发器的触发时间到达时，第一个节点将会获得任务，并改变任务状态，成为执行任务的节点。

故障切换的发生是在当一个节点正在执行一个或者多个任务失败的时候。当一个节点失败了，其他的节点会检测到并且标识在失败节点上正在进行的数据库中的任务。任何被标记为可恢复的任务都会被其他的节点重新执行。没有标记可恢复的任务只会被释放出来，将会在下次相关触发器触发时执行。

注意：

如果是集群模式，则要求每个节点的时钟一定要一致，否则将发生无法预料的问题。

根据经验，建议简单触发器的间隔时间不要小于20秒。

普元 EOS定时任务实现原理

普元 EOS定时任务实现原理相关推荐

最新文章

热门文章