• 1、匯入依賴：

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

• 2、在專案中新增quartz.properties檔案（這樣就不會走它自帶的properties檔案）

#quartz叢集配置  
 

# ===========================================================================    
# Configure Main Scheduler Properties 排程器屬性    
# ===========================================================================  
#排程標識名 叢集中每一個例項都必須使用相同的名稱    
org.quartz.scheduler.instanceName=DefaultQuartzScheduler
#ID設定為自動獲取 每一個必須不同  
 

org.quartz.scheduler.instanceid=AUTO
#============================================================================  
# Configure ThreadPool    
#============================================================================  
#執行緒池的實現類（一般使用SimpleThreadPool即可滿足幾乎所有使用者的需求）  
org.quartz.threadPool.class
 
 = org.quartz.simpl.SimpleThreadPool
#指定執行緒數，至少為1（無預設值）(一般設定為1-100直接的整數合適)  
org.quartz.threadPool.threadCount = 5
#設定執行緒的優先順序（最大為java.lang.Thread.MAX_PRIORITY 10，最小為Thread.MIN_PRIORITY 1，預設為5）   
org.quartz.threadPool.threadPriority = 5
#============================================================================  
# Configure JobStore    
#============================================================================  
# 資訊儲存時間 預設值60秒   
org.quartz.jobStore.misfireThreshold = 60000
#資料儲存方式為資料庫持久化  
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
#資料庫代理類，一般org.quartz.impl.jdbcjobstore.StdJDBCDelegate可以滿足大部分資料庫  
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#使用自己的配置檔案
org.quartz.jobStore.useProperties = true
#資料庫別名 隨便取  
org.quartz.jobStore.dataSource = myDS
#表的字首，預設QRTZ_  
org.quartz.jobStore.tablePrefix = qrtz_
#是否加入叢集  
org.quartz.jobStore.isClustered = false
#排程例項失效的檢查時間間隔  
org.quartz.jobStore.clusterCheckinInterval = 20000
#============================================================================  
# Configure Datasources    
#============================================================================  
#資料庫引擎  
org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
#資料庫連線  
org.quartz.dataSource.myDS.URL = jdbc:mysql://127.0.0.1:3306/quartz?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true
#資料庫使用者  
org.quartz.dataSource.myDS.user = root
#資料庫密碼  
org.quartz.dataSource.myDS.password = cym
#允許最大連線  
org.quartz.dataSource.myDS.maxConnections = 50
#驗證查詢sql,可以不設定  
#org.quartz.dataSource.myDS.validationQuery=select 0 from dual

• 3 、 在資料庫中建立quartz相關的表

  進入quartz的官網http://www.quartz-scheduler.org/，點選Downloads，下載後在目錄\docs\dbTables下有常用資料庫建立quartz表的指令碼。

• 4 、註冊相關的bean

  • 自定義AutowiringSpringBeanJobFactory，解決spring不能在quartz中注入bean的問題

package com.cci.eclickup.common.configuration.quartz;

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

/**
 * @Author: Kingcym
 * @Description:
 * @Date: 2017/12/14 0:31
 */
public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements
        ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

    @Override
    public void setApplicationContext(final ApplicationContext context) {
        beanFactory = context.getAutowireCapableBeanFactory();
    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
        final Object job = super.createJobInstance(bundle);
        beanFactory.autowireBean(job);
        return job;
    }
}

註冊SchedulerFactoryBean的bean

package com.cci.eclickup.common.configuration.quartz;

import org.quartz.spi.JobFactory;
import org.springframework.beans.factory.config.PropertiesFactoryBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

import java.util.Properties;

/**
 * @Author: Kingcym
 * @Description:
 * @Date: 2017/12/13 23:45
 */
@Configuration
public class QuartzConfig {
    public static final String QUARTZ_PROPERTIES_PATH = "/quartz.properties";

