spring-boot-quartz, 依赖spring-boot-parent

@Configurationpublic class QuartzConfig {    @Bean    public Scheduler scheduler() throws IOException, SchedulerException {        SchedulerFactory schedulerFactory = new StdSchedulerFactory(quartzProperties());        Scheduler scheduler = schedulerFactory.getScheduler();        scheduler.start();        return scheduler;    }    /**     * 设置quartz属性     * @throws IOException     * 2016年10月8日下午2:39:05     */    public Properties quartzProperties() throws IOException {        Properties prop = new Properties();        prop.put("quartz.scheduler.instanceName", "ServerScheduler");        prop.put("org.quartz.scheduler.instanceId", "AUTO");        prop.put("org.quartz.scheduler.skipUpdateCheck", "true");        prop.put("org.quartz.scheduler.instanceId", "NON_CLUSTERED");        prop.put("org.quartz.scheduler.jobFactory.class", "org.quartz.simpl.SimpleJobFactory");        prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");        prop.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.StdJDBCDelegate");        prop.put("org.quartz.jobStore.dataSource", "quartzDataSource");        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");        prop.put("org.quartz.jobStore.isClustered", "true");        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");        prop.put("org.quartz.threadPool.threadCount", "5");        prop.put("org.quartz.dataSource.quartzDataSource.driver", "com.mysql.jdbc.Driver");        prop.put("org.quartz.dataSource.quartzDataSource.URL", "jdbc:mysql://localhost:3306/demo-schema");        prop.put("org.quartz.dataSource.quartzDataSource.user", "root");        prop.put("org.quartz.dataSource.quartzDataSource.password", "123456");        prop.put("org.quartz.dataSource.quartzDataSource.maxConnections", "10");        return prop;    }}

@Servicepublic class TaskServiceImpl {    private Logger logger = LogManager.getLogger(getClass());    @Autowired    private Scheduler scheduler;    /**     * 所有任务列表     * 2016年10月9日上午11:16:59     */    public List<TaskInfo> list(){        List<TaskInfo> list = new ArrayList<>();        try {            for(String groupJob: scheduler.getJobGroupNames()){                for(JobKey jobKey: scheduler.getJobKeys(GroupMatcher.<JobKey>groupEquals(groupJob))){                    List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);                    for (Trigger trigger: triggers) {                        Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());                        JobDetail jobDetail = scheduler.getJobDetail(jobKey);                        String cronExpression = "", createTime = "";                        if (trigger instanceof CronTrigger) {                            CronTrigger cronTrigger = (CronTrigger) trigger;                            cronExpression = cronTrigger.getCronExpression();                            createTime = cronTrigger.getDescription();                        }                        TaskInfo info = new TaskInfo();                        info.setJobName(jobKey.getName());                        info.setJobGroup(jobKey.getGroup());                        info.setJobDescription(jobDetail.getDescription());                        info.setJobStatus(triggerState.name());                        info.setCronExpression(cronExpression);                        info.setCreateTime(createTime);                        list.add(info);                    }                                   }            }                   } catch (SchedulerException e) {            e.printStackTrace();        }        return list;    }    /**     * 保存定时任务     * @param info     * 2016年10月9日上午11:30:40     */    @SuppressWarnings("unchecked")    public void addJob(TaskInfo info) {        String jobName = info.getJobName(),                jobGroup = info.getJobGroup(),                cronExpression = info.getCronExpression(),               jobDescription = info.getJobDescription(),               createTime = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");        try {            if (checkExists(jobName, jobGroup)) {                logger.info("===> AddJob fail, job already exist, jobGroup:{}, jobName:{}", jobGroup, jobName);                throw new ServiceException(String.format("Job已经存在, jobName:{%s},jobGroup:{%s}", jobName, jobGroup));            }            TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);            JobKey jobKey = JobKey.jobKey(jobName, jobGroup);            CronScheduleBuilder schedBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();            CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withDescription(createTime).withSchedule(schedBuilder).build();            Class<? extends Job> clazz = (Class<? extends Job>)Class.forName(jobName);            JobDetail jobDetail = JobBuilder.newJob(clazz).withIdentity(jobKey).withDescription(jobDescription).build();            scheduler.scheduleJob(jobDetail, trigger);        } catch (SchedulerException | ClassNotFoundException e) {            throw new ServiceException("类名不存在或执行表达式错误");        }    }    /**     * 修改定时任务     * @param info     * 2016年10月9日下午2:20:07     */    public void edit(TaskInfo info) {        String jobName = info.getJobName(),                jobGroup = info.getJobGroup(),                cronExpression = info.getCronExpression(),               jobDescription = info.getJobDescription(),               createTime = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");        try {            if (!checkExists(jobName, jobGroup)) {                throw new ServiceException(String.format("Job不存在, jobName:{%s},jobGroup:{%s}", jobName, jobGroup));            }            TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);            JobKey jobKey = new JobKey(jobName, jobGroup);            CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();            CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withDescription(createTime).withSchedule(cronScheduleBuilder).build();            JobDetail jobDetail = scheduler.getJobDetail(jobKey);            jobDetail.getJobBuilder().withDescription(jobDescription);            HashSet<Trigger> triggerSet = new HashSet<>();            triggerSet.add(cronTrigger);            scheduler.scheduleJob(jobDetail, triggerSet, true);        } catch (SchedulerException e) {            throw new ServiceException("类名不存在或执行表达式错误");        }    }    /**     * 删除定时任务     * @param jobName     * @param jobGroup     * 2016年10月9日下午1:51:12     */    public void delete(String jobName, String jobGroup){        TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);        try {            if (checkExists(jobName, jobGroup)) {                scheduler.pauseTrigger(triggerKey);                scheduler.unscheduleJob(triggerKey);                logger.info("===> delete, triggerKey:{}", triggerKey);            }        } catch (SchedulerException e) {            throw new ServiceException(e.getMessage());        }    }    /**     * 验证是否存在     * @param jobName     * @param jobGroup     * @throws SchedulerException     * 2016年10月8日下午5:30:43     */    private boolean checkExists(String jobName, String jobGroup) throws SchedulerException{        TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);        return scheduler.checkExists(triggerKey);    }}

