怎样进行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基于数据库的定时任务统一管理的实现就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。