淺談在springboot中使用定時(shí)任務(wù)的方式
更新時(shí)間：2021年06月29日 14:38:32 作者：拍打醒
今天給大家?guī)淼氖顷P(guān)于Java的相關(guān)知識(shí),文章圍繞著在springboot中使用定時(shí)任務(wù)的方式展開,文中有非常詳細(xì)的介紹及代碼示例,需要的朋友可以參考下
springboot定時(shí)任務(wù)
在springboot環(huán)境下有多種方法，這里記錄下使用過的其中兩種；1、使用注解，2、通過實(shí)現(xiàn)接口的方式。
使用注解的方式雖然比較簡(jiǎn)單，但是如果項(xiàng)目需要用戶對(duì)定時(shí)周期進(jìn)行修改操作，只使用注解就比較難實(shí)現(xiàn)。所以可以使用實(shí)現(xiàn)接口的方式。通過對(duì)接口的實(shí)現(xiàn)，可以在項(xiàng)目運(yùn)行時(shí)根據(jù)需要修改任務(wù)執(zhí)行周期，只需要關(guān)閉原任務(wù)再開啟新任務(wù)即可。
1、使用注解方式
首先需要在啟動(dòng)類下添加 @EnableScheduling 注解（@EnableAsync是開啟異步的注解）
package com.fongtech.cli;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@MapperScan("com.fongtech.cli.mbg.*.**")
@EnableAsync
@EnableScheduling
public class SpringbootAdminApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootAdminApplication.class, args);
}
}
接著在需要用到定時(shí)任務(wù)的類和方法下加 @Component 和 @Scheduled(cron = "0 0/1 * * * ? ")注解，其中@Scheduled()中的 ‘cron' 有固定的格式。（@Async注解表示開啟異步）
@Slf4j
@Component
public class AsyncTaskConfiguration {
/**
* 每分鐘檢查任務(wù)列表，判斷任務(wù)類型執(zhí)行相應(yīng)的任務(wù)
* 根據(jù)實(shí)際任務(wù)執(zhí)行情況，限定執(zhí)行任務(wù)數(shù)量
*/
@Scheduled(cron = "0 0/1 * * * ? ")
@Async
public void startCommonTask() throws Exception {
log.info("startCommonTask start........." + Thread.currentThread().getName());
commonTaskService.startCommonTask();
log.info("startCommonTask end........." + Thread.currentThread().getName());
}}
2、使用實(shí)現(xiàn)接口的方式
通過實(shí)現(xiàn) SchedulingConfigurer 接口，可對(duì)定時(shí)任務(wù)進(jìn)行操作。實(shí)現(xiàn)接口的方式相比使用注解更加靈活，但需要編寫代碼，相對(duì)繁瑣。
實(shí)現(xiàn)工具類如下：
package com.fongtech.cli.admin.tasktime;
import com.fongtech.cli.common.util.BeanUtils;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.SchedulingException;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.config.TriggerTask;
import org.springframework.scheduling.support.CronTrigger;
import javax.annotation.PostConstruct;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ScheduledFuture;
/**
* @author linb
* @date 2020/6/15 11:16
*/
@Configuration
//@EnableScheduling
public class DefaultSchedulingConfigurer implements SchedulingConfigurer {
private ScheduledTaskRegistrar taskRegistrar;
private Set<ScheduledFuture<?>> scheduledFutures = null;
private Map<String, ScheduledFuture<?>> taskFutures = new ConcurrentHashMap<>();
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
this.taskRegistrar = taskRegistrar;
}
@SuppressWarnings("unchecked")
private Set<ScheduledFuture<?>> getScheduledFutures() {
if (scheduledFutures == null) {
try {
// spring版本不同選用不同字段scheduledFutures
scheduledFutures = (Set<ScheduledFuture<?>>) BeanUtils.getProperty(taskRegistrar, "scheduledTasks");
} catch (NoSuchFieldException e) {
throw new SchedulingException("not found scheduledFutures field.");
}
}
return scheduledFutures;
}
/**
* 添加任務(wù)
*/
public void addTriggerTask(String taskId, TriggerTask triggerTask) {
if (taskFutures.containsKey(taskId)) {
throw new SchedulingException("the taskId[" + taskId + "] was added.");
}
TaskScheduler scheduler = taskRegistrar.getScheduler();
ScheduledFuture<?> future = scheduler.schedule(triggerTask.getRunnable(), triggerTask.getTrigger());
getScheduledFutures().add(future);
taskFutures.put(taskId, future);
}
/**
* 取消任務(wù)
*/
public void cancelTriggerTask(String taskId) {
ScheduledFuture<?> future = taskFutures.get(taskId);
if (future != null) {
future.cancel(true);
}
taskFutures.remove(taskId);
getScheduledFutures().remove(future);
}
/**
* 重置任務(wù)
*/
public void resetTriggerTask(String taskId, TriggerTask triggerTask) {
cancelTriggerTask(taskId);
addTriggerTask(taskId, triggerTask);
}
/**
* 任務(wù)編號(hào)
*/
public Set<String> taskIds() {
return taskFutures.keySet();
}
/**
* 是否存在任務(wù)
*/
public boolean hasTask(String taskId) {
return this.taskFutures.containsKey(taskId);
}
/**
* 任務(wù)調(diào)度是否已經(jīng)初始化完成
*/
public boolean inited() {
return this.taskRegistrar != null && this.taskRegistrar.getScheduler() != null;
}
}
在項(xiàng)目啟動(dòng)后就自動(dòng)開啟任務(wù)的操作類如下：
package com.fongtech.cli.admin.tasktime;
import com.fongtech.cli.admin.service.IAuthLoginService;
import com.fongtech.cli.admin.service.IBackupsService;
import com.fongtech.cli.admin.service.IDictionnaryEntryService;
import com.fongtech.cli.mbg.model.entity.AuthLogin;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.scheduling.config.TriggerTask;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
/**
* 項(xiàng)目啟動(dòng)后執(zhí)行，
*/
@Slf4j
@Component
@Order(value = 1)
public class CmdRunner implements CommandLineRunner {
@Autowired
private DefaultSchedulingConfigurer defaultSchedulingConfigurer;
@Autowired
private IDictionnaryEntryService dictionnaryEntryService;
@Autowired
private IBackupsService backupsService;
@Autowired
private IAuthLoginService authLoginService;
@Override
public void run(String... args) throws Exception {
log.info("------按照預(yù)設(shè)備份周期啟動(dòng)數(shù)據(jù)庫備份定時(shí)任務(wù)");
while (!defaultSchedulingConfigurer.inited())
{
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
}
}
String cron = dictionnaryEntryService.getEntryValueByName("CRON_VALUE");
//默認(rèn)按照管理員用戶權(quán)限執(zhí)行備份任務(wù)
AuthLogin authLogin = authLoginService.query().eq(AuthLogin::getLogin_user, "admin").getOne();
//啟動(dòng)線程，按照原表內(nèi)的時(shí)間執(zhí)行備份任務(wù)
defaultSchedulingConfigurer.addTriggerTask("task",
new TriggerTask(
() -> System.out.println("=====----------啟動(dòng)定時(shí)任務(wù)=-----------");,
new CronTrigger(cron)));
}
}
暫停定時(shí)任務(wù)：
defaultSchedulingConfigurer.cancelTriggerTask("task");
到此這篇關(guān)于淺談在springboot中使用定時(shí)任務(wù)的方式的文章就介紹到這了,更多相關(guān)springboot定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
在Maven中,依賴排除是一種常見的技術(shù),用于從項(xiàng)目的依賴中排除特定的傳遞性依賴,這通常用于解決依賴沖突或避免引入不需要的庫,以下是如何在Maven中使用依賴排除的詳細(xì)步驟,包括代碼示例,需要的朋友可以參考下2024-11-11
雖然java8出來很久了，但是之前用的一直也不多，最近正好學(xué)習(xí)了java8。下面給大家分享java8中的foreach循環(huán)，感興趣的朋友一起看看吧2017-05-05
java加密算法分享(rsa解密、對(duì)稱加密、md5加密)
這篇文章主要介紹了java加密算法，包括rsa解密、對(duì)稱加密、md5加密等,需要的朋友可以參考下2014-05-05
java多線程并發(fā)executorservice(任務(wù)調(diào)度)類
這篇文章主要介紹了線程并發(fā)ScheduledExecutorService類，設(shè)置 ScheduledExecutorService ，2秒后，在 1 分鐘內(nèi)每 10 秒鐘蜂鳴一次2014-01-01
文章介紹了如何在SpringBoot項(xiàng)目中使用Logback實(shí)現(xiàn)日志打印,并通過自定義日志打印工具類和日志分文件打印來提高日志排查和監(jiān)控的效率2024-12-12
Spring ApplicationContext接口功能詳細(xì)介紹
ApplicationContext是Spring應(yīng)用程序中的中央接口，由于繼承了多個(gè)組件，使得ApplicationContext擁有了許多Spring的核心功能，如獲取bean組件，注冊(cè)監(jiān)聽事件，加載資源文件等2023-02-02
Java使用Tesseract-Ocr識(shí)別數(shù)字
這篇文章主要介紹了Java使用Tesseract-Ocr識(shí)別數(shù)字的方法，幫助大家更好的理解和學(xué)習(xí)使用Java，感興趣的朋友可以了解下2021-04-04
這篇文章主要給大家介紹了關(guān)于java讀取zip/jar包中文件的幾種方式,在我們?nèi)粘Ｊ褂弥袎嚎s文件是非常常用的,文中通過示例代碼將java讀取zip/jar包中文件的方法介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
新手小白學(xué)JAVA IDEA下載使用手冊(cè)全集
IDEA的每一個(gè)方面都是為了最大限度地提高開發(fā)人員的工作效率而設(shè)計(jì)的,它的智能編碼輔助和人機(jī)工程學(xué)設(shè)計(jì)會(huì)讓開發(fā)過程變得愉悅且高效，今天給大家分享新手小白學(xué)JAVA IDEA下載使用手冊(cè)全集，對(duì)idea新手使用相關(guān)知識(shí)感興趣的朋友跟隨小編一起學(xué)習(xí)吧2021-05-05
在本篇文章中我們給大家分享的是一篇關(guān)于java壓縮文件亂碼問題的解決辦法，有需要的朋友們可以學(xué)習(xí)下。2019-12-12