SpringBoot2.x学习笔记——定时任务使用与持久化

<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-webartifactId>
dependency>

package com.springboot.demo.scheduled;


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


import java.util.Date;


@Component
public class ScheduledDemo {
@Scheduled(fixedDelay = 1000)
public void fixedDelay()
{
System.out.println("fixedDelay:"+new Date());
}
@Scheduled(fixedRate=2000)
public void fixedRate()
{
System.out.println("fixedRate:"+new Date());
}
@Scheduled(initialDelay = 1000,fixedRate = 2000)
public void initialDelay()
{
System.out.println("initialDelay:"+new Date());
}
@Scheduled(cron = "0 * * * * ?")
public void cron()
{
System.out.println("cron---------"+new Date());
}
}



<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-quartzartifactId>
dependency>

@Component
public class FirstJob {
public void firstJobTest()
{
System.out.println("firstJob-------"+new Date());
}
}


@Component
public class SecondJob extends QuartzJobBean {
private String message;


public void setMessage(String message) {
this.message = message;
}


@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println("info------"+message+"--------"+new Date());
}
}

@Configuration
public class QuartzConfig {
/**
* 通过 MethodInvokingJobDetailFactoryBean配置JobDetail
* @return JobBean
*/
@Bean
MethodInvokingJobDetailFactoryBean getFirstJobDetail()
{
MethodInvokingJobDetailFactoryBean firstJobBean=new MethodInvokingJobDetailFactoryBean();
firstJobBean.setTargetBeanName("firstJob");
firstJobBean.setTargetMethod("firstJobTest");
return firstJobBean;
}
@Bean
JobDetailFactoryBean getSecondJobDetail()
{
JobDetailFactoryBean secOndJob=new JobDetailFactoryBean();
secondJob.setJobClass(SecondJob.class);
//设置参数
JobDataMap dataMap=new JobDataMap();
dataMap.put("message","quartzJobInfo");
secondJob.setJobDataMap(dataMap);
        secondJob.setDurability(true);
return secondJob;
}


/**
* 简易触发器
* @return 简易触发器实例
*/
@Bean
SimpleTriggerFactoryBean getSimpleTrigger()
{
//初始化简易触发器
SimpleTriggerFactoryBean simpleTriggerBean=new SimpleTriggerFactoryBean();
//为触发器绑定定时任务
simpleTriggerBean.setJobDetail(getFirstJobDetail().getObject());
//设置定时任务执行次数
simpleTriggerBean.setRepeatCount(3);
//定时任务初始化执行延迟时间
simpleTriggerBean.setStartDelay(1000);
//定时任务执行时间间隔
simpleTriggerBean.setRepeatInterval(2000);
return simpleTriggerBean;
}


/**
* Crom表达式触发器
* @return cron表达式触发器实例
*/
@Bean
CronTriggerFactoryBean getCronTrigger()
{
//初始化Cron表达式触发器
CronTriggerFactoryBean crOnTrigger=new CronTriggerFactoryBean();
//触发器绑定定时任务
cronTrigger.setJobDetail(getSecondJobDetail().getObject());
//设置cron表达式
cronTrigger.setCronExpression("0 * * * * ? ");
return cronTrigger;
}


/**
* 创建定时任务工厂并设置触发器
* @return 定时任务工厂
*/
@Bean
SchedulerFactoryBean getSchedulerFactory()
{
//初始化定时任务工厂实例
SchedulerFactoryBean schedulerFactory=new SchedulerFactoryBean();
//获取绑定定时任务后的触发器
SimpleTrigger simpleTrigger=getSimpleTrigger().getObject();
CronTrigger crOnTrigger=getCronTrigger().getObject();
//为定时任务工厂设置触发器
schedulerFactory.setTriggers(simpleTrigger,cronTrigger);
//返回定时任务工厂
return schedulerFactory;
}


}



@EnableScheduling
public class DemoApplication {


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


}