基于Springboot执行多个定时任务并动态获取定时任务信息

package test;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.ComponentScan;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.transaction.annotation.EnableTransactionManagement;@SpringBootApplication@EnableTransactionManagement@EnableScheduling@ComponentScan(value = {"test.*"})@MapperScan("test.mapper.*")public class TomcatlogApplication {  public static void main(String[] args) {    SpringApplication.run(TomcatlogApplication.class, args);  }}

import org.apache.ibatis.annotations.Param;import org.apache.ibatis.annotations.Select;import java.util.List;/* * @version 1.0 created by liuxuewen on 2018/8/21 14:39 */public interface TomcatlogMapper {  @Select("SELECT * FROM scheduledtask s WHERE s.`enable` = 1")  String queryScheduledTask();}

package test.service;import java.util.ArrayList;import java.util.List;/* * @version 1.0 created by liuxuewen on 2018/8/21 14:44 */public interface TomcatlogService {  List<ScheduledtaskEntity> queryScheduledTask();}

import test.mapper.tomcatlog.TomcatlogMapper;import test.service.TomcatlogService;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import java.util.List;/* * @version 1.0 created by liuxuewen on 2018/8/21 14:44 */@Servicepublic class TomcatlogServiceImpl implements TomcatlogService {  private static final Logger LOGGER = LoggerFactory.getLogger(TomcatlogServiceImpl.class);  @Autowired  TomcatlogMapper tomcatlogMapper;  @Override  public String queryScheduledTask() {    try {      String res = tomcatlogMapper.queryScheduledTask();      return res;    } catch (Exception e) {      LOGGER.info(e);    }    return null;}

package test.schedultask;import test.controller.MainController;import test.service.ControllerService;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;/* * @version 1.0 created by liuxuewen on 2018/8/27 9:25 */@Componentpublic class ElasticsearchSchedultaskController implements SchedulingConfigurer {  private static final Logger LOGGER = LoggerFactory.getLogger(ElasticsearchSchedultaskController.class);  @Autowired  private ControllerService controllerService;  @Autowired  private MainController mainController;  @Override  public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {    try {      scheduledTaskRegistrar.addTriggerTask(          //1.添加任务内容(Runnable)，可以为方法          () -> Sytem.out.println("定时任务1"),          //2.设置执行周期(Trigger)          triggerContext -> {            //2.1 从数据库获取执行周期，在这里调用不同的方法返回不同的定时任务信息            String cron = controllerService.getSchedultaskForElasticsearch();            System.out.println("controllerService.getSchedultaskForElasticsearch()");            System.out.println(cron);            //2.2 合法性校验.            if (StringUtils.isEmpty(cron)) {              // Omitted Code ..              LOGGER.error("计划任务为空");            }            //2.3 返回执行周期(Date)            return new CronTrigger(cron).nextExecutionTime(triggerContext);          }      );    }catch (Exception e){      String ex = exceptionLoggingUtil.exceptionPrint(e);      LOGGER.info(ex);    }  }}