怎樣進行SpringBoot基于數據庫的定時任務統一管理的實現

這篇文章給大家介紹怎樣進行SpringBoot基于數據庫的定時任務統一管理的實現，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

定時任務1

import lombok.extern.slf4j.Slf4j;/** * @author Created by niugang on 2019/12/24/15:29 */@Slf4jpublic class TaskTest {  public void task1() {    log.info("反射調用測試[一]類");  }}

定時任務2

import lombok.extern.slf4j.Slf4j;/** * @author Created by niugang on 2019/12/24/15:54 */@Slf4jpublic class TaskTest2 {  public void task2() {    log.info("反射調用測試[二]類");  }}

配置類

import lombok.Data;import lombok.extern.slf4j.Slf4j;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.CronTask;import org.springframework.scheduling.config.ScheduledTask;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import java.lang.reflect.Method;import java.util.ArrayList;import java.util.List;/** * @author Created by niugang on 2019/12/24/15:19 */@Configuration@EnableScheduling@Slf4jpublic class CompleteScheduleConfig implements SchedulingConfigurer {  private static List<TaskRecord> taskRecordList = new ArrayList<>();  

/*   *模擬數據庫存儲   */  static {    

TaskRecord taskRecord = new TaskRecord();    taskRecord.setExecuteMehod("task1");

 taskRecord.setClassPath("com.example.demo.pojo.TaskTest");    

taskRecord.setCron("0/5 * * * * ?");    

taskRecordList.add(taskRecord);    

TaskRecord taskRecord2 = new TaskRecord();   

 taskRecord2.setExecuteMehod("task2");    

taskRecord2.setClassPath("com.example.demo.pojo.TaskTest2");    

taskRecord2.setCron("0/10 * * * * ?");    

taskRecordList.add(taskRecord2);  }  @Override  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {    // taskRegistrar.addCronTask(() -> log.info("執行定時任務,{}", LocalDateTime.now()), "0/5 * * * * ?");/*    taskRegistrar.addCronTask(new Runnable() {      

@Override      public void run() {        try {          

Class<?> aClass = Class.forName("com.example.demo.pojo.TaskTest");          

Object o = aClass.newInstance();          

Method[] declaredMethods = aClass.getDeclaredMethods();          for (Method declaredMethod : declaredMethods) {            declaredMethod.invoke(o);            

// log.info("方法名稱:{}",declaredMethod.getName());

          }        } 

catch (Exception e) {          e.printStackTrace();

        }      }    }, "0/5 * * * * ?");

*/    for (TaskRecord taskRecord : taskRecordList) {      String classPath = taskRecord.getClassPath();      

String cron = taskRecord.getCron();      

String executeMehod = taskRecord.getExecuteMehod();      

Runnable runnable = () -> {        Class<?> aClass;        

try {          aClass = Class.forName(classPath);          

Object o = aClass.newInstance();          

Method[] declaredMethods = aClass.getDeclaredMethods();          

for (Method declaredMethod : declaredMethods) {            

if (declaredMethod.getName().equals(executeMehod)) {              

/// log.info("方法名稱:{}",declaredMethod.getName());              

declaredMethod.invoke(o); 

           }          }        } 

catch (Exception e1) {          e1.printStackTrace();

        }      };      

CronTask cronTask = new CronTask(runnable, cron);      

ScheduledTask scheduledTask = taskRegistrar.scheduleCronTask(cronTask);      

//scheduledTask.cancel(); 取消定時任務    }  }  

@Data  private static class TaskRecord {    private String classPath;    

private String executeMehod;    

private String cron;    

//可以在增加一個type 執行其他類型的定時任務  }}

關于怎樣進行SpringBoot基于數據庫的定時任務統一管理的實現就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。