一、使用SpringBoot實現定時任務
這個不是重點,就簡單的實現一下,至于cron表達式怎么寫也不是重點,自行百度即可。
1-1、基于?@Scheduled?注解的方式
import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;@Component@EnableSchedulingpublic class XdxOne { @Scheduled(cron = "*/1 * * * * ?") public void testOne(){ System.out.println("one " + " "+ Thread.currentThread().getName()); }}
1-2、基于SchedulingConfigurer接口實現
import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;import java.util.Date;@Component // 1.主要用于標記配置類,兼備Component的效果。@EnableScheduling // 2.開啟定時任務public class XdxTestOne implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { Runnable task = new Runnable() { @Override public void run() { Thread t = Thread.currentThread(); String name = t.getName(); System.out.println("XdxTestOne=" + name); } }; Trigger trigger = new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { // 這里我們可以通過去數據庫獲取cron表達式,從而實現動態 CronTrigger trigger = new CronTrigger("*/3 * * * * ?"); Date nextExec = trigger.nextExecutionTime(triggerContext); return nextExec; } }; scheduledTaskRegistrar.addTriggerTask(task, trigger); }}
上面兩種方式都可以實現定時任務,毫無疑問注解方式實現起來更為舒服。但假如你不想把這個cron表達式寫死,對于注解方式我們可能無可奈何(也可能是我沒有找到方法)。但是對于接口的方式,我們可以在設置的時候去數據庫獲取,這樣就實現了動態。
接口方式的定時任務每次執行的時候,都會去執行那個獲取cron的方法。
二、異步實現
上面只是簡單的實現了定時任務,一般來說也沒有什么問題,但是上面的方式是一個線程挨個執行定時任務,這就會導致比如你某個線程是1s執行一次,但是你另外一個定時任務執行一次需要10min,那么你的這個定時任務就會被阻塞。?
? 一般來說可能也不重要,因為只要最后執行就好了,但有時卻是致命的,比我在工作中有一個定時任務是及時去同步數據來處理,這個時候阻塞了就是致命的。因此我們需要開啟異步執行,也就是多線程執行,這樣你一個定時任務阻塞了,還有另外的線程去執行我們的定時任務。
2-1、對于使用@Scheduled注解方式實現異步
我們可以使用?@Async?注解實現異步(異步方法使用注解@Async的返回值只能為void或者Future),把@Async加在類或者方法上面,然后還需要一個?@EnableAsync來開啟異步。
@EnableAsync可以加在啟動類上面這樣可以直接開啟所有的異步,也可以單獨加在每個類上面。
2-1-1:版本差異
springBoot2.0 和 springBoot2.2 默認的線程池是不一樣的,2.0默認線程池每開啟一個新的任務都是新開一個線程的。2.2默認線程池有8個。
如果你的定時任務比較少,并且執行時間比較短其實上面兩種都沒啥關系。但是如果定時任務多且慢,那么2.0每次創建一個線程可能導致JVM掛掉,而2.2只有8個線程也會滿足不了,會導致任務等待。
2-1-2:自定義線程池
創建一個線程池:
import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;@Configuration@EnableAsyncpublic class AsyncConfig { @Bean(name = "taskExecutor") public ThreadPoolTaskExecutor asyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 核心線程數 executor.setCorePoolSize(10); // 最大線程數 executor.setMaxPoolSize(50); // 隊列最大長度 executor.setQueueCapacity(1000); // 線程池維護線程所允許的空閑時間 executor.setKeepAliveSeconds(100); // 線程前綴 executor.setThreadNamePrefix("AsyncExecutorThread-"); // 線程池對拒絕任務(無線程可用)的處理策略 executor.setRejectedExecutionHandler(new CallerRunsPolicy()); executor.initialize(); return executor; }}
我們創建了上面的線程池后,所有的任務都將使用這個線程池里面的線程(可以通過輸出線程名查看)
但是如果我們有多個線程池的時候,這個時候我們可以使用?@Async(“name”)?name就是線程池的名字,沒有寫name的時候默認使用bean為taskExecutor?的線程池。
2-2、對于使用接口的方式實現異步
而對于使用注解的定時任務,如果你沒有使用@Async注解給它指定線程池(可以理解默認name = taskExecutor,如果你沒有taskExecutor線程池就會使用默認線程池),它也會使用接口里面創建的線程池進行調用。
三、其它
@EnableScheduling注解是開啟定時任務的,隨便放在那里都可以,只需要一個。