SpringBoot整合Quartz（升级版）

本片文章是对上一篇《SpringBoot整合Quartz》的升级。

参考&＃xff1a;https://my.oschina.net/u/2289161/blog/865479


org.springframeworkspring-context-support 4.3.9.RELEASE

org.springframeworkspring-tx 4.3.9.RELEASE

org.quartz-schedulerquartz2.3.0

创建QuartzConfig配置类

&＃64;Configuration
public class QuartzConfig {&＃64;Beanpublic SchedulerFactoryBean schedulerFactoryBean(){SchedulerFactoryBean schedulerFactoryBean &＃61; new SchedulerFactoryBean();return schedulerFactoryBean;}&＃64;Beanpublic Scheduler scheduler(){return schedulerFactoryBean().getScheduler();}
} 创建job

public class CloseTradeJob implements Job {&＃64;Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {System.out.println("测试job &＃61; " &＃43; new Date());}
} 创建Task

&＃64;Service
public class MyTask {&＃64;Autowiredpublic Scheduler scheduler;&＃64;PostConstruct //等同于init-methodpublic void init(){//定义jobdetailJobDetail jobDetail &＃61; JobBuilder.newJob(CloseTradeJob.class).withIdentity("close1", "closeTrade").build();//定义triggerSimpleScheduleBuilder simpleScheduleBuilder &＃61; SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever();Trigger trigger &＃61; TriggerBuilder.newTrigger().withIdentity("trigger1", "closeTrade").startNow().withSchedule(simpleScheduleBuilder).build();//启动jobtry {scheduler.scheduleJob(jobDetail, trigger);} catch (SchedulerException e) {e.printStackTrace();}}
} 测试