欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot如何實現(xiàn)定時任務(wù)示例詳解

 更新時間：2021年10月15日 09:22:20   作者：Jae1995  
使用定時任務(wù)完成一些業(yè)務(wù)邏輯,比如天氣接口的數(shù)據(jù)獲取,定時發(fā)送短信,郵件。以及商城中每天用戶的限額,定時自動收貨等等,這篇文章主要給大家介紹了關(guān)于SpringBoot如何實現(xiàn)定時任務(wù)的相關(guān)資料,需要的朋友可以參考下

寫在前面

SpringBoot創(chuàng)建定時任務(wù)的方式很簡單，主要有兩種方式：一、基于注解的方式（@Scheduled）二、數(shù)據(jù)庫動態(tài)配置。實際開發(fā)中，第一種需要在代碼中寫死表達式，如果修改起來，又得重啟會顯得很麻煩；所以我們往往會采取第二種方式，可以直接從數(shù)據(jù)庫中讀取定時任務(wù)的指定執(zhí)行時間，無需重啟。

下面就來介紹下這兩種方式吧

一、基于注解（@Scheduled）

基于注解是一種靜態(tài)的方式，只需要幾行代碼就可以搞定了

添加一個配置類

@Configuration  //標記配置類
@EnableScheduling   //開啟定時任務(wù)
public class MyScheduleConfig {

    //添加定時任務(wù)
    @Scheduled(cron = "0/5 * * * * ?")
    private void myTasks() {
        System.out.println("執(zhí)行定時任務(wù) " + LocalDateTime.now());
    }
}

上面代碼的cron表達式表示每5秒執(zhí)行一次，可以通過這個網(wǎng)站（http://tools.jb51.net/code/Quartz_Cron_create）去生成要的cron表達式

啟動應(yīng)用，控制臺看效果

這個方式的確很簡單方便，但前面介紹也說到了，有個缺點就是當我們需要去修改定時任務(wù)的執(zhí)行周期或者停止的時候，我們需要到代碼層去修改，重啟。

二、數(shù)據(jù)庫動態(tài)配置

這里使用MySQL數(shù)據(jù)庫

1、表數(shù)據(jù)添加，資源配置

1.1 添加表

