微服务批量框架总结-Quartz（微服务常用框架）

先简单介绍一下Quartz，Quartz包括三个比较重要的概念：任务调度器（Scheduler）、触发器（Trigger）、任务（Job）。总的来说就是任务调度器来调度触发器，触发器来定义规则执行任务。之所以Quartz能够很好的来应对集群的情况，是因为Quartz是可以搭配数据库来使用的，避免集群情况下对同一任务重复执行的问题。Quartz框架给出了对应的不同数据库所需的sql文件，但是智能应答进行了定制化，并没有使用推荐的数据库表，只使用了两个表，一个是qa_batch_define(问答批量任务执行定义表)，一个是qa_batch_task(问答批量任务执行任务表)

从图中可以看到，框架主要有两个任务，一个是batchDefineScannerDetail，执行类为batchDefinitionScanner，执行方法为executeBatchDefInfo；另一个是batchExecuteScannerDetail，执行类为batchExecuteScanner，执行方法为executeBatchTask。触发器的设定都是“0 0/2 * * * ? *”，即每两分钟执行一次。

接下来分别介绍下这两个任务。任务一，即batchDefineScannerDetail，每两分钟会执行一次executeBatchDefInfo方法。这个任务的作用就是从qa_batch_define(问答批量任务执行定义表)中读取要执行的批量任务放入qa_batch_task(问答批量任务执行任务表)中。查询要执行的批量任务有以下条件限制：当前时间要大于等于批量任务定义有效开始时间，小于批量任务定义有效结束时间，同时当前时间大于等于下次生成实例时间。

从qa_batch_define读取的待执行任务信息中，读取一条数据，进行尝试锁定，锁定的目的就是防止集群重复执行。锁定的方式就是通过读取数据的定义任务号和更新时间，修改更新时间，以及下次生成实例时间（通过任务的cron规则计算），使得其他集群在上一步读取要执行的批量任务时不再读取本条数据，从而实现锁定。这里的更新成功条数如果是0条，说明别的集群进行了锁定，不再执行后序代码，等下个调度点再重新从qa_batch_define表中读取待执行任务数据。感觉这里的锁定方法挺巧妙

如果上步锁定成功，则将要执行的任务信息存储到qa_batch_task(问答批量任务执行任务表)中，等待任务二的调度。

任务二，即batchExecuteScannerDetail，每两分钟执行一次executeBatchTask方法。这个任务的作用就是从表qa_batch_task查询要执行的任务进行执行。查询的限制是判断当前微服务的名称是否为任务要求的一致或者为空，要执行的当前机器名是否为任务要求的一致或者为空，当前时间是否大于预计执行时间（这里的预计执行时间就是任务一更新的下次生成实例时间），并且当前时间要小于预计时间+2小时内（预计执行时间后的两小时都未执行，则放弃该任务），同时任务状态为等待执行。

为防止集群的重复执行，对上步查询出的待执行任务进行锁定，这里的锁定主要是更新了任务状态从“等待执行”到“执行中”。然后开启新的线程执行任务。

执行任务的具体过程是从任务数据中获取对应的bean名称，并且执行bean中对应的executeService方法（bean实现了ICommonBatch接口），所以当我们创建新的批量任务的时候，只要指定任务对应的cron，以及要执行的微服务名，并且实现ICommonBatch接口的executeService方法，批量框架就会自动调度执行了。