- Timer:這是java自帶的java.util.Timer類,這個(gè)類允許你調(diào)度一個(gè)java.util.TimerTask任務(wù)刊侯。使用這種方式可以讓你的程序按照某一個(gè)頻度執(zhí)行章办,但不能在指定時(shí)間運(yùn)行。一般用的較少滨彻。
- ScheduledExecutorService:也jdk自帶的一個(gè)類藕届;是基于線程池設(shè)計(jì)的定時(shí)任務(wù)類,每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的一個(gè)線程去執(zhí)行,也就是說,任務(wù)是并發(fā)執(zhí)行,互不影響。
- Spring Task:Spring3.0以后自帶的task疮绷,可以將它看成一個(gè)輕量級(jí)的Quartz翰舌,而且使用起來比Quartz簡單許多。
- Quartz:這是一個(gè)功能比較強(qiáng)大的的調(diào)度器冬骚,可以讓你的程序在指定時(shí)間執(zhí)行,也可以按照某一個(gè)頻度執(zhí)行懂算,配置起來稍顯復(fù)雜只冻。
Timer方法
public class TestTimer {
public static void main(String[] args) {
TimerTask timerTask = new TimerTask() {
@Override
public void run() {
System.out.println("task run:"+ new Date());
}
};
Timer timer = new Timer();
//安排指定的任務(wù)在指定的時(shí)間開始進(jìn)行重復(fù)的固定延遲執(zhí)行。這里是每3秒執(zhí)行一次
timer.schedule(timerTask,10,3000);
}
}
使用ScheduledExecutorService
該方法跟Timer方法類似计技,可直接看demo
public class TestScheduledExecutorService {
public static void main(String[] args) {
ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
// 參數(shù):1喜德、任務(wù)體 2、首次執(zhí)行的延時(shí)時(shí)間
// 3垮媒、任務(wù)執(zhí)行間隔 4舍悯、間隔時(shí)間單位
service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+new Date()), 0, 3, TimeUnit.SECONDS);
}
}
使用SpringTask
- 首先新建項(xiàng)目,添加依賴
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
- 創(chuàng)建任務(wù)類
@Slf4j
@Component
public class ScheduledService {
@Scheduled(cron = "0/5 * * * * *")
public void scheduled(){
log.info("=====>>>>>使用cron {}",System.currentTimeMillis());
}
@Scheduled(fixedRate = 5000)
public void scheduled1() {
log.info("=====>>>>>使用fixedRate{}", System.currentTimeMillis());
}
@Scheduled(fixedDelay = 5000)
public void scheduled2() {
log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
}
}
- 在主類上使用@EnableScheduling注解開啟對(duì)定時(shí)任務(wù)的支持睡雇,然后啟動(dòng)項(xiàng)目
可以看到三個(gè)定時(shí)任務(wù)都已經(jīng)執(zhí)行萌衬,并且使同一個(gè)線程中串行執(zhí)行,如果只有一個(gè)定時(shí)任務(wù)它抱,這樣做肯定沒問題秕豫,當(dāng)定時(shí)任務(wù)增多,如果一個(gè)任務(wù)卡死观蓄,會(huì)導(dǎo)致其他任務(wù)也無法執(zhí)行混移。
多線程執(zhí)行
在傳統(tǒng)的Spring項(xiàng)目中,我們可以在xml配置文件添加task的配置侮穿,而在SpringBoot項(xiàng)目中一般使用config配置類的方式添加配置歌径,所以新建一個(gè)AsyncConfig類
@Configuration
@EnableAsync
public class AsyncConfig {
/*
此處成員變量應(yīng)該使用@Value從配置中讀取
*/
private int corePoolSize = 10;
private int maxPoolSize = 200;
private int queueCapacity = 10;
@Bean
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setQueueCapacity(queueCapacity);
executor.initialize();
return executor;
}
}
@Configuration:表明該類是一個(gè)配置類
@EnableAsync:開啟異步事件的支持
然后在定時(shí)任務(wù)的類或者方法上添加@Async 。最后重啟項(xiàng)目亲茅,每一個(gè)任務(wù)都是在不同的線程中
執(zhí)行時(shí)間的配置
在上面的定時(shí)任務(wù)中回铛,我們?cè)诜椒ㄉ鲜褂聾Scheduled注解來設(shè)置任務(wù)的執(zhí)行時(shí)間金矛,并且使用三種屬性配置方式:
- fixedRate:定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)
- fixedDelay:定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù),與上面不同的是勺届,改屬性可以配合initialDelay驶俊, 定義該任務(wù)延遲執(zhí)行時(shí)間。
- cron:通過表達(dá)式來配置任務(wù)執(zhí)行時(shí)間
cron表達(dá)式詳解
在線cron表達(dá)式生成:http://qqe2.com/cron/index
整合Quartz
- 添加依賴
如果SpringBoot版本是2.0.0以后的免姿,則在spring-boot-starter中已經(jīng)包含了quart的依賴饼酿,則可以直接使用spring-boot-starter-quartz依賴:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
如果是1.5.9則要使用以下添加依賴:
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
- 創(chuàng)建任務(wù)類TestQuartz,該類主要是繼承了QuartzJobBean
public class TestQuartz extends QuartzJobBean {
/**
* 執(zhí)行定時(shí)任務(wù)
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println("quartz task "+new Date());
}
}
- 創(chuàng)建配置類QuartzConfig
@Configuration
public class QuartzConfig {
@Bean
public JobDetail teatQuartzDetail(){
return JobBuilder.newJob(TestQuartz.class).withIdentity("testQuartz").storeDurably().build();
}
@Bean
public Trigger testQuartzTrigger(){
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10) //設(shè)置時(shí)間周期單位秒
.repeatForever();
return TriggerBuilder.newTrigger().forJob(teatQuartzDetail())
.withIdentity("testQuartz")
.withSchedule(scheduleBuilder)
.build();
}
}
- 啟動(dòng)項(xiàng)目
注:該文章部分摘自https://blog.csdn.net/wqh8522/article/details/79224290