使用@EnableScheduling方式
專注于為中小企業(yè)提供成都網(wǎng)站建設(shè)、做網(wǎng)站服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)義馬免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了成百上千企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。
@Component
@Configurable
@EnableScheduling
public class Task1 {
private static Log logger = LogFactory.getLog(Task1.class);
@Scheduled(cron = "0/2 * * * * * ")
public void execute() {
logger.info("Task1>>" + new Date());
}
}
xml配置方式
application 啟動加入讀取 xml 文件
@SpringBootApplication
@ImportResource(value = { "classpath:applicationContext*.xml" })
public class Springboot2TaskApplication {
public static void main(String[] args) {
SpringApplication.run(Springboot2TaskApplication.class, args);
}
}
@Service
public class Task2 {
private static Log logger = LogFactory.getLog(Task2.class);
public void method2() {
logger.info("Task2----method2>>>>" + new Date());
}
}
bean創(chuàng)建工廠方式
使用到的 jar 包
org.springframework
spring-context-support
org.springframework
spring-tx
org.quartz-scheduler
quartz
2.3.0
新建 SchedledConfiguration.java 文件
@Configuration
public class SchedledConfiguration {
/**
* attention:
* Details：配置定時任務(wù)
*/
@Bean(name = "jobDetail")
public MethodInvokingJobDetailFactoryBean detailFactoryBean(Task3 task) {// TestTask為需要執(zhí)行的任務(wù)
MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
/*
* 是否并發(fā)執(zhí)行
* 例如每5s執(zhí)行一次任務(wù)，但是當(dāng)前任務(wù)還沒有執(zhí)行完，就已經(jīng)過了5s了，
* 如果此處為true，則下一個任務(wù)會執(zhí)行，如果此處為false，則下一個任務(wù)會等待上一個任務(wù)執(zhí)行完后，再開始執(zhí)行
*/
jobDetail.setConcurrent(false);
// 設(shè)置任務(wù)的名字
jobDetail.setName("jobDetailName");
// 設(shè)置任務(wù)的分組，這些屬性都可以存儲在數(shù)據(jù)庫中，在多任務(wù)的時候使用
jobDetail.setGroup("jobDetailGroup");
/*
* 為需要執(zhí)行的實(shí)體類對應(yīng)的對象
*/
jobDetail.setTargetObject(task);
/*
* 通過這幾個配置，告訴JobDetailFactoryBean我們需要執(zhí)行定時執(zhí)行ScheduleTask類中的task方法
*/
jobDetail.setTargetMethod("task");
return jobDetail;
}
/**
* Details：配置定時任務(wù)的觸發(fā)器，也就是什么時候觸發(fā)執(zhí)行定時任務(wù)
*/
@Bean(name = "jobTrigger")
public CronTriggerFactoryBean cronJobTrigger(JobDetail jobDetail) {
CronTriggerFactoryBean tigger = new CronTriggerFactoryBean();
tigger.setJobDetail(jobDetail);
// 初始時的cron表達(dá)式，可以改成從數(shù)據(jù)庫中獲取
tigger.setCronExpression("0/2 * * * * ?");
// trigger的name
tigger.setName("tiggerName");
return tigger;
}
/**
* Details：定義quartz調(diào)度工廠
*/
@Bean(name = "scheduler")
public SchedulerFactoryBean schedulerFactory(Trigger trigger) {
SchedulerFactoryBean bean = new SchedulerFactoryBean();
// 用于quartz集群,QuartzScheduler 啟動時更新己存在的Job
bean.setOverwriteExistingJobs(true);
// 延時啟動，應(yīng)用啟動1秒后
bean.setStartupDelay(1);
// 注冊觸發(fā)器
bean.setTriggers(trigger);
return bean;
}
}
新建Task任務(wù)
@Service
public class Task3 {
@Resource(name = "jobTrigger")
private CronTrigger cronTrigger;
@Resource(name = "scheduler")
private Scheduler scheduler;
private static Log logger = LogFactory.getLog(Task3.class);
public void task() {
logger.info("Task3---------" + new Date());
}
/**
* 設(shè)置cron并重啟定時器
* @param cron cron值
*/
public void setCron(String cron) {
try {
// 表達(dá)式調(diào)度構(gòu)建器
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
// 按新的cronExpression表達(dá)式重新構(gòu)建trigger
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(cronTrigger.getKey());
trigger = trigger.getTriggerBuilder().withIdentity(cronTrigger.getKey())
.withSchedule(scheduleBuilder).build();
// 按新的trigger重新設(shè)置job執(zhí)行
scheduler.rescheduleJob(cronTrigger.getKey(), trigger);
} catch (SchedulerException e) {
logger.info("cron表達(dá)式錯誤");
}
}
}其中 setCron 方法可以進(jìn)行重新設(shè)定任務(wù)調(diào)度時間
ThreadPoolTaskScheduler Runnable方式
public class Task4 implements Runnable {
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
private static Log logger = LogFactory.getLog(Task4.class);
@Override
public void run() {
logger.info("Task4================" + new Date());
}
/**
* 設(shè)置cron并啟動
* @param cronExp cron值
*/
public void reStart(String cronExp) {
if (null != this.threadPoolTaskScheduler) {
ScheduledExecutorService scheduledExecutorService = this.threadPoolTaskScheduler.getScheduledExecutor();
if (!scheduledExecutorService.isShutdown()) {
scheduledExecutorService.shutdownNow();
}
this.threadPoolTaskScheduler.destroy();
}
if (null != cronExp && cronExp.trim().length() > 0) {
this.threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
this.threadPoolTaskScheduler.setThreadNamePrefix("task4");
this.threadPoolTaskScheduler.initialize();
this.threadPoolTaskScheduler.schedule(this, new CronTrigger(cronExp));
}
}
}
其中reStart可以進(jìn)行任務(wù)啟動和重新設(shè)置任務(wù)調(diào)度時間,調(diào)用方式如下所示
/**
* 初始化task4
* 這里的代碼不應(yīng)該寫在rest層上， 應(yīng)該寫在service層上
*/
@PostConstruct
private void initTask4() {
//初始化task4任務(wù)調(diào)度器cron，可以從數(shù)據(jù)庫中查詢到cron值
setTask4Cron("0/3 * * * * ?");
}
/**
* 改變task4的cron
* @param cron cron值
* @return 成功標(biāo)志
*/
@RequestMapping(value = { "/setTask4Cron" }, method = RequestMethod.GET)
@ResponseBody
public String setTask4Cron(String cron) {
if (null == task4) {
task4 = new Task4();
}
task4.reStart(cron);
return "success";
}initTask4 方法加了 @PostConstruct '注解,可以在項(xiàng)目啟動時自動根據(jù)cron來啟動任務(wù), setTask4Cron 方法可以重新調(diào)置任務(wù)時間
四個任務(wù)的效果如下:
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。
當(dāng)前文章：SpringBoot2taskscheduler定時任務(wù)調(diào)度器四種方式
路徑分享：
http://weahome.cn/article/ihsphi.html
重慶分公司
重慶分公司
