Springboot整个Quartz实现动态定时任务的示例代码

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

org.quartz.scheduler.instanceName = MySchedulerorg.quartz.scheduler.instanceId = AUTOorg.quartz.scheduler.rmi.export = falseorg.quartz.scheduler.rmi.proxy = falseorg.quartz.scheduler.wrapJobExecutionInUserTransaction = false#线程池配置org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPoolorg.quartz.threadPool.threadCount = 10org.quartz.threadPool.threadPriority = 5org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true#持久化配置org.quartz.jobStore.misfireThreshold = 50000org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX#支持集群org.quartz.jobStore.isClustered = trueorg.quartz.jobStore.useProperties:trueorg.quartz.jobStore.clusterCheckinInterval = 15000#使用weblogic连接Oracle驱动org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.weblogic.WebLogicOracleDelegate#org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegateorg.quartz.jobStore.tablePrefix = QRTZ_org.quartz.jobStore.dataSource = qzDS#数据源连接信息，quartz默认使用c3p0数据源可以被自定义数据源覆盖org.quartz.dataSource.qzDS.driver = oracle.jdbc.driver.OracleDriverorg.quartz.dataSource.qzDS.URL = jdbc:oracle:thin:@localhost:1521/XEorg.quartz.dataSource.qzDS.user = rootorg.quartz.dataSource.qzDS.password = 123456org.quartz.dataSource.qzDS.maxConnections = 10

//TB_APP_QUARTZ表的实体类public class AppQuartz {  private Integer quartzId; //id 主键  private String jobName; //任务名称  private String jobGroup; //任务分组  private String startTime; //任务开始时间  private String cronExpression; //corn表达式  private String invokeParam;//需要传递的参数  ...省略set get}

