springboot maven动态向数据库添加定时任务demo，执行相应程序(结合数据库操作)

package com.example.demo; import java.time.LocalDateTime; import javax.annotation.Resource; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Select; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import org.springframework.scheduling.support.CronTrigger; import org.springframework.util.StringUtils; import com.example.demo.dao.CronRepository; import com.example.demo.service.CronService; @Configuration @EnableScheduling public class CompleteScheduleConfig implements SchedulingConfigurer{ @Resource private CronService cronService; @Resource private CronRepository cronRepository; @Mapper public interface CronMapper { @Select("select cron from cron limit 1") String getCron(); } @Autowired @SuppressWarnings("all") CronMapper cronMapper; private static final Logger logger = LoggerFactory.getLogger(CompleteScheduleConfig.class); // @Scheduled(cron="0 */3 * * * ?") // public void executeFileDownLoadTask() { // // 每隔3分钟定时向数据库里面添加一条定时任务 // Thread current = Thread.currentThread(); // if (current != null){ // cronService.insertTwo(); // System.out.println("定时任务1——动态调用接口向DB里面添加一条定时任务:"+current.getId()); // logger.info("ScheduledTest.executeFileDownLoadTask 定时任务1:"+current.getId()+ ",name:"+current.getName()); // } // } /** * 执行定时任务. */ @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.addTriggerTask( //1.添加任务内容(Runnable) () -> logger.info("执行定时任务1: " + LocalDateTime.now()+"从数据库里面读取定时任务cron表达式设置成功！"), //2.设置执行周期(Trigger) triggerContext -> { //2.1 从数据库获取执行周期 String cron = cronMapper.getCron(); //2.2 合法性校验. if (StringUtils.isEmpty(cron)) { // Omitted Code .. } //2.3 返回执行周期(Date) return new CronTrigger(cron).nextExecutionTime(triggerContext); } ); } }