    @Bean
    public JobFactory jobFactory(ApplicationContext applicationContext) {
        AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
        jobFactory.setApplicationContext(applicationContext);
        return jobFactory;
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean( JobFactory jobFactory) {
        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
        schedulerFactoryBean.setJobFactory(jobFactory);
        schedulerFactoryBean.setStartupDelay(20);
        //用於quartz叢集,載入quartz資料來源配置
        schedulerFactoryBean.setQuartzProperties(quartzProperties());
        return schedulerFactoryBean;
    }

    public Properties quartzProperties(){
        PropertiesFactoryBean factoryBean = new PropertiesFactoryBean();
        factoryBean.setLocation(new ClassPathResource(QUARTZ_PROPERTIES_PATH));
        try {
            factoryBean.afterPropertiesSet();
            return factoryBean.getObject();
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
}

定義JobDetail，Trigger

package com.cci.eclickup.common.configuration.quartz;

import com.cci.eclickup.cn.task.CheckStatusTask;
import com.cci.eclickup.cn.task.InsertEvaluateTask;
import org.apache.log4j.Logger;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

import static org.quartz.CronScheduleBuilder.cronSchedule;

/**
 * @Author: Kingcym
 * @Description:
 * @Date: 2017/12/14 0:14
 */
@Component
public class QuartzScheduler {
    @SuppressWarnings("SpringJavaAutowiringInspection")
    @Autowired
    private SchedulerFactoryBean schedulerFactoryBean;

    private Logger logger = Logger.getLogger(QuartzScheduler.class);


    @PostConstruct
    public void init() throws SchedulerException {
        scheduleJobs();
    }

    public void scheduleJobs() throws SchedulerException {
        logger.info("=======任務初始化========");
        Scheduler scheduler = schedulerFactoryBean.getScheduler();
        //需要傳遞資料,就是使用JobDataMa
 //       JobDataMap jobDataMap = new JobDataMap();
 //       jobDataMap.put("jobArg", "world");
         //CheckStatusTask.class 是需要執行定時任務的類名
        JobDetail jobDetail = JobBuilder.newJob(CheckStatusTask.class)
  //              .setJobData(jobDataMap)
                .withDescription("CheckStatusTask")
                .withIdentity("job-CheckStatus", "demo-group")
                .build();
        //InsertEvaluateTask.class 是需要執行定時任務的類名
        JobDetail jobDetail2 = JobBuilder.newJob(InsertEvaluateTask.class)
    //            .setJobData(jobDataMap)
                .withDescription("InsertEvaluateTask")
                .withIdentity("job-InsertEvaluate", "demo-group")
                .build();

        Trigger trigger = TriggerBuilder.newTrigger()
                .forJob(jobDetail)
                .withSchedule(cronSchedule("0 0/2 * * * ? "))
                .build();

        Trigger trigger2 = TriggerBuilder.newTrigger()
                .forJob(jobDetail2)
                .withSchedule(cronSchedule("0 0/1 * * * ? "))
                .build();

        try {
            if(!scheduler.checkExists(JobKey.jobKey("job-CheckStatus","demo-group"))){
                scheduler.scheduleJob(jobDetail,trigger);
            }
            if(!scheduler.checkExists(JobKey.jobKey("job-InsertEvaluate","demo-group"))){
                scheduler.scheduleJob(jobDetail2,trigger2);
            }
            scheduler.start();
            logger.info("=======任務初始化完成========");
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}

• 5 定義定時任務，只需繼承Job介面，實現execute方法

package com.cci.eclickup.cn.task;



import com.cci.eclickup.cn.service.EclickupService;
import org.apache.log4j.Logger;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


/**
 * @Description: 定時重新整理z_check_evaluate裡的checkStatus
 * @author cym
 * @date 2017年12月14日 上午12:04:40
 * @version V1.0
 */
@PersistJobDataAfterExecution
@DisallowConcurrentExecution
@Component
public class CheckStatusTask implements Job {

    private Logger log = Logger.getLogger(CheckStatusTask.class);

    @Autowired
    private EclickupService eclickupService;

    public void execute(JobExecutionContext context) throws JobExecutionException {
        log.info("===============定時重新整理z_check_evaluate裡的checkStatus 開始==============");
        int result = eclickupService.editCheckStatus();
        if (result > 0)
            log.info("===============定時重新整理z_check_evaluate裡的checkStatus 成功==============個數："+result);
    }

}