分布式任务调度(00)--Quartz
1 任务调度整体流程https://img2023.cnblogs.com/other/1097393/202311/1097393-20231107160948154-215300986.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：
[*]调度线程从JobStore中获取需要执行的的触发器列表，并修改触发器的状态
[*]Fire触发器，修改触发器信息(下次执行触发器的时间，以及触发器状态），并存储
[*]最后创建具体的执行任务对象，通过worker线程池执行任务
3 集群部署方案
没有负责集中管理的节点，而是利用数据库行级锁实现并发控制。
scheduler实例在集群模式先获取{0}LOCKS表中的行锁，MySQL获取行锁：
https://img2023.cnblogs.com/other/1097393/202311/1097393-20231107160948737-589292673.png
[*]{0}会替换为配置文件默认配置的QRTZ_
[*]sched_name为应用集群的实例名
[*]lock_name就是行级锁名
1.3 Quartz的行级锁
[*]触发器访问锁 (TRIGGER_ACCESS)
[*]状态访问锁（STATE_ACCESS）
https://img2023.cnblogs.com/other/1097393/202311/1097393-20231107160949631-1112191641.png
解决了任务的分布式调度问题，同一个任务只能有一个节点运行，其他节点将不执行任务，当碰到大量短任务时，各节点频繁的竞争数据库锁，节点越多性能越差。
本文由博客一文多发平台 OpenWrite 发布！
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
页:
[1]