一、springboot与quartz的整合
一、背景1.因为需求需要,所以我们用到了定时任务,但是之前使用的定时任务是基于spring的xml形式,但是在微服务的模块中这显然不太合适,因为单独的模块,做成了独立的服务,所以我最终选择了基于注解的方式来完成我们的需求。2.所以我写了一个小demo来让大家借鉴先怎么使用springboot与quartz的合起来使用。下面我们就进入今天的学习内容。二、quartz的简介1.Quar...
一、背景
1.因为需求需要,所以我们用到了定时任务,但是之前使用的定时任务是基于spring的xml形式,但是在微服务的模块中这显然不太合适,因为单独的模块,做成了独立的服务,所以我最终选择了基于注解的方式来完成我们的需求。
2.所以我写了一个小demo来让大家借鉴先怎么使用springboot与quartz的合起来使用。下面我们就进入今天的学习内容。
二、quartz的简介
1.Quartz是一个开源的任务调度框架。基于定时、定期的策略来执行任务是它的核心功能,比如x年x月的每个星期五上午8点到9点,每隔10分钟执行1次。
2.Quartz有3个核心要素:调度器(Scheduler)、任务(Job)、触发器(Trigger)。
2.1.Job(任务):是一个接口,有一个方法void execute(),可以通过实现该接口来定义需要执行的任务(具体的逻辑代码)。
2.2.JobDetail:Quartz每次执行job时,都重新创建一个Job实例,会接收一个Job实现类,以便运行的时候通过newInstance()的反射调用机制去实例化Job.JobDetail是用来描述Job实现类以及相关静态信息,比如任务在scheduler中的组名等信息。
2.3.Trigger(触发器):描述触发Job执行的时间触发规则实现类SimpleTrigger和CronTrigger可以通过crom表达式定义出各种复杂的调度方案。
2.4.Calendar:是一些日历特定时间的集合。一个Trigger可以和多个 calendar关联,比如每周一早上10:00执行任务,法定假日不执行,则可以通过calendar进行定点排除。
2.5.Scheduler(调度器):代表一个Quartz的独立运行容器。Trigger和JobDetail可以注册到Scheduler中。Scheduler可以将Trigger绑定到某一JobDetail上,这样当Trigger被触发时,对应的Job就会执行。一个Job可以对应多个Trigger,但一个Trigger只能对应一个Job.
三、代码结构图
1.项目结构
四、具体的代码分析
1.pom.xml
<!--spring boot集成quartz-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
2.DateTimeJob.java(具体的业务逻辑代码写在这里)
public class DateTimeJob extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
//获取JobDetail中关联的数据
String msg = (String) jobExecutionContext.getJobDetail().getJobDataMap().get("msg");
System.out.println("current time :"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "---" + msg);
}
}
3.QuartzConfig.java(配置类)
@Configuration
public class QuartzConfig {
@Bean
public JobDetail printTimeJobDetail(){
return JobBuilder.newJob(DateTimeJob.class)//PrintTimeJob我们的业务类
.withIdentity("DateTimeJob")//可以给该JobDetail起一个id
//每个JobDetail内都有一个Map,包含了关联到这个Job的数据,在Job类中可以通过context获取
.usingJobData("msg", "Hello Quartz")//关联键值对
.storeDurably()//即使没有Trigger关联时,也不需要删除该JobDetail
.build();
}
@Bean
public Trigger printTimeJobTrigger() {
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/1 * * * * ?");
return TriggerBuilder.newTrigger()
.forJob(printTimeJobDetail())//关联上述的JobDetail
.withIdentity("quartzTaskService")//给Trigger起个名字
.withSchedule(cronScheduleBuilder)
.build();
}
}
五、结果
六、结束
这就完成了我们的定时任务!!!希望能帮助到大家。
更多推荐
所有评论(0)