spring 版本是4.3.6
Quartz 整合spring
- Quarz Job类使用spring bean
- Quartz配置 quartz.properties
Quarz Job类使用spring bean
<!-- ======================== 调度工厂 ======================== --><bean id="schedulerFactoryBean" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="dataSource" ref="dataSource"></property><property name="configLocation" value="classpath:quartz.properties" /><!--spring上下文名称--><property name="applicationContextSchedulerContextKey" value="applicationContext" /></bean>
然后取得时候代码,这样就能取到spring bean
public class Job extends QuartzJobBean {private static final Logger log = LoggerFactory.getLogger(OpenLiveJob.class);@Overrideprotected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {//通过 jobExecutionContext 来获取对象String jobName = jobExecutionContext.getJobDetail().getKey().getName();String jobGroupName = jobExecutionContext.getJobDetail().getKey().getGroup();//获取上下文ApplicationContext applicationContext = null;try {applicationContext = (ApplicationContext) (jobExecutionContext.getScheduler().getContext().get("applicationContext"));} catch (SchedulerException e) {log.error("applicationContext is error = {}", e);throw new JobExecutionException("applicationContext get error");}}
Quartz配置 quartz.properties
#===========================================
#Configure Main Scheduler Properties 调度器属性
#===========================================
#集群中应用采用相同的Scheduler实例
org.quartz.scheduler.instanceName: DefaultQuartzScheduler
#集群节点的ID必须唯一,可由quartz自动生成
org.quartz.scheduler.instanceId: AUTO#通知Scheduler实例要它参与到一个集群当中
org.quartz.jobStore.isClustered: true
#===========================================
#Configure ThreadPool 线程池属性
#处理Job的线程个数,至少为1,但最多的话最好不要超过100,在多数机器上设置该值超过100的话就会显得相当不适用,特别是在Job执行时间较长的情况下
org.quartz.threadPool.threadCount: 5
#线程的优先级,优先级别高的线程比级别低的线程优先得到执行。最小为1,最大为10,默认为5
org.quartz.threadPool.threadPriority: 5
#一个实现了 org.quartz.spi.ThreadPool 接口的类,Quartz 自带的线程池实现类是 org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPoolorg.quartz.jobStore.misfireThreshold: 20000#持久化
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
##驱动代理为 标准的jdbc
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#数据库表前缀
org.quartz.jobStore.tablePrefix=qrtz_#系统关闭时插件
org.quartz.plugin.shutdownhook.class=org.quartz.plugins.management.ShutdownHookPlugin
org.quartz.plugin.shutdownhook.cleanShutdown = true
#配置自定义的插件日志逻辑
org.quartz.plugin.DBLoggingJobHistoryPlugin.class=com.suning.lv.serviceimpl.quartz.plugin.DBLoggingJobHistoryPlugin
对于quartz 运行过程中的时间记录,我这次使用的是quartz 自定义插件,给了很多事件回调的地方,可以记录到数据库汇总,参考下面这篇文章,获取springbean 方式和上面列的一致
自定义插件
Quartz的监听器(六)