CREATE TABLE `scheduled_job` (
  `job_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主鍵id',
  `job_key` varchar(128) NOT NULL COMMENT '定時任務(wù)完整類名',
  `cron_expression` varchar(20) NOT NULL COMMENT 'cron表達式',
  `task_explain` varchar(50) NOT NULL DEFAULT '' COMMENT '任務(wù)描述',
  `status` tinyint(4) NOT NULL DEFAULT '1' COMMENT '狀態(tài),1:正常;-1:停用',
  PRIMARY KEY (`job_id`),
  UNIQUE KEY `job_key` (`job_key`),
  UNIQUE KEY `cron_key_unique_idx` (`job_key`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='定時任務(wù)表';

1.2 插入兩條數(shù)據(jù)，job_key根據(jù)是完整的類名

1.3 引入依賴

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--mysql-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.49</version>
            <scope>runtime</scope>
        </dependency>
        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.1.tmp</version>
        </dependency>
        <!--lombok簡化代碼-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.20</version>
            <scope>provided</scope>
        </dependency>

1.4 配置application.yml

spring:
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/test?userUnicode=true&characterEncoding=UTF8&useSSL=false
    username: root
    password: 123
    driver-class-name: com.mysql.jdbc.Driver
server:
  servlet:
    context-path: /demo
  port: 8888

2、瘋狂貼代碼

2.1 創(chuàng)建定時任務(wù)線程池

@Configuration
@Slf4j
public class ScheduledConfig {

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        log.info("創(chuàng)建定時任務(wù)調(diào)度線程池 start");
        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
        threadPoolTaskScheduler.setPoolSize(20);
        threadPoolTaskScheduler.setThreadNamePrefix("taskExecutor-");
        threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
        threadPoolTaskScheduler.setAwaitTerminationSeconds(60);
        log.info("創(chuàng)建定時任務(wù)調(diào)度線程池 end");
        return threadPoolTaskScheduler;
    }

}

2.2 項目啟動時初始化定時任務(wù)

@Slf4j
@Component
public class ScheduledTaskRunner implements ApplicationRunner {
    @Autowired
    private ScheduledTaskService scheduledTaskService;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        log.info("----初始化定時任務(wù)開始----");
        scheduledTaskService.initTask();
        log.info("----初始化定時任務(wù)完成----");
    }
}

2.3 定時任務(wù)公共接口

public interface ScheduledOfTask extends Runnable{

    void execute();

    @Override
    default void run() {
        execute();
    }
}

2.4 創(chuàng)建兩個定時任務(wù)實現(xiàn)類

@Component
@Slf4j
public class TaskJob1 implements ScheduledOfTask{
    @Override
    public void execute() {
        log.info("執(zhí)行任務(wù)1 "+ LocalDateTime.now());
    }
}
@Component
@Slf4j
public class TaskJob2 implements ScheduledOfTask{
    @Override
    public void execute() {
        log.info("執(zhí)行任務(wù)2 "+ LocalDateTime.now());
    }
}

2.5 定時任務(wù)管理接口

public interface ScheduledTaskService{

    Boolean start(ScheduledJob scheduledJob);

    Boolean stop(String jobKey);

    Boolean restart(ScheduledJob scheduledJob);

    void initTask();
}

2.6 定時任務(wù)管理實現(xiàn)類

@Slf4j
@Service
public class ScheduledTaskServiceImpl implements ScheduledTaskService {

    /**
     * 可重入鎖
     */
    private ReentrantLock lock = new ReentrantLock();

    /**
     * 定時任務(wù)線程池
     */
    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;

    /**
     * 啟動狀態(tài)的定時任務(wù)集合
     */
    public Map<String, ScheduledFuture> scheduledFutureMap = new ConcurrentHashMap<>();

    @Autowired
    private ScheduledJobService scheduledJobService;

    @Override
    public Boolean start(ScheduledJob scheduledJob) {
        String jobKey = scheduledJob.getJobKey();
        log.info("啟動定時任務(wù)"+jobKey);
        //添加鎖放一個線程啟動，防止多人啟動多次
        lock.lock();
        log.info("加鎖完成");

        try {
            if(this.isStart(jobKey)){
                log.info("當前任務(wù)在啟動狀態(tài)中");
                return false;
            }
            //任務(wù)啟動
            this.doStartTask(scheduledJob);
        } finally {
            lock.unlock();
            log.info("解鎖完畢");
        }

        return true;
    }

    /**
     * 任務(wù)是否已經(jīng)啟動
     */
    private Boolean isStart(String taskKey) {
        //校驗是否已經(jīng)啟動
        if (scheduledFutureMap.containsKey(taskKey)) {
            if (!scheduledFutureMap.get(taskKey).isCancelled()) {
                return true;
            }
        }
        return false;
    }

    @Override
    public Boolean stop(String jobKey) {
        log.info("停止任務(wù) "+jobKey);
        boolean flag = scheduledFutureMap.containsKey(jobKey);
        log.info("當前實例是否存在 "+flag);
        if(flag){
            ScheduledFuture scheduledFuture = scheduledFutureMap.get(jobKey);

            scheduledFuture.cancel(true);

            scheduledFutureMap.remove(jobKey);
        }
        return flag;
    }

    @Override
    public Boolean restart(ScheduledJob scheduledJob) {
        log.info("重啟定時任務(wù)"+scheduledJob.getJobKey());
        //停止
        this.stop(scheduledJob.getJobKey());

        return this.start(scheduledJob);
    }

    /**
     * 執(zhí)行啟動任務(wù)
     */
    public void doStartTask(ScheduledJob sj){
        log.info(sj.getJobKey());
        if(sj.getStatus().intValue() != 1)
            return;
        Class<?> clazz;
        ScheduledOfTask task;
        try {
            clazz = Class.forName(sj.getJobKey());
            task = (ScheduledOfTask) SpringContextUtil.getBean(clazz);
        } catch (ClassNotFoundException e) {
            throw new IllegalArgumentException("spring_scheduled_cron表數(shù)據(jù)" + sj.getJobKey() + "有誤", e);
        }
        Assert.isAssignable(ScheduledOfTask.class, task.getClass(), "定時任務(wù)類必須實現(xiàn)ScheduledOfTask接口");
        ScheduledFuture scheduledFuture = threadPoolTaskScheduler.schedule(task,(triggerContext -> new CronTrigger(sj.getCronExpression()).nextExecutionTime(triggerContext)));
        scheduledFutureMap.put(sj.getJobKey(),scheduledFuture);
    }

    @Override
    public void initTask() {
        List<ScheduledJob> list = scheduledJobService.list();
        for (ScheduledJob sj : list) {
            if(sj.getStatus().intValue() == -1) //未啟用
                continue;
            doStartTask(sj);
        }
    }
}

2.8 上面用到的獲取Bean的工具類SpringContextUtil

@Component
public class SpringContextUtil implements ApplicationContextAware {


    private static ApplicationContext applicationContext = null;
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        if(SpringContextUtil.applicationContext == null){
            SpringContextUtil.applicationContext  = applicationContext;
        }
    }

    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }

    public static Object getBean(String name){
        return getApplicationContext().getBean(name);
    }

    public static <T> T getBean(Class<T> clazz){
        return getApplicationContext().getBean(clazz);
    }

    public static <T> T getBean(String name,Class<T> clazz){
        return getApplicationContext().getBean(name, clazz);
    }
}

2.9 表操作對應(yīng)的一些類

Pojo

@Data
@TableName("scheduled_job")
public class ScheduledJob {

    @TableId(value = "job_id",type = IdType.AUTO)
    private Integer jobId;

    private String jobKey;

    private String cronExpression;

    private String taskExplain;

    private Integer status;

}

ScheduledJobMapper

public interface ScheduledJobMapper extends BaseMapper<ScheduledJob> {
}

ScheduledJobService

public interface ScheduledJobService extends IService<ScheduledJob> {

    /**
     * 修改定時任務(wù)，并重新啟動
     * @param scheduledJob
     * @return
     */
    boolean updateOne(ScheduledJob scheduledJob);
}
@Service
@Slf4j
public class ScheduledJobServiceImpl extends ServiceImpl<ScheduledJobMapper, ScheduledJob> implements ScheduledJobService{

    @Autowired
    private ScheduledTaskService scheduledTaskService;

    @Override
    public boolean updateOne(ScheduledJob scheduledJob) {
        if(updateById(scheduledJob))
            scheduledTaskService.restart(getById(scheduledJob.getJobId()));
        return true;
    }
}

2.10 修改定時任務(wù)的接口

@RestController
@RequestMapping("/job")
public class ScheduledJobController {

    @Autowired
    private ScheduledJobService scheduledJobService;

    @PostMapping(value = "/update")
    public CallBackResult update(HttpServletRequest request, ScheduledJob scheduledJob){
         if(scheduledJobService.updateOne(scheduledJob))
             return new CallBackResult(true,"修改成功");
         return new CallBackResult(false,"修改失敗");
    }

}

3、測試結(jié)果

3.1 啟動項目，看下定時任務(wù)的執(zhí)行結(jié)果，控制臺輸出結(jié)果

我們可以看到任務(wù)1是每5秒執(zhí)行一次，任務(wù)2是12秒執(zhí)行一次

3.2 修改任務(wù)1的cron參數(shù)或者狀態(tài)

3.2.1 修改cron，執(zhí)行周期改為20秒執(zhí)行一次，狀態(tài)不變

再看控制臺輸出結(jié)果，任務(wù)2沒變化，任務(wù)1由5秒一次變成了20秒一次了

3.2.1 修改狀態(tài)

再看控制臺輸出結(jié)果，任務(wù)2沒變化，任務(wù)1已經(jīng)不再執(zhí)行了

最后

第二種方式支持通過接口的方式去改動，并且不需要重啟，當然啦，也可以直接在數(shù)據(jù)庫中添加或修改數(shù)據(jù)后重啟項目，配置更加靈活一點。

如果是一個固定的需求，執(zhí)行周期一定不會變的了，推薦還是第一種寫法，畢竟簡單嘛。

如果覺得寫得還不錯的話，給個推薦鼓勵一下吧。

到此這篇關(guān)于SpringBoot如何實現(xiàn)定時任務(wù)的文章就介紹到這了,更多相關(guān)SpringBoot實現(xiàn)定時任務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

  • java JVM原理與常識知識點

    java JVM原理與常識知識點

    在本文中小編給大家分享的是關(guān)于java的JVM原理和java常識，有興趣的朋友們可以學(xué)習(xí)下
    2018-12-12
  • Java輕松使用工具類實現(xiàn)獲取wav時間長度

    Java輕松使用工具類實現(xiàn)獲取wav時間長度

    在Java中，工具類定義了一組公共方法，這篇文章將介紹Java中使用工具類來獲取一個wav文件的時間長度，感興趣的同學(xué)繼續(xù)往下閱讀吧
    2021-10-10
  • SpringBoot整合websocket實現(xiàn)即時通信聊天

    SpringBoot整合websocket實現(xiàn)即時通信聊天

    這篇文章主要介紹了SpringBoot整合websocket實現(xiàn)即時通信聊天,實時通信是一個實時通信系統(tǒng)，允許兩人或多人使用網(wǎng)絡(luò)實時的傳遞文字消息、文件、語音與視頻交流，需要的朋友可以參考下
    2022-05-05
  • SpringBoot構(gòu)建ORM框架的方法步驟

    SpringBoot構(gòu)建ORM框架的方法步驟

    本文主要介紹了SpringBoot構(gòu)建ORM框架的方法步驟，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-02-02
  • Java多線程中Callable和Future的解讀

    Java多線程中Callable和Future的解讀

    這篇文章主要介紹了Java多線程中Callable和Future的解讀,Callable接口類似于Runnable,從名字就可以看出來了,但是Runnable不會返回結(jié)果,并且無法拋出返回結(jié)果的異常,而Callable功能更強大一些,被線程執(zhí)行后,可以返回值,這個返回值可以被Future拿到,需要的朋友可以參考下
    2023-09-09
  • Java SoftReference類案例詳解

    Java SoftReference類案例詳解

    這篇文章主要介紹了Java SoftReference類案例詳解,本篇文章通過簡要的案例,講解了該項技術(shù)的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下
    2021-08-08
  • SpringBoot多環(huán)境開發(fā)與日志小結(jié)

    SpringBoot多環(huán)境開發(fā)與日志小結(jié)

    這篇文章主要介紹了SpringBoot多環(huán)境開發(fā)與日志,下面給大家說一下如何基于多環(huán)境開發(fā)做配置獨立管理，務(wù)必掌握，需要的朋友可以參考下
    2022-08-08
  • Java分治法與二分搜索算法實例分析

    Java分治法與二分搜索算法實例分析

    這篇文章主要介紹了Java分治法與二分搜索算法,簡單講述了分治法與二分搜索算法的原理并結(jié)合java實例分析了二分搜索算法的實現(xiàn)與使用技巧,需要的朋友可以參考下
    2017-11-11
  • 深入理解Java中HashCode方法

    深入理解Java中HashCode方法

    這篇文章主要介紹了深入理解Java中HashCode方法，具有一定借鑒價值,需要的朋友可以參考下
    2018-01-01

    • 最新評論