spring+quartz实现定时任务

1.准备工作

<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>${quartz_version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>4.3.1.RELEASE</version> </dependency>

2.初始化SchedulerFactoryBean

SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean(); schedulerFactoryBean.setConfigLocation(new ClassPathResource("quartz.properties"));//quartz.properties放在resources目录下的文件，可以通过org.quartz.threadPool.threadCount= 10来定义任务池的线程数等 >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> @Autowired private Scheduler scheduler;

3.定义任务

public class MyJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { //这个定时任务做什么 } }

4.开启一个定时任务

JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity(key).build(); //jobDetail.getJobDataMap()可以放入一些参数在定时任务MyJob里面通过JobExecutionContext的相关接口获取到，以达到传参的目的 TriggerKey triggerKey = TriggerKey.triggerKey(key); SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.repeatMinutelyForever(interval); SimpleTrigger simpleTrigger = TriggerBuilder.newTrigger().withIdentity(key).withSchedule(simpleScheduleBuilder).startAt(start).build(); scheduler.scheduleJob(jobDetail, simpleTrigger);

5.修改一个定时任务执行频率 * 首先得知道被修改定时任务在定时任务框架里的标识符即 identifier key “` TriggerKey triggerKey = TriggerKey.triggerKey(key); SimpleTrigger simpleTrigger = (SimpleTrigger) scheduler.getTrigger(triggerKey);

* 判断simpleTrigger不为空,然后进行修改

SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.repeatMinutelyForever(newInterval); simpleTrigger = simpleTrigger.getTriggerBuilder().withSchedule(simpleScheduleBuilder).withIdentity(triggerKey).startAt(start).build(); scheduler.rescheduleJob(triggerKey, simpleTrigger);

“`

6.其它与Scheduler有关

暂停任务 pauseJob(jobKey)删除任务 deleteJob(JobKey.jobKey(key))