Quartz定时任务Spring FrameWork整合

spring 版本是4.3.6

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);

    @Override
    protected 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.SimpleThreadPool


org.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的监听器(六)