1. <dependency>  
2.             <groupId>org.springframework</groupId>  
3.             <artifactId>spring-context-support</artifactId>  
4.             <version>4.1.6.RELEASE</version>  
5.         </dependency>  
6. <dependency>  
7.             <groupId>org.quartz-scheduler</groupId>  
8.             <artifactId>quartz</artifactId>  
9.             <version>2.2.1</version>  
10.         </dependency>  

1. package com.xxx;  
2.   
3. import java.io.IOException;  
4.   
5. import org.mybatis.spring.annotation.MapperScan;  
6. import org.quartz.JobDetail;  
7. import org.quartz.Trigger;  
8. import org.quartz.spi.JobFactory;  
9. import org.springframework.beans.factory.annotation.Qualifier;  
10. import org.springframework.beans.factory.annotation.Value;  
11. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;  
12. import org.springframework.context.ApplicationContext;  
13. import org.springframework.context.annotation.Bean;  
14. import org.springframework.context.annotation.ComponentScan;  
15. import org.springframework.context.annotation.ComponentScan.Filter;  
16. import org.springframework.context.annotation.Configuration;  
17. import org.springframework.context.annotation.FilterType;  
18. import org.springframework.scheduling.annotation.EnableScheduling;  
19. import org.springframework.scheduling.quartz.CronTriggerFactoryBean;  
20. import org.springframework.scheduling.quartz.JobDetailFactoryBean;  
21. import org.springframework.scheduling.quartz.SchedulerFactoryBean;  
22. import org.springframework.test.context.ContextConfiguration;  
23. import org.springframework.test.context.web.WebAppConfiguration;  
24. import org.springframework.transaction.annotation.EnableTransactionManagement;  
25.   
26. import com.xxx.base.BaseWebAppConfig;  
27. import com.xxx.cars.quartz.AutowiringSpringBeanJobFactory;  
28. import com.xxx.cars.quartz.SampleJob;  
29.   
30. @Configuration  
31. @EnableScheduling  
32. @ContextConfiguration  
33. @WebAppConfiguration  
34. @ComponentScan(basePackages = { "com.xxx" }, excludeFilters = { @Filter(type = FilterType.ANNOTATION, value = Configuration.class) })  
35. @MapperScan("com.xxx.cars.persistence")  
36. @EnableTransactionManagement  
37. @EnableAutoConfiguration  
38. public class WebAppConfig extends BaseWebAppConfig {  
39.     /** 
40.      * 配置拦截器 
41.      *  
42.      * @author jodie 
43.      * @param registry 
44.      */  
45. //  public void addInterceptors(InterceptorRegistry registry) {  
46. //      registry.addInterceptor(new UserSecurityInterceptor()).addPathPatterns(  
47. //              "/**");  
48. //  }  
49.       
50.      @Bean  
51.         public JobFactory jobFactory(ApplicationContext applicationContext) {  
52.             AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();  
53.             jobFactory.setApplicationContext(applicationContext);  
54.             return jobFactory;  
55.         }  
56.   
57.         /**调度工厂bean  
58.          * @param jobFactory  
59.          * @param sampleJobTrigger  
60.          * @return  
61.          * @author LDX  
62.          * @throws IOException  
63.          */  
64.         @Bean  
65.         public SchedulerFactoryBean schedulerFactoryBean(JobFactory jobFactory,  
66.                                                          @Qualifier("cronJobTrigger") Trigger cronJobTrigger) throws IOException {  
67.             SchedulerFactoryBean factory = new SchedulerFactoryBean();  
68.             // this allows to update triggers in DB when updating settings in config file:  
69.             //用于quartz集群,QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了  
70.             factory.setOverwriteExistingJobs(true);  
71.           //用于quartz集群,加载quartz数据源  
72. //          factory.setDataSource(dataSource);  
73.             factory.setJobFactory(jobFactory);  
74.             //QuartzScheduler 延时启动，应用启动完20秒后 QuartzScheduler 再启动  
75.             factory.setStartupDelay(20);  
76.           //用于quartz集群,加载quartz数据源配置  
77. //          factory.setQuartzProperties(quartzProperties());  
78.             //注册触发器  
79.             factory.setTriggers(cronJobTrigger);  
80.   
81.             return factory;  
82.         }  
83.   
84.         /**加载quartz数据源配置,quartz集群时用到 
85.          * @return 
86.          * @author LDX 
87.          * @throws IOException 
88.          */  
89. //      @Bean  
90. //      public Properties quartzProperties() throws IOException {  
91. //          PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();  
92. //          propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));  
93. //          propertiesFactoryBean.afterPropertiesSet();  
94. //          return propertiesFactoryBean.getObject();  
95. //      }  
96.   
97.         /**加载触发器 
98.          * @author LDX 
99.          * @return 
100.          */  
101.         @Bean  
102.         public JobDetailFactoryBean sampleJobDetail() {  
103.             return createJobDetail(ApplicationJob.class);  
104.         }  
105.   
106.         /**加载定时器 
107.          * @param jobDetail 
108.          * @param frequency 
109.          * @author LDX 
110.          * @return 
111.          */  
112.         @Bean(name = "cronJobTrigger")  
113.         public CronTriggerFactoryBean sampleJobTrigger(@Qualifier("sampleJobDetail") JobDetail jobDetail,  
114.                                                          @Value("${samplejob.frequency}") long frequency) {  
115.             return createTrigger(jobDetail, frequency);  
116.         }  
117.   
118.         /**创建触发器工厂 
119.          * @param jobClass 
120.          * @author LDX 
121.          * @return 
122.          */  
123.         private static JobDetailFactoryBean createJobDetail(Class jobClass) {  
124.             JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();  
125.             factoryBean.setJobClass(jobClass);  
126.             factoryBean.setDurability(true);  
127.             return factoryBean;  
128.         }  
129.   
130.         /**创建一个以频率为触发节点,以毫秒为单位,可以指定每隔x秒执行任务 
131.          * @param jobDetail 
132.          * @param pollFrequencyMs 
133.          * @author LDX 
134.          * @return 
135.           
136.         private static SimpleTriggerFactoryBean createTrigger(JobDetail jobDetail, long pollFrequencyMs) { 
137.             SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean(); 
138.             factoryBean.setJobDetail(jobDetail); 
139.             factoryBean.setStartDelay(0L); 
140.             factoryBean.setRepeatInterval(pollFrequencyMs); 
141.             factoryBean.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY); 
142.             // in case of misfire, ignore all missed triggers and continue : 
143.             factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT); 
144.             return factoryBean; 
145.         }*/  
146.           
147.         /**创建定时器工厂 
148.          * @param jobDetail 
149.          * @param pollFrequencyMs 
150.          * @author LDX 
151.          * @return 
152.          */  
153.         private static CronTriggerFactoryBean createTrigger(JobDetail jobDetail, long pollFrequencyMs) {  
154.             CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();  
155.             factoryBean.setJobDetail(jobDetail);  
156.             factoryBean.setStartDelay(0L);  
157.             factoryBean.setCronExpression ("0/5 * * * * ? ");//每5秒执行一次  
158.             return factoryBean;  
159.         }  
160.           

1. package com.xxx.cars.quartz;  
2.   
3. import org.quartz.spi.TriggerFiredBundle;  
4. import org.springframework.beans.factory.config.AutowireCapableBeanFactory;  
5. import org.springframework.context.ApplicationContext;  
6. import org.springframework.context.ApplicationContextAware;  
7. import org.springframework.scheduling.quartz.SpringBeanJobFactory;  
8.   
9. public class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory  
10.         implements ApplicationContextAware {  
11.   
12.     private transient AutowireCapableBeanFactory beanFactory;  
13.   
14.     @Override  
15.     public void setApplicationContext(final ApplicationContext context) {  
16.         beanFactory = context.getAutowireCapableBeanFactory();  
17.     }  
18.   
19.     @Override  
20.     protected Object createJobInstance(final TriggerFiredBundle bundle)  
21.             throws Exception {  
22.         final Object job = super.createJobInstance(bundle);  
23.         beanFactory.autowireBean(job);  
24.         return job;  
25.     }  
26. }  

1. package com.xxx.cars.quartz;  
2.   
3. import javax.annotation.Resource;  
4.   
5. import org.quartz.Job;  
6. import org.quartz.JobExecutionContext;  
7. import org.quartz.JobExecutionException;  
8.   
9. import com.cbkj.sz.cars.entity.ApplicationInfo;  
10. import com.cbkj.sz.cars.service.ApplicationInfoService;  
11. import org.springframework.scheduling.quartz.QuartzJobBean;  
12.   
13. /** 
14.  * @author LDX 
15.  * 
16.  */  
17. public class ApplicationJob implements Job{  
18.   
19.     @Resource  
20.     private ApplicationInfoService<ApplicationInfo> applicationInfoService;  
21.   
22.     @Override  
23.     public void execute(JobExecutionContext arg0) throws JobExecutionException {  
24.         try {  
25.             applicationInfoService.quartz_text();  
26.         } catch (Exception e) {  
27.             e.printStackTrace();  
28.         }     
29.           
30.     }  
31.   
32.       
33.       
34.       
35. }   

1. <pre name="code" class="java">@Value("${samplejob.frequency}")  

@Component@Configurable@EnableSchedulingpublic class ScheduledTasks{    @Scheduled(fixedRate = 1000 * 30)    public void reportCurrentTime(){        System.out.println ("Scheduling Tasks Examples: The time is now " + dateFormat ().format (new Date ()));    }    //每1分钟执行一次    @Scheduled(cron = "0 */1 *  * * * ")    public void reportCurrentByCron(){        System.out.println ("Scheduling Tasks Examples By Cron: The time is now " + dateFormat ().format (new Date ()));    }    private SimpleDateFormat dateFormat(){        return new SimpleDateFormat ("HH:mm:ss");    }    }

<dependency>    <groupId>org.quartz-scheduler</groupId>    <artifactId>quartz</artifactId>    <version>1.8.4</version></dependency>

@Configurationpublic class SchedledConfiguration {    // 配置中设定了    // ① targetMethod: 指定需要定时执行scheduleInfoAction中的simpleJobTest()方法    // ② concurrent：对于相同的JobDetail，当指定多个Trigger时, 很可能第一个job完成之前，    // 第二个job就开始了。指定concurrent设为false，多个job不会并发运行，第二个job将不会在第一个job完成之前开始。    // ③ cronExpression：0/10 * * * * ?表示每10秒执行一次，具体可参考附表。    // ④ triggers：通过再添加其他的ref元素可在list中放置多个触发器。 scheduleInfoAction中的simpleJobTest()方法    @Bean(name = "detailFactoryBean")    public MethodInvokingJobDetailFactoryBean detailFactoryBean(ScheduledTasks scheduledTasks){        MethodInvokingJobDetailFactoryBean bean = new MethodInvokingJobDetailFactoryBean ();        bean.setTargetObject (scheduledTasks);        bean.setTargetMethod ("reportCurrentByCron");        bean.setConcurrent (false);        return bean;    }    @Bean(name = "cronTriggerBean")    public CronTriggerBean cronTriggerBean(MethodInvokingJobDetailFactoryBean detailFactoryBean){        CronTriggerBean tigger = new CronTriggerBean ();        tigger.setJobDetail (detailFactoryBean.getObject ());        try {            tigger.setCronExpression ("0/5 * * * * ? ");//每5秒执行一次        } catch (ParseException e) {            e.printStackTrace ();        }        return tigger;    }    @Bean    public SchedulerFactoryBean schedulerFactory(CronTriggerBean[] cronTriggerBean){        SchedulerFactoryBean bean = new SchedulerFactoryBean ();        System.err.println (cronTriggerBean[0]);        bean.setTriggers (cronTriggerBean);        return bean;    }
}

public abstract class BaseCronTrigger extends CronTriggerBean implements Serializable {    private static final long serialVersionUID = 1L;    public void init(){        // 得到任务        JobDetail jobdetail = new JobDetail (this.getClass ().getSimpleName (),this.getMyTargetObject ().getClass ());        this.setJobDetail (jobdetail);        this.setJobName (jobdetail.getName ());        this.setName (this.getClass ().getSimpleName ());        try {            this.setCronExpression (this.getMyCronExpression ());        } catch (java.text.ParseException e) {            e.printStackTrace ();        }    }    public abstract String getMyCronExpression();    public abstract Job getMyTargetObject();}

public class ScheduledTasks implements Job {       @Override    public void execute(JobExecutionContext context) throws JobExecutionException{        System.out.println ("Scheduling Tasks Examples By Cron: The time is now " + dateFormat ().format (new Date ()));    }   private SimpleDateFormat dateFormat(){        return new SimpleDateFormat ("HH:mm:ss");    }}

@Componentpublic class InitializingCronTrigger extends BaseCronTrigger implements Serializable {    private static final long    serialVersionUID = 1L;    @Autowired    private SchedulerFactoryBean schedulerFactoryBean;    public InitializingCronTrigger() {        init ();    }    @Override    public String getMyCronExpression(){        return "0/5 * * * * ?";    }    @Override    public Job getMyTargetObject(){        return new ScheduledTasks ();    }    public void parse(){        try {            schedulerFactoryBean.getObject ().pauseAll ();        } catch (SchedulerException e) {            e.printStackTrace ();        }    }}

  @Bean    public SchedulerFactoryBean schedulerFactory(CronTriggerBean[] cronTriggerBean){        SchedulerFactoryBean bean = new SchedulerFactoryBean ();        System.err.println (cronTriggerBean[0]);        bean.setTriggers (cronTriggerBean);        return bean;    }