分布式任务调度(00)--Quartz

布满荆棘的人生 2024-02-19 09:27 14阅读 0赞

### 1 任务调度整体流程 ###

![39c35815578f42708bd05f3610aca01f.png][]

### 2 组件 ###

*  调度器 ：工厂类创建Scheduler，根据触发器定义的时间规则调度任务
 *  任务：Job表示被调度的任务
 *  触发器：Trigger 定义调度时间的元素，按啥时间规则执行任务。一个Job可被多个Trigger关联，但是一个Trigger 只能关联一个Job

import org.quartz.*;
    import org.quartz.SchedulerException;
    import org.quartz.impl.StdSchedulerFactory;
    
    public class QuartzDemo {
        public static void main(String[] args) throws SchedulerException {
            // 创建JobDetail对象
            JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
                    .withIdentity("myJob", "group1")
                    .build();
    
            // 创建Trigger对象
            Trigger trigger = TriggerBuilder.newTrigger()
                    .withIdentity("myTrigger", "group1")
                    .startNow()
                    .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
                    .build();
    
            // 创建Scheduler对象
            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.start();
    
            // 将Job和Trigger注册到Scheduler
            scheduler.scheduleJob(jobDetail, trigger);
        }
    }

执行任务调度核心类QuartzSchedulerThread：

1.  调度线程从JobStore中获取需要执行的的触发器列表，并修改触发器的状态
2.  Fire触发器，修改触发器信息(下次执行触发器的时间，以及触发器状态），并存储
3.  最后创建具体的执行任务对象，通过worker线程池执行任务

### 3 集群部署方案 ###

没有负责集中管理的节点，而是利用数据库行级锁实现并发控制。

scheduler实例在集群模式先获取\{0\}LOCKS表中的行锁，MySQL获取行锁：

![c5aeda26e10d4434b8a4c52547246bfb.png][]

*  \{0\}会替换为配置文件默认配置的QRTZ\_
 *  sched\_name为应用集群的实例名
 *  lock\_name就是行级锁名

#### 1.3 Quartz的行级锁 ####

*  触发器访问锁 (TRIGGER\_ACCESS)
 *  状态访问锁（STATE\_ACCESS）

![97a6cddecbaf4db7818f166d3d2a55ff.png][]

解决了任务的分布式调度问题，同一个任务只能有一个节点运行，其他节点将不执行任务，当碰到大量短任务时，各节点频繁的竞争数据库锁，节点越多性能越差。

> 本文由博客一文多发平台 [OpenWrite][] 发布！

[39c35815578f42708bd05f3610aca01f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/19/8e899f56407a478283871c8256798a1c.png
[c5aeda26e10d4434b8a4c52547246bfb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/19/3385cb52364f44c2a74c798e2122a25b.png
[97a6cddecbaf4db7818f166d3d2a55ff.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/19/51f5abf1070d4cc19be12ca4bb9e5c4a.png
[OpenWrite]: https://openwrite.cn?from=article_bottom