23、springboot集成quartz

"http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0

spring-cloud
sc-scheduled
0.0.1-SNAPSHOT
jar

sc-scheduled
http://maven.apache.org


org.springframework.boot
spring-boot-starter-parent
2.0.4.RELEASE





org.springframework.cloud
spring-cloud-dependencies
Finchley.RELEASE
pom
import






UTF-8
1.8
1.8



org.springframework.boot
spring-boot-starter



org.springframework.boot
spring-boot-starter-web








org.springframework.boot
spring-boot-starter-quartz

package sc.schedule;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling // 开启spring自带定时任务
public class ScheduledApplication {

public static void main(String[] args) {
SpringApplication.run(ScheduledApplication.class, args);
}

}

package sc.schedule.spring;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class SpringScheduled {

// 每1分钟执行一次

@Scheduled(cron = "0 */1 * * * * ")
public void reportCurrentByCron() {
System.out.println("Spring Scheduling Tasks: " + dateFormat().format(new Date()));
}

private SimpleDateFormat dateFormat() {
return new SimpleDateFormat("HH:mm:ss");
}
}

package sc.schedule.quartz;

import org.quartz.JobDetail;
import org.quartz.Trigger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

@Configuration
public class QuartzScheduledOne {

@Bean
public ScheduledJobOne getScheduledJobOne() {
return new ScheduledJobOne();
}

/**
* 调度工厂
*
* @param jobTrigger
* 触发器
* @return
*/
@Bean(name = "scheduler")
public SchedulerFactoryBean schedulerFactory(Trigger jobTrigger) {
SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
// 用于quartz集群,QuartzScheduler 启动时更新己存在的Job

factoryBean.setOverwriteExistingJobs(true);
// 延时启动，应用启动1秒后

factoryBean.setStartupDelay(1);
// 注册触发器

factoryBean.setTriggers(jobTrigger);
return factoryBean;
}

/**
*
* 定时触发器
*
* @param reptilianJob
* 任务
*
* @return
*
*/
@Bean(name = "jobTrigger")
public CronTriggerFactoryBean cronJobTrigger(JobDetail jobDetail) {
CronTriggerFactoryBean tigger = new CronTriggerFactoryBean();
tigger.setJobDetail(jobDetail);
// cron表达式，每1分钟执行一次

tigger.setCronExpression("0/20 * * * * ?");
tigger.setName("jobTrigger");
return tigger;
}

/**
* 配置任务
*
* @param quartzTask
* QuartzTask为需要执行的任务
* @return
*/
@Bean(name = "jobDetail")
public MethodInvokingJobDetailFactoryBean detailFactoryBean(ScheduledJobOne quartzTask) {
MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
// 是否并发执行

jobDetail.setConcurrent(false);
// 设置任务的名字

jobDetail.setName("jobDetail");
// 设置任务的分组，在多任务的时候使用

jobDetail.setGroup("jobDetailGroup");
// 需要执行的对象

jobDetail.setTargetObject(quartzTask);
/*
* TODO非常重要 执行QuartzTask类中的需要执行方法
*/
jobDetail.setTargetMethod("execute");
return jobDetail;
}

}