/** * 创建job 实例工厂，解决spring注入问题，如果使用默认会导致spring的@Autowired 无法注入问题 * @author LLQ * */@Componentpublic class JobFactory extends AdaptableJobFactory{  @Autowired  private AutowireCapableBeanFactory capableBeanFactory;     @Override    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {      //调用父类的方法      Object jobInstance = super.createJobInstance(bundle);      //进行注入      capableBeanFactory.autowireBean(jobInstance);      return jobInstance;    }}

@Configurationpublic class SchedulerConfig implements ApplicationListener<ContextRefreshedEvent>{    @Autowired  private JobFactory jobFactory;  @Autowired  @Qualifier("dataSource")  private DataSource primaryDataSource;    @Override   public void onApplicationEvent(ContextRefreshedEvent event) {    System.out.println("任务已经启动..."+event.getSource());  }    @Bean  public SchedulerFactoryBean schedulerFactoryBean() throws IOException {        //获取配置属性    PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();    propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));    //在quartz.properties中的属性被读取并注入后再初始化对象    propertiesFactoryBean.afterPropertiesSet();    //创建SchedulerFactoryBean    SchedulerFactoryBean factory = new SchedulerFactoryBean();    factory.setQuartzProperties(propertiesFactoryBean.getObject());    //使用数据源，自定义数据源    factory.setDataSource(this.primaryDataSource);    factory.setJobFactory(jobFactory);    factory.setWaitForJobsToCompleteOnShutdown(true);//这样当spring关闭时，会等待所有已经启动的quartz job结束后spring才能完全shutdown。    factory.setOverwriteExistingJobs(false);     factory.setStartupDelay(1);     return factory;  }      /*   * 通过SchedulerFactoryBean获取Scheduler的实例   */  @Bean(name="scheduler")  public Scheduler scheduler() throws IOException {    return schedulerFactoryBean().getScheduler();  }      @Bean  public QuartzInitializerListener executorListener() {    return new QuartzInitializerListener();  }}

@Servicepublic class JobUtil {   @Autowired   @Qualifier("scheduler")   private Scheduler scheduler;           /**   * 新建一个任务   *    */      public String addJob(AppQuartz appQuartz) throws Exception {            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");       Date date=df.parse(appQuartz.getStartTime());            if (!CronExpression.isValidExpression(appQuartz.getCronExpression())) {              return "Illegal cron expression";  //表达式格式不正确      }                    JobDetail jobDetail=null;      //构建job信息      if("JobOne".equals(appQuartz.getJobGroup())) {         jobDetail = JobBuilder.newJob(JobOne.class).withIdentity(appQuartz.getJobName(), appQuartz.getJobGroup()).build();      }      if("JobTwo".equals(appQuartz.getJobGroup())) {         jobDetail = JobBuilder.newJob(JobTwo.class).withIdentity(appQuartz.getJobName(), appQuartz.getJobGroup()).build();      }                //表达式调度构建器(即任务执行的时间,不立即执行)      CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(appQuartz.getCronExpression()).withMisfireHandlingInstructionDoNothing();      //按新的cronExpression表达式构建一个新的trigger      CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(appQuartz.getJobName(), appQuartz.getJobGroup()).startAt(date)          .withSchedule(scheduleBuilder).build();                       //传递参数      if(appQuartz.getInvokeParam()!=null && !"".equals(appQuartz.getInvokeParam())) {        trigger.getJobDataMap().put("invokeParam",appQuartz.getInvokeParam());        }                      scheduler.scheduleJob(jobDetail, trigger);      // pauseJob(appQuartz.getJobName(),appQuartz.getJobGroup());      return "success";    }      /**     * 获取Job状态     * @param jobName     * @param jobGroup     * @return     * @throws SchedulerException     */     public String getJobState(String jobName, String jobGroup) throws SchedulerException {              TriggerKey triggerKey = new TriggerKey(jobName, jobGroup);         return scheduler.getTriggerState(triggerKey).name();      }          //暂停所有任务     public void pauseAllJob() throws SchedulerException {             scheduler.pauseAll();     }        //暂停任务    public String pauseJob(String jobName, String jobGroup) throws SchedulerException {            JobKey jobKey = new JobKey(jobName, jobGroup);      JobDetail jobDetail = scheduler.getJobDetail(jobKey);      if (jobDetail == null) {         return "fail";      }else {         scheduler.pauseJob(jobKey);         return "success";      }                         }        //恢复所有任务    public void resumeAllJob() throws SchedulerException {            scheduler.resumeAll();    }        // 恢复某个任务    public String resumeJob(String jobName, String jobGroup) throws SchedulerException {            JobKey jobKey = new JobKey(jobName, jobGroup);      JobDetail jobDetail = scheduler.getJobDetail(jobKey);      if (jobDetail == null) {        return "fail";      }else {                scheduler.resumeJob(jobKey);        return "success";      }    }        //删除某个任务    public String deleteJob(AppQuartz appQuartz) throws SchedulerException {            JobKey jobKey = new JobKey(appQuartz.getJobName(), appQuartz.getJobGroup());      JobDetail jobDetail = scheduler.getJobDetail(jobKey);      if (jobDetail == null ) {         return "jobDetail is null";      }else if(!scheduler.checkExists(jobKey)) {        return "jobKey is not exists";      }else {         scheduler.deleteJob(jobKey);         return "success";      }           }        //修改任务    public String modifyJob(AppQuartz appQuartz) throws SchedulerException {            if (!CronExpression.isValidExpression(appQuartz.getCronExpression())) {        return "Illegal cron expression";      }      TriggerKey triggerKey = TriggerKey.triggerKey(appQuartz.getJobName(),appQuartz.getJobGroup());            JobKey jobKey = new JobKey(appQuartz.getJobName(),appQuartz.getJobGroup());      if (scheduler.checkExists(jobKey) && scheduler.checkExists(triggerKey)) {        CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);              //表达式调度构建器,不立即执行        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(appQuartz.getCronExpression()).withMisfireHandlingInstructionDoNothing();        //按新的cronExpression表达式重新构建trigger        trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)          .withSchedule(scheduleBuilder).build();        //修改参数        if(!trigger.getJobDataMap().get("invokeParam").equals(appQuartz.getInvokeParam())) {          trigger.getJobDataMap().put("invokeParam",appQuartz.getInvokeParam());        }                //按新的trigger重新设置job执行        scheduler.rescheduleJob(triggerKey, trigger);                                return "success";                }else {        return "job or trigger not exists";      }            }}

@PersistJobDataAfterExecution@DisallowConcurrentExecution@Componentpublic class JonOne implements Job{  @Override  public void execute(JobExecutionContext context) throws JobExecutionException{    JobDataMap data=context.getTrigger().getJobDataMap();    String invokeParam =(String) data.get("invokeParam");    //在这里实现业务逻辑    }}

@PersistJobDataAfterExecution@DisallowConcurrentExecution@Componentpublic class JobTwo implements Job{  @Override  public void execute(JobExecutionContext context) throws JobExecutionException{    JobDataMap data=context.getTrigger().getJobDataMap();    String invokeParam =(String) data.get("invokeParam");    //在这里实现业务逻辑    }}

@RestControllerpublic class JobController {  @Autowired  private JobUtil jobUtil;    @Autowired  private AppQuartzService appQuartzService;      //添加一个job  @RequestMapping(value="/addJob",method=RequestMethod.POST)  public ReturnMsg addjob(@RequestBody AppQuartz appQuartz) throws Exception {      appQuartzService.insertAppQuartzSer(appQuartz);        result=jobUtil.addJob(appQuartz);                          }    //暂停job    @RequestMapping(value="/pauseJob",method=RequestMethod.POST)  public ReturnMsg pausejob(@RequestBody Integer[]quartzIds) throws Exception {      AppQuartz appQuartz=null;          if(quartzIds.length>0){      for(Integer quartzId:quartzIds) {        appQuartz=appQuartzService.selectAppQuartzByIdSer(quartzId).get(0);        jobUtil.pauseJob(appQuartz.getJobName(), appQuartz.getJobGroup());                  }      return new ReturnMsg("200","success pauseJob");      }else {      return new ReturnMsg("404","fail pauseJob");      }                                  }    //恢复job  @RequestMapping(value="/resumeJob",method=RequestMethod.POST)  public ReturnMsg resumejob(@RequestBody Integer[]quartzIds) throws Exception {      AppQuartz appQuartz=null;    if(quartzIds.length>0) {      for(Integer quartzId:quartzIds) {        appQuartz=appQuartzService.selectAppQuartzByIdSer(quartzId).get(0);        jobUtil.resumeJob(appQuartz.getJobName(), appQuartz.getJobGroup());              }      return new ReturnMsg("200","success resumeJob");    }else {      return new ReturnMsg("404","fail resumeJob");    }        }         //删除job  @RequestMapping(value="/deletJob",method=RequestMethod.POST)  public ReturnMsg deletjob(@RequestBody Integer[]quartzIds) throws Exception {    AppQuartz appQuartz=null;    for(Integer quartzId:quartzIds) {      appQuartz=appQuartzService.selectAppQuartzByIdSer(quartzId).get(0);      String ret=jobUtil.deleteJob(appQuartz);      if("success".equals(ret)) {        appQuartzService.deleteAppQuartzByIdSer(quartzId);      }    }    return new ReturnMsg("200","success deleteJob");    }      //修改  @RequestMapping(value="/updateJob",method=RequestMethod.POST)  public ReturnMsg modifyJob(@RequestBody AppQuartz appQuartz) throws Exception {    String ret= jobUtil.modifyJob(appQuartz);          if("success".equals(ret)) {            appQuartzService.updateAppQuartzSer(appQuartz);      return new ReturnMsg("200","success updateJob",ret);    }else {      return new ReturnMsg("404","fail updateJob",ret);    }          }    //暂停所有  @RequestMapping(value="/pauseAll",method=RequestMethod.GET)  public ReturnMsg pauseAllJob() throws Exception {    jobUtil.pauseAllJob();    return new ReturnMsg("200","success pauseAll");  }    //恢复所有  @RequestMapping(value="/repauseAll",method=RequestMethod.GET)  public ReturnMsg repauseAllJob() throws Exception {    jobUtil.resumeAllJob();    return new ReturnMsg("200","success repauseAll");  }    }