美文网首页程序员
分布式任务调度(00)--Quartz

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

作者: JavaEdge | 来源:发表于2023-11-06 16:09 被阅读0次

    1 任务调度整体流程

    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获取行锁:

    • {0}会替换为配置文件默认配置的QRTZ_
    • sched_name为应用集群的实例名
    • lock_name就是行级锁名

    1.3 Quartz的行级锁

    • 触发器访问锁 (TRIGGER_ACCESS)
    • 状态访问锁(STATE_ACCESS)

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

    本文由博客一文多发平台 OpenWrite 发布!

    相关文章

      网友评论

        本文标题:分布式任务调度(00)--Quartz

        本文链接:https://www.haomeiwen.com/subject/ldqxwdtx.html