springboot動態(tài)定時任務的實現(xiàn)方法示例
更新時間：2021年02月05日 14:26:40 作者：qaqhat
這篇文章主要給大家介紹了關于springboot動態(tài)定時任務的實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
1、maven引入quartz包
<!-- https://mvnrepository.com/artifact/org.quartz-scheduler/quartz --> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.2</version> </dependency>
2、創(chuàng)建定時任務工廠類
/**
* 定時任務工廠類
*/
@Component
public class JobFactory extends SpringBeanJobFactory implements ApplicationContextAware {
private transient AutowireCapableBeanFactory beanFactory;
@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
final Object jobInstance = super.createJobInstance(bundle);
beanFactory.autowireBean(jobInstance);
return jobInstance;
}
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.beanFactory = applicationContext.getAutowireCapableBeanFactory();
}
}
3、創(chuàng)建定時任務抽象類
public abstract class AbstractTask implements Job {
private Logger logger = LoggerFactory.getLogger(AbstractTask.class);
protected abstract void executeInternal(JobExecutionContext context) throws Exception;
/**
* 定時任務標識
*/
private String key;
/**
* 數(shù)據(jù)庫里配置的主鍵id
*/
private Long dataBaseId;
@Override
public void execute(JobExecutionContext context) {
try {
executeInternal(context);
} catch (Exception e) {
logger.error(e.getMessage(), e);
logger.error("job execute failed!");
}
}
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}
public Long getDataBaseId() {
return dataBaseId;
}
public void setDataBaseId(Long dataBaseId) {
this.dataBaseId = dataBaseId;
}
}
4、創(chuàng)建定時任務業(yè)務實現(xiàn)類
這里可以寫你的業(yè)務代碼，實現(xiàn)具體的業(yè)務邏輯。
@Component("JobTask")
public class JobTask extends AbstractTask {
@Override
protected void executeInternal(JobExecutionContext context) {
System.out.println("key = " + this.getKey());
System.out.println("dataBaseId = " + this.getDataBaseId());
}
}
5、創(chuàng)建定時任務管理器
包括項目啟動時添加定時任務，手動添加定時任務，更新定時任務，刪除定時任務方法。
/**
* 定時任務管理容器 component （單例模式）
*/
@Component
@Scope("singleton")
public class JobQuartzManager implements ApplicationContextAware {
/**
* 創(chuàng)建新的scheduler
*/
private static SchedulerFactory schedulerFactory = new StdSchedulerFactory();
private Scheduler scheduler;
/**
* 定義組名稱，不同的組用于區(qū)分任務
*/
private static final String JOB_GROUP_NAME = "JOB_GROUP_NAME";
private static final String TRIGGER_GROUP_NAME = "TRIGGER_GROUP_NAME";
/**
* 日志
*/
private Logger logger = LoggerFactory.getLogger(JobQuartzManager.class);
private ApplicationContext applicationContext;
@Autowired
private JobFactory jobFactory;
public void start() {
//啟動定時任務（初始化）
try {
this.scheduler = schedulerFactory.getScheduler();
scheduler.setJobFactory(jobFactory); //設置定時任務工廠模式
//項目啟動時默認給spring容器添加動態(tài)的定時任務
this.addJob("job" + 100L, 100L, JobTask.class, "0/2 * * * * ?");
} catch (SchedulerException e) {
logger.error(e.getMessage(), e);
throw new RuntimeException("init Scheduler failed");
}
}
public boolean addJob(String jobName, Long dataBaseId, Class jobClass, String cronExp) {
boolean result = false;
if (!CronExpression.isValidExpression(cronExp)) {
logger.error("Illegal cron expression format({})", cronExp);
return result;
}
try {
JobDetail jobDetail = JobBuilder.newJob().withIdentity(new JobKey(jobName, JOB_GROUP_NAME))
.ofType((Class<AbstractTask>) Class.forName(jobClass.getName()))
.build();
//創(chuàng)建完jobDetail之后，使用語句傳參數(shù)值，方便定時任務內(nèi)部識別它是什么標識
JobDataMap jobDataMap = jobDetail.getJobDataMap();
jobDataMap.put("key", jobName);
jobDataMap.put("dataBaseId", dataBaseId);
Trigger trigger = TriggerBuilder.newTrigger()
.forJob(jobDetail)
.withSchedule(CronScheduleBuilder.cronSchedule(cronExp))
.withIdentity(new TriggerKey(jobName, TRIGGER_GROUP_NAME))
.build();
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
result = true;
} catch (Exception e) {
logger.error(e.getMessage(), e);
logger.error("QuartzManager add job failed");
}
return result;
}
public boolean updateJob(String jobName, String cronExp) {
boolean result = false;
if (!CronExpression.isValidExpression(cronExp)) {
logger.error("Illegal cron expression format({})", cronExp);
return result;
}
JobKey jobKey = new JobKey(jobName, JOB_GROUP_NAME);
TriggerKey triggerKey = new TriggerKey(jobName, TRIGGER_GROUP_NAME);
try {
if (scheduler.checkExists(jobKey) && scheduler.checkExists(triggerKey)) {
JobDetail jobDetail = scheduler.getJobDetail(jobKey);
Trigger newTrigger = TriggerBuilder.newTrigger()
.forJob(jobDetail)
.withSchedule(CronScheduleBuilder.cronSchedule(cronExp))
.withIdentity(new TriggerKey(jobName, TRIGGER_GROUP_NAME))
.build();
scheduler.rescheduleJob(triggerKey, newTrigger);
result = true;
} else {
logger.error("update job name:{},group name:{} or trigger name:{},group name:{} not exists..",
jobKey.getName(), jobKey.getGroup(), triggerKey.getName(), triggerKey.getGroup());
}
} catch (SchedulerException e) {
logger.error(e.getMessage(), e);
logger.error("update job name:{},group name:{} failed!", jobKey.getName(), jobKey.getGroup());
}
return result;
}
public boolean deleteJob(String jobName) {
boolean result = false;
JobKey jobKey = new JobKey(jobName, JOB_GROUP_NAME);
try {
if (scheduler.checkExists(jobKey)) {
result = scheduler.deleteJob(jobKey);
} else {
logger.error("delete job name:{},group name:{} not exists.", jobKey.getName(), jobKey.getGroup());
}
} catch (SchedulerException e) {
logger.error(e.getMessage(), e);
logger.error("delete job name:{},group name:{} failed!", jobKey.getName(), jobKey.getGroup());
}
return result;
}
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
}
6、創(chuàng)建定時任務啟動類
項目運行時給spring注入定時任務
/**
* 定時任務啟動類
*/
@Component
public class JobRunner implements ApplicationRunner {
//注入定時任務管理器
@Autowired
private JobQuartzManager quartzManager;
/**
* 項目啟動時激活定時任務
*/
@Override
public void run(ApplicationArguments applicationArguments) {
System.out.println("--------------------注入定時任務---------------------");
quartzManager.start();
System.out.println("--------------------定時任務注入完成---------------------");
}
}
7、測試案例
@RestController
@RequestMapping("/job")
public class JobController {
@Autowired
JobQuartzManager quartzManager;
@PostMapping("addJob")
@ResponseBody
public String addJob(@RequestParam("dataBaseId") Long dataBaseId, @RequestParam("cronExp") String cronExp){
boolean success = quartzManager.addJob("job" + dataBaseId, dataBaseId, JobTask.class, cronExp);
if(success){
return "添加成功";
}else{
return "添加失敗！";
}
}
@PostMapping("deleteJob")
@ResponseBody
public String deleteJob(@RequestParam("jobName") String jobName){
boolean success = quartzManager.deleteJob(jobName);
if(success){
return "刪除成功";
}else{
return "刪除失??！";
}
}
@PostMapping("updateJob")
@ResponseBody
public String updateJob(@RequestParam("jobName") String jobName, @RequestParam("cronExp") String cronExp){
boolean success = quartzManager.updateJob(jobName, cronExp);
if(success){
return "更新成功";
}else{
return "更新失??！";
}
}
}
總結
到此這篇關于springboot實現(xiàn)動態(tài)定時任務的文章就介紹到這了,更多相關springboot動態(tài)定時任務內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
mybatis3.4.6 批量更新 foreach 遍歷map 的正確姿勢詳解
這篇文章主要介紹了mybatis3.4.6 批量更新 foreach 遍歷map 的正確姿勢詳解，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11
文件編碼的格式?jīng)Q定了文件可存儲的字符類型，所以得到文件的類型至關重要，下文筆者講述獲取一個文本文件的格式信息的方法分享及java字符串編碼格式實現(xiàn)，感興趣的朋友一起看看吧2022-09-09
java公眾平臺通用接口工具類HttpConnectUtil實例代碼
下面小編就為大家分享一篇java公眾平臺通用接口工具類HttpConnectUtil實例代碼，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-01-01
本文通過四種方法給大家介紹java命令執(zhí)行jar包的方式，每種方法通過實例代碼給大家詳解，需要的朋友參考下吧2019-11-11
spring?boot項目自定義參數(shù)校驗規(guī)則示例詳解
這篇文章主要介紹了spring boot項目如何自定義參數(shù)校驗規(guī)則,自定義校驗規(guī)則和自帶的規(guī)則實現(xiàn)方式一樣，先自定義一個注解，然后指定校驗類，在校驗類里實現(xiàn)具體的校驗規(guī)則，本文結合示例代碼給大家介紹的非常詳細，需要的朋友可以參考下2023-07-07
Spring Boot作為微服務中最好的Java框架，本文主要為大家整理匯總了七個Spring Boot的重要知識點，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2021-11-11
這篇文章主要給大家介紹了關于Java對List進行排序的兩種實現(xiàn)方法，第一種是實體類自己實現(xiàn)比較，第二種是借助比較器進行排序，下面開一起看看詳細的介紹吧，有需要的朋友們可以參考借鑒。2016-12-12
這篇文章主要介紹了HttpClient詳細使用示例詳解,本文給大家介紹的非常想詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-01-01
Java畢業(yè)設計實戰(zhàn)項目之在線服裝銷售商城系統(tǒng)的實現(xiàn)流程
基礎掌握怎么樣，用實戰(zhàn)檢驗就知道了，本篇文章手把手帶你用java+SpringBoot+Maven+Vue+mysql實現(xiàn)一個在線服裝銷售商城系統(tǒng),大家可以在過程中查缺補漏，提升水平2022-01-01
下面小編就為大家?guī)硪黄狫ava基礎的幾道練習題(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望可以幫到你2021-08-08