前言
- 如果不想套繁重的quartz的情況
- 如果想動態(tài)加入定時任務(wù)
- 如果不同的task有不同的開發(fā)人員負責(zé)毛俏，不能都在一個項目中
- 如果不想花費太多的時間來處理
滿足以上至少一條的同學(xué)可以繼續(xù)看了，如果想做集群調(diào)度的饲窿，請移步我覺得不錯的一個架構(gòu): antares
項目架構(gòu)
搭建配置
- maven增加依賴
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>4.0.0</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus</artifactId>
<version>倉庫最高版本號</version>
</dependency>
其他mysql依賴忽略
- 啟動類新增
@Bean
@Order(0)
public Scheduler quartzTask() {
Scheduler scheduler = new Scheduler();
scheduler.setDaemon(true);
scheduler.setMatchSecond(true);
return scheduler;
}
- 調(diào)度主類
@Configuration
@Order(1)
@Slf4j
public class QuartzJobs {
@Autowired(required = false)
private Scheduler scheduler;
@Autowired(required = false)
private QuartzDetailsService quartzDetailsService;
/**
* 每間隔5秒鐘從數(shù)據(jù)庫鐘查詢?nèi)蝿?wù)并添加到調(diào)度隊列中
*
* @throws MalformedURLException
* @throws ClassNotFoundException
* @throws IllegalAccessException
* @throws InstantiationException
*/
@Scheduled(fixedDelay = 30000)
public void queueJobs() {
//從task表中查詢新增加的任務(wù)信息
List<QuartzDetails> jobDetails = quartzDetailsService.selectList(new EntityWrapper<QuartzDetails>().eq("job_enable", 1).eq("job_add_flag", 0));
if (jobDetails != null && !jobDetails.isEmpty()) {
jobDetails.forEach((QuartzDetails job) -> {
try {
URL url = new URL("file:" + job.getJobPath());
URLClassLoader urlClassLoader = new URLClassLoader(new URL[]{url}, Thread.currentThread().getContextClassLoader());
Class<?> clazz = urlClassLoader.loadClass(job.getJobMain());
Runnable runnable = (Runnable) clazz.newInstance();
scheduler.schedule(job.getJobId(), job.getJobCorn(), runnable);
log.warn("新增jod : {} 成功", job.getJobId());
job.setJobAddFlag(1);
quartzDetailsService.update(job, new EntityWrapper<QuartzDetails>().eq("job_id", job.getJobId()));
} catch (CronException cron) {
log.warn("該任務(wù)已添加過,請勿重復(fù)添加調(diào)度task:{}", cron);
} catch (IllegalAccessException | InstantiationException | ClassNotFoundException | MalformedURLException e) {
log.error("添加任務(wù)失敗:{}", e);
}
});
if (!scheduler.isStarted()) {
scheduler.start();
}
}
}
/**
* 每次間隔30秒鐘檢測一次當前調(diào)度是否存活
*/
@Scheduled(fixedRate = 30000)
public void removeQueueJobs() {
//從task表中查詢需移除的任務(wù)信息
List<QuartzDetails> jobDetails = quartzDetailsService.selectList(new EntityWrapper<QuartzDetails>().eq("job_enable", 0).eq("job_add_flag", 1));
jobDetails.forEach(job -> {
if (scheduler.isStarted()) {
scheduler.deschedule(job.getJobId());
log.warn("移除task任務(wù) : {} 成功", job.getJobId());
job.setJobAddFlag(0);
quartzDetailsService.update(job, new EntityWrapper<QuartzDetails>().eq("job_id", job.getJobId()));
}
});
}
}
思路闡述
從數(shù)據(jù)庫表中查詢已啟用但未增加到調(diào)度的任務(wù)
新增后煌寇，將job_add_flag修改為已添加
每隔30s查詢當前已經(jīng)新增過調(diào)度，但是停用的任務(wù)移除db表展示
| juncai_quartz_details | CREATE TABLE `juncai_quartz_details` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主鍵',
`job_id` varchar(20) NOT NULL COMMENT '任務(wù)名稱',
`job_path` varchar(200) NOT NULL COMMENT '任務(wù)地址(絕對路徑)',
`job_main` varchar(100) NOT NULL COMMENT '執(zhí)行run路徑',
`job_enable` tinyint(4) NOT NULL DEFAULT '1' COMMENT '默認為1啟用 否則為暫停',
`job_add_flag` tinyint(4) DEFAULT '0' COMMENT '是否添加到調(diào)度隊列標識 0未添加 否則為添加',
`job_corn` varchar(50) NOT NULL COMMENT '執(zhí)行表達式',
`job_ip` varchar(20) DEFAULT NULL COMMENT '任務(wù)所在機器地址',
`job_id_log` varchar(50) DEFAULT NULL COMMENT '任務(wù)日志名稱',
`create_time` datetime DEFAULT NULL COMMENT '創(chuàng)建時間',
`update_time` datetime DEFAULT NULL COMMENT '修改時間',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8
- 具體調(diào)度任務(wù)代碼展示
@Slf4j
public class QueryZcmlcLoan implements Runnable{
@Override
public void run() {
log.warn("開始查詢.");
System.out.println("hello world!");
log.warn("查詢task結(jié)束.");
}
}
如有疑問或者問題請留言阀溶，thanks
