1.依赖:

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

2.代码:

SRE实战 互联网时代守护先锋,助力企业售后服务体系运筹帷幄!一键直达领取阿里云限量特价优惠。
// 定时任务组名称
public static final String Quartz_Group_Name = "businessOpenQuartzJobGroup";
//定时任务方法后缀
public static final String Quartz_Job_Suffix = "_job";
//定时任务触发器后缀
public static final String Quartz_Trigger_Suffix = "_trigger";

@Value("${0 0/1 * * * ? *}")
private String cronRedisBatchDataInitializerJob
;
定义jobFactory:
//解决Job中注入Spring Bean为null的问题
@Component("jobFactory")
private static class QuartzJobFactory extends AdaptableJobFactory {
@Autowired
private AutowireCapableBeanFactory capableBeanFactory;

protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
Object jobInstance = super.createJobInstance(bundle);
capableBeanFactory.autowireBean(jobInstance);
return jobInstance;
}
}

定义一个@Config

@Bean(name = "triggers")
public CronTriggerImpl[] createTriggers()
throws ParseException {
List<CronTriggerImpl> list = new ArrayList<CronTriggerImpl>();

list.add(createTrigger(BatchRedisDataInitializeJob.class,cronRedisBatchDataInitializerJob));

return list.toArray(new CronTriggerImpl[list.size()]);
}

createTrigger

private CronTriggerImpl createTrigger(Class<? extends Job> clazz, String cronExpression) throws ParseException {
CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
cronTriggerFactoryBean.setJobDetail(createJobDetail(clazz));
cronTriggerFactoryBean.setCronExpression(cronExpression);
cronTriggerFactoryBean.setName(clazz.getSimpleName() + Quartz_Trigger_Suffix);
cronTriggerFactoryBean.setGroup(Quartz_Group_Name);
cronTriggerFactoryBean.afterPropertiesSet();
return (CronTriggerImpl) cronTriggerFactoryBean.getObject();
}

 

createDetail

private JobDetail createJobDetail(Class<? extends Job> c) {
JobDetailFactoryBean jobDetailFactoryBean = new JobDetailFactoryBean();
jobDetailFactoryBean.setDurability(true);
jobDetailFactoryBean.setRequestsRecovery(true);
jobDetailFactoryBean.setJobClass(c);
jobDetailFactoryBean.setName(c.getSimpleName() + Quartz_Job_Suffix);
jobDetailFactoryBean.setGroup(Quartz_Group_Name);
jobDetailFactoryBean.afterPropertiesSet();
JobDetail jobDetail = jobDetailFactoryBean.getObject();
return jobDetail;
}

Scheduler:

@Bean(name = "myQuartzScheduler")
public SchedulerFactoryBean schedulerFactoryBean(JobFactory jobFactory, @Qualifier("triggers") CronTriggerImpl[] triggers) {
SchedulerFactoryBean factory = new SchedulerFactoryBean();
factory.setJobFactory(jobFactory);
if (jobStoreToDb) { //quartz任务是否持久化到数据库,测试时可设置为false,同时将quarz.properties里org.quartz.jobStore开头的配置全部注释掉,避免本机触发不了任务
factory.setDataSource(dataSource); //使用应用的数据源
}
//factory.setTaskExecutor(executor); //设置线程池
factory.setOverwriteExistingJobs(true);
factory.setStartupDelay(2);
factory.setQuartzProperties(PropertiesReader.getPropInstance(QUARTZ_CONFIG));
//factory.setConfigLocation(new ClassPathResource(QUARTZ_CONFIG));
factory.setAutoStartup(true);
// 集群需要通过QuartzJobBean注入,需要设置上下文
factory.setApplicationContextSchedulerContextKey("applicationContext");

factory.setTriggers(triggers); // 注册触发器
return factory;
}



 quartz.properties:

#quartz\u96C6\u7FA4\u914D\u7F6E
# ===========================================================================
# Configure Main Scheduler Properties \u8C03\u5EA6\u5668\u5C5E\u6027
# ===========================================================================
#\u8C03\u5EA6\u6807\u8BC6\u540D \u96C6\u7FA4\u4E2D\u6BCF\u4E00\u4E2A\u5B9E\u4F8B\u90FD\u5FC5\u987B\u4F7F\u7528\u76F8\u540C\u7684\u540D\u79F0\u3002\u6B64\u5904\u53EF\u4E0D\u914D\u7F6E\uFF0C\u503C\u4EE5QuartzConfig\u91CC\u7684SchedulerFactoryBean\u540D\u5B57\u4E3A\u51C6
org.quartz.scheduler.instanceName=luQuartzScheduler
#ID\u8BBE\u7F6E\u4E3A\u81EA\u52A8\u83B7\u53D6 \u6BCF\u4E00\u4E2A\u5FC5\u987B\u4E0D\u540C
org.quartz.scheduler.instanceId=AUTO
#============================================================================
# Configure ThreadPool
#============================================================================
#\u7EBF\u7A0B\u6C60\u7684\u5B9E\u73B0\u7C7B\uFF08\u4E00\u822C\u4F7F\u7528SimpleThreadPool\u5373\u53EF\u6EE1\u8DB3\u51E0\u4E4E\u6240\u6709\u7528\u6237\u7684\u9700\u6C42\uFF09
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
#\u6307\u5B9A\u7EBF\u7A0B\u6570\uFF0C\u81F3\u5C11\u4E3A1\uFF08\u65E0\u9ED8\u8BA4\u503C\uFF09(\u4E00\u822C\u8BBE\u7F6E\u4E3A1-100\u76F4\u63A5\u7684\u6574\u6570\u5408\u9002)
org.quartz.threadPool.threadCount = 25
#\u8BBE\u7F6E\u7EBF\u7A0B\u7684\u4F18\u5148\u7EA7\uFF08\u6700\u5927\u4E3Ajava.lang.Thread.MAX_PRIORITY 10\uFF0C\u6700\u5C0F\u4E3AThread.MIN_PRIORITY 1\uFF0C\u9ED8\u8BA4\u4E3A5\uFF09
org.quartz.threadPool.threadPriority = 5
#============================================================================
# Configure JobStore
#============================================================================
## \u4FE1\u606F\u4FDD\u5B58\u65F6\u95F4 \u9ED8\u8BA4\u503C60\u79D2
#org.quartz.jobStore.misfireThreshold = 60000
##\u6570\u636E\u4FDD\u5B58\u65B9\u5F0F\u4E3A\u6570\u636E\u5E93\u6301\u4E45\u5316
#org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
##\u6570\u636E\u5E93\u4EE3\u7406\u7C7B\uFF0C\u4E00\u822Corg.quartz.impl.jdbcjobstore.StdJDBCDelegate\u53EF\u4EE5\u6EE1\u8DB3\u5927\u90E8\u5206\u6570\u636E\u5E93
#org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
##JobDataMaps\u662F\u5426\u90FD\u4E3AString\u7C7B\u578B
#org.quartz.jobStore.useProperties = false
##\u8868\u7684\u524D\u7F00\uFF0C\u9ED8\u8BA4QRTZ_
#org.quartz.jobStore.tablePrefix = QRTZ_
##\u662F\u5426\u52A0\u5165\u96C6\u7FA4
#org.quartz.jobStore.isClustered = false
##\u8C03\u5EA6\u5B9E\u4F8B\u5931\u6548\u7684\u68C0\u67E5\u65F6\u95F4\u95F4\u9694
#org.quartz.jobStore.clusterCheckinInterval = 20000
扫码关注我们
微信号:SRE实战
拒绝背锅 运筹帷幄