1,简单实例

Job接口包含唯一方法execute()，将任务逻辑添加到该方法中。

package com.wjb.quartz;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
/**
 * Created by wjb on 2017/6/16.
 */
public class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd:HH:mm:ss:SSS");
        System.out.println("测试quartz任务:" + format.format(Calendar.getInstance().getTime()));
    }
}

StdSchedulerFactory.getScheduler()返回一个可运行的实例，然后创建调度任务的JobDetail实例，并传递3个参数给构造方法。第一个参数是任务名，用于引用该任务。第二个参数是任务组名，这里使用默认名，任务组名用于引用集合起来的一组任务，如可以使用Scheduler.pauseJobGroup()来暂停一组任务，每个组中的任务名是唯一的。第三个参数是实现特定任务的类。创建JobDetail实例后，需要创建一个Trigger，这里使用的是SimpleTrigger类，它提供了JDK Timer风格的触发器行为。传递给SimpleTrigger构造方法的两个参数分别是触发器名和任务组名，触发器名在它所在的任务组中必须是唯一的。接下来是设置触发器的一些属性，setStartTime()是设置启动时间，setRepeatInterval()是设置重复间隔，setRepeatCount()是设置重复次数。最后，scheduler.start()启动调度，终止调度可以用stop()方法。

package com.wjb.quartz;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.text.SimpleDateFormat;
import java.util.Calendar;
/**
* Created by wjb on 2017/6/16.
*/
public class TestJob {
   public static void main(String[] args) {
       SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd:HH:mm:ss:SSS");
       System.out.println("开始时间:" + format.format(Calendar.getInstance().getTime()));
       try {
//            通过schedulerFactory获取一个调度器
           Scheduler scheduler = new StdSchedulerFactory().getScheduler();
//            创建jobDetail实例，绑定Job实现类,指明job的名称，所在组的名称，以及绑定job类
           JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity("wjb", "bboyGroup").build();
//            使用simpleTrigger规则
           Trigger trigger = TriggerBuilder.newTrigger().withIdentity("simpleTrigger", "triggerGroup")
                   .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withRepeatCount(8))
                   .startNow().build();


//            使用cornTrigger规则
//            Trigger trigger = TriggerBuilder.newTrigger().withIdentity("simpleTrigger","triggerGroup")
//                    .withSchedule(CronScheduleBuilder.cronSchedule("0/15 * * * * ? *"))
//                    .startNow().build();
//            把作业和触发器注册到任务调度中
           scheduler.scheduleJob(jobDetail, trigger);
//            启动调度
           scheduler.start();
       } catch (SchedulerException e) {
           e.printStackTrace();
       }
   }
}

2,线程实现5分钟执行一次数据查询

package com.apply.business;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
import com.apply.model.TWare;
import com.apply.service.WareService;

@Component
public class WareManager implements ApplicationContextAware, Runnable {
    private WareService wareService;
    private static ApplicationContext context = null;
    private static WareManager wareManager = new WareManager();
    private static Map<Integer, TWare> mapWare = new ConcurrentHashMap<Integer, TWare>();

    private WareManager() {
        
    }

    public static WareManager getInstance() {
        return wareManager;
    }
    
    public boolean isExist(Integer id) {
        return mapWare.containsKey(id);
    }
    
    public boolean isExist(BigDecimal price) {
        for (Integer key : mapWare.keySet()) {
            if (mapWare.get(key).getOriginal().equals(price)) {
                return true;
            }
        }
        
        return false;
    }
    
    public TWare getById(Integer id) {
        return mapWare.containsKey(id) ? mapWare.get(id) : null;
    }
    
    public List<TWare> getAll() {
        List<TWare> lstWare = new ArrayList<TWare>();
        for (Integer key : mapWare.keySet()) {
            lstWare.add(mapWare.get(key));
        }
        
        return lstWare;
    }

    @Override
    public void setApplicationContext(ApplicationContext context) throws BeansException {
        if (WareManager.context == null) {
            WareManager.context = context;
            this.wareService = context.getBean(WareService.class);
            new Thread(this).start();
        }
    }

    @Override
    public void run() {
        while (true) {
            try {
                List<TWare> lstWare = wareService.getAll();
                for (TWare ware : lstWare) {
                    mapWare.put(ware.getId(), ware);
                }
                
                Thread.sleep(300000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

3，springboot-quartz

SchedulerListener

package com.apply.config;

import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

/**
 * Created by Administrator on 2017/8/4.
 */
@Configuration
public class SchedulerListener implements ApplicationListener<ContextRefreshedEvent> {
    @Autowired
    public IndentScheduler indentScheduler;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        try {
            indentScheduler.scheduleJobs();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(){
        return new SchedulerFactoryBean();
    }
}

IndentScheduler

package com.apply.config;

import com.apply.utils.IndentJob;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Component;

/**
 * Created by Administrator on 2017/8/4.
 */
@Component
public class IndentScheduler {
    @Autowired
    private SchedulerFactoryBean schedulerFactoryBean;

    public void scheduleJobs() throws SchedulerException{
        Scheduler scheduler = schedulerFactoryBean.getScheduler();
        startJob(scheduler);
    }
    private void startJob(Scheduler scheduler) throws SchedulerException{
        JobDetail jobDetail = JobBuilder.newJob(IndentJob.class)
                .withIdentity("job1", "group1").build();
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");
        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
                .withSchedule(scheduleBuilder).build();
        scheduler.scheduleJob(jobDetail,cronTrigger);
    }
}

IndentJob

package com.apply.utils;

import com.apply.service.indent.IndentService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * Created by Administrator on 2017/8/4.
 */
public class IndentJob implements Job {
    @Autowired
    private IndentService indentService;

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.out.println("quartz测试");

    }
}

CronTrigger能够提供复杂的触发器表达式的支持。CronTrigger是基于Unix Cron守护进程，它是一个调度程序，支持简单而强大的触发器语法。使用CronTrigger主要的是要掌握Cron表达式。Cron表达式包含6个必要组件和一个可选组件，如下表所示。

Cron表达式举例：

"30 * * * * ?" 每半分钟触发任务
"30 10 * * * ?" 每小时的10分30秒触发任务
"30 10 1 * * ?" 每天1点10分30秒触发任务
"30 10 1 20 * ?" 每月20号1点10分30秒触发任务
"30 10 1 20 10 ? *" 每年10月20号1点10分30秒触发任务
"30 10 1 20 10 ? 2011" 2011年10月20号1点10分30秒触发任务
"30 10 1 ? 10 * 2011" 2011年10月每天1点10分30秒触发任务
"30 10 1 ? 10 SUN 2011" 2011年10月每周日1点10分30秒触发任务
"15,30,45 * * * * ?" 每15秒，30秒，45秒时触发任务
"15-45 * * * * ?" 15到45秒内，每秒都触发任务
"15/5 * * * * ?" 每分钟的每15秒开始触发，每隔5秒触发一次
"15-30/5 * * * * ?" 每分钟的15秒到30秒之间开始触发，每隔5秒触发一次
"0 0/3 * * * ?" 每小时的第0分0秒开始，每三分钟触发一次
"0 15 10 ? * MON-FRI" 星期一到星期五的10点15分0秒触发任务
"0 15 10 L * ?" 每个月最后一天的10点15分0秒触发任务
"0 15 10 LW * ?" 每个月最后一个工作日的10点15分0秒触发任务
"0 15 10 ? * 5L" 每个月最后一个星期四的10点15分0秒触发任务
"0 15 10 ? * 5#3" 每个月第三周的星期四的10点15分0秒触发任务