Spring Boot 集成动态定时任务

心已赠人 2024-04-18 18:09 55阅读 0赞

# 1.**导入依赖** #

<dependency>
 <groupId>org.slf4j</groupId>
 <artifactId>slf4j-log4j12</artifactId>
 <version>2.0.0-alpha0</version>
 <scope>test</scope>
 </dependency>

# 2.添加定时任务配置类 #

import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.TaskScheduler;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
    
    /**
     * @author Unclue_liu
     * @organization tyzn
     * @date 2019/9/9 0009 9:31
     * @desc TODO 定时任务的线程池配置类
     */
    @Configuration
    public class SchedulingConfig {
        @Bean
        public TaskScheduler taskScheduler() {
            ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
            // 定时任务执行线程池核心线程数
            taskScheduler.setPoolSize(20);
            taskScheduler.setRemoveOnCancelPolicy(true);
            taskScheduler.setThreadNamePrefix("TaskSchedulerThreadPool-");
            return taskScheduler;
        }
    }

# 3.添加ScheduledFuture的包装类 #

import java.util.concurrent.ScheduledFuture;
 
 /**
 * @author Unclue_liu
 * @organization tyzn
 * @date 2019/9/9 0009 11:30
 * @desc TODO ScheduledFuture的包装类
 */
 public final class ScheduledTask {
 
 volatile ScheduledFuture<?> future;
 
 /**
 * 取消定时任务
 */
 public void cancel() {
 ScheduledFuture<?> future = this.future;
 if (future != null) {
 future.cancel(true);
 }
 }
 }

# 4.Runnable接口实现类，被定时任务线程池调用 #

中间根据项目的一些需求进行修改

import com.common.Utils.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.util.ReflectionUtils;
    
    import java.lang.reflect.Method;
    import java.util.Objects;
    
    /**
     * @author Unclue_liu
     * @organization tyzn
     * @date 2019/9/9 0009 11:17
     * @desc TODO Runnable接口实现类，被定时任务线程池调用
     */
    public class SchedulingRunnable implements Runnable {
    
        private static final Logger logger = LoggerFactory.getLogger(SchedulingRunnable.class);
    
        private String beanName;
    
        private String methodName;
    
        private String params;
    
        private Long jobid; //定时任务id
    
        public SchedulingRunnable(String beanName, String methodName) {
            this(beanName, methodName, null,null);
        }
    
        public SchedulingRunnable(String beanName, String methodName, String params, Long jobid) {
            this.beanName = beanName;
            this.methodName = methodName;
            this.params = params;
            this.jobid = jobid;
        }
    
        @Override
        public void run() {
            logger.info("定时任务开始执行 - bean：{}，方法：{}，参数：{}", beanName, methodName, params);
            long startTime = System.currentTimeMillis();
    
            try {
                Object target = SpringContextUtils.getBean(beanName);
    
                Method method = null;
                if (StringUtils.isNotEmpty(params)) {
                    method = target.getClass().getDeclaredMethod(methodName, String.class);
                } else {
                    method = target.getClass().getDeclaredMethod(methodName);
                }
    
                ReflectionUtils.makeAccessible(method);
                if (StringUtils.isNotEmpty(params)) {
                    method.invoke(target, params);
                } else {
                    method.invoke(target);
                }
            } catch (Exception ex) {
                logger.error(String.format("定时任务执行异常 - bean：%s，方法：%s，参数：%s ", beanName, methodName, params), ex);
            }
    
            long times = System.currentTimeMillis() - startTime;
            logger.info("定时任务执行结束 - bean：{}，方法：{}，参数：{}，耗时：{} 毫秒", beanName, methodName, params, times);
        }
    
        @Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (o == null || getClass() != o.getClass()) return false;
            SchedulingRunnable that = (SchedulingRunnable) o;
            if (params == null) {
                return beanName.equals(that.beanName) &&
                        methodName.equals(that.methodName) &&
                        that.params == null;
            }
    
            return beanName.equals(that.beanName) &&
                    methodName.equals(that.methodName) &&
                    params.equals(that.params);
        }
    
        @Override
        public int hashCode() {
            if (params == null) {
                return Objects.hash(beanName, methodName);
            }
    
            return Objects.hash(beanName, methodName, params);
        }
    
        public Long getJobid() {
            return jobid;
        }
    
        public String getMethodName() {
            return methodName;
        }
    
        /**
         * 获取定时编号
         * @return
         */
        public String jobNumber(){
            return getJobid()+getMethodName();
        }
    }

# 5.添加定时任务注册类 #

import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.config.CronTask;
 import org.springframework.stereotype.Component;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
 * @author Unclue_liu
 * @organization tyzn
 * @date 2019/9/9 0009 11:22
 * @desc TODO 定时任务注册类
 */
 @Component
 public class CronTaskRegistrar implements DisposableBean {
 
 private final Map<String, ScheduledTask> scheduledTasks = new ConcurrentHashMap<>();
 
 @Autowired
 private TaskScheduler taskScheduler;
 
 public TaskScheduler getScheduler() {
 return this.taskScheduler;
 }
 
 private SchedulingRunnable schedulingRunnable;
 
 /**
 * 添加定时任务
 * @param task
 * @param cronExpression
 */
 public void addCronTask(SchedulingRunnable task, String cronExpression) {
 this.schedulingRunnable=task;
 addCronTask(new CronTask(task, cronExpression));
 }
 
 public void addCronTask(CronTask cronTask) {
 if (cronTask != null) {
 //定时编号
 String jobNumber = this.schedulingRunnable.jobNumber();
 if (this.scheduledTasks.containsKey(jobNumber)) {
 removeCronTask(jobNumber);
 }
 //添加定时
 this.scheduledTasks.put(jobNumber, scheduleCronTask(cronTask));
 
 }
 }
 
 /**
 * 移除Cron任务
 * @param jobNumber
 */
 public void removeCronTask(String jobNumber) {
 ScheduledTask scheduledTask = this.scheduledTasks.remove(jobNumber);
 if (scheduledTask != null){
 scheduledTask.cancel();
 }
 }
 
 /**
 * 安排Cron任务
 * @param cronTask
 * @return
 */
 public ScheduledTask scheduleCronTask(CronTask cronTask) {
 ScheduledTask scheduledTask = new ScheduledTask();
 scheduledTask.future = this.taskScheduler.schedule(cronTask.getRunnable(), cronTask.getTrigger());
 return scheduledTask;
 }
 
 
 @Override
 public void destroy() {
 for (ScheduledTask task : this.scheduledTasks.values()) {
 task.cancel();
 }
 this.scheduledTasks.clear();
 }
 }

# 6.定时任务示例类 #

import org.springframework.stereotype.Component;
    /**
     * @author Unclue_liu
     * @organization tyzn
     * @date 2019/9/9 0009 14:46
     * @desc TODO 
     */
    @Component("demoTask")
    public class DemoTask {
        public void taskWithParams(String params) {
            System.out.println("执行有参示例任务：" + params);
        }
    
        public void taskNoParams() {
            System.out.println("执行无参示例任务");
        }
    }

# 7.操作处理 #

根据自己的业务需求设计数据库表

**数据库表：**

<table> 
 <tbody> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;width:147pt;">字段</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;width:95.25pt;">类型</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;width:95.25pt;">长度</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;width:80.25pt;">是否为空</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;width:278.25pt;">注释</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">jobId</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">int</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">11</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">任务ID</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">bean_name</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">100</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">bean名称</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">start_method_name</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">100</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">start方法名称</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">job_group</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">40</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">是</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">定时任务组</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">method_params</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">500</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">是</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">方法参数(设备编号)</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">start_time</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">50</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">start定时任务启动时间</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">job_status</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">int</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">11</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">状态:1启动、2关闭</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">remark</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">100</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">是</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">备注</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">create_time</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">timestamp</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">0</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">否</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">创建时间</td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">update_time</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">varchar</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">20</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">是</td> 
 <td style="border-color:#000000;text-align:center;vertical-align:middle;">修改时间</td> 
 </tr> 
 </tbody> 
</table>

**实体类：**

import com.common.Utils.DateUtils;
    import org.apache.commons.lang3.builder.ToStringBuilder;
    import org.apache.commons.lang3.builder.ToStringStyle;
    
    /**
     * 定时任务对象 sys_job_p_o
     * 
     * @author ruoyi
     * @date 2019-09-10
     */
    public class SysJobPO
    {
        private static final long serialVersionUID = 1L;
    
        /** 任务ID */
        private Long jobid;
    
        /** bean名称 */
        private String beanName;
    
        /** start方法名称 */
        private String startMethodName;
    
        /** 方法参数(设备编号) */
        private String methodParams;
    
        /** start定时任务启动时间 */
        private String startTime;
    
        /** 状态:1启动、2关闭 */
        private Integer jobStatus;
    
        /** 定时任务组 */
        private String jobGroup;
    
        /** 备注 */
        private String remark;
    
        /** 创建时间 */
        private String createTime;
    
        /** 修改时间 */
        private String updateTime;
    
        public Long getJobid() {
            return jobid;
        }
    
        public void setJobid(Long jobid) {
            this.jobid = jobid;
        }
    
        public String getBeanName() {
            return beanName;
        }
    
        public void setBeanName(String beanName) {
            this.beanName = beanName;
        }
    
        public String getStartMethodName() {
            return startMethodName;
        }
    
        public void setStartMethodName(String startMethodName) {
            this.startMethodName = startMethodName;
        }
    
        public String getMethodParams() {
            return methodParams;
        }
    
        public void setMethodParams(String methodParams) {
            this.methodParams = methodParams;
        }
    
        public String getStartTime() {
            return startTime;
        }
    
        public void setStartTime(String startTime) {
            this.startTime = startTime;
        }
    
        public Integer getJobStatus() {
            return jobStatus;
        }
    
        public void setJobStatus(Integer jobStatus) {
            this.jobStatus = jobStatus;
        }
    
        public String getJobGroup() {
            return jobGroup;
        }
    
        public void setJobGroup(String jobGroup) {
            this.jobGroup = jobGroup;
        }
    
        public String getRemark() {
            return remark;
        }
    
        public void setRemark(String remark) {
            this.remark = remark;
        }
    
        public String getCreateTime() {
            return createTime;
        }
    
        public void setCreateTime(String createTime) {
            this.createTime = createTime;
        }
    
        public String getUpdateTime() {
            return updateTime;
        }
    
        public void setUpdateTime(String updateTime) {
            this.updateTime = updateTime;
        }
    
        @Override
        public String toString() {
            return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
                .append("jobid", getJobid())
                .append("beanName", getBeanName())
                .append("startMethodName", getStartMethodName())
                .append("methodParams", getMethodParams())
                .append("startTime", getStartTime())
                .append("jobStatus", getJobStatus())
                .append("remark", getRemark())
                .append("createTime", getCreateTime())
                .append("updateTime", getUpdateTime())
                .toString();
        }
    
        /**
         * Start表达式
         * @return
         */
        public String getStartCron(){
            return DateUtils.getCron(DateUtils.dateTime("yyyy-MM-dd HH:mm:ss","2000-01-10 "+getStartTime()));
        }
    
    
        /**
         * Start方法编号
         * @return
         */
        public String jobStartNumber(){
            return getJobid()+getStartMethodName();
        }
    
    }

**工具类：**

import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
 import org.springframework.stereotype.Component;
 
 /**
 * @author Unclue_liu
 * @organization tyzn
 * @date 2019/9/9 0009 11:23
 * @desc TODO 用来从spring容器里获取bean
 */
 @Component
 public class SpringContextUtils implements ApplicationContextAware {
 
 private static ApplicationContext applicationContext;
 
 @Override
 public void setApplicationContext(ApplicationContext applicationContext)
 throws BeansException {
 SpringContextUtils.applicationContext = applicationContext;
 }
 
 public static Object getBean(String name) {
 return applicationContext.getBean(name);
 }
 
 public static <T> T getBean(Class<T> requiredType) {
 return applicationContext.getBean(requiredType);
 }
 
 public static <T> T getBean(String name, Class<T> requiredType) {
 return applicationContext.getBean(name, requiredType);
 }
 
 public static boolean containsBean(String name) {
 return applicationContext.containsBean(name);
 }
 
 public static boolean isSingleton(String name) {
 return applicationContext.isSingleton(name);
 }
 
 public static Class<? extends Object> getType(String name) {
 return applicationContext.getType(name);
 }
 }

import org.apache.commons.lang3.time.DateFormatUtils;
    
    import java.lang.management.ManagementFactory;
    import java.text.ParseException;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    /**
     * 时间工具类
     * 
     * @Author: Uncle liu
     */
    public class DateUtils extends org.apache.commons.lang3.time.DateUtils
    {
        public static String YYYY = "yyyy";
    
        public static String YYYY_MM = "yyyy-MM";
    
        public static String YYYY_MM_DD = "yyyy-MM-dd";
    
        public static String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
    
        public static String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
        
        private static String[] parsePatterns = {
                "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM", 
                "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
                "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};
    
        /**
         * 获取当前Date型日期
         * 
         * @return Date() 当前日期
         */
        public static Date getNowDate()
        {
            return new Date();
        }
    
        /**
         * 获取当前日期, 默认格式为yyyy-MM-dd
         * 
         * @return String
         */
        public static String getDate()
        {
            return dateTimeNow(YYYY_MM_DD);
        }
    
        public static final String getTime()
        {
            return dateTimeNow(YYYY_MM_DD_HH_MM_SS);
        }
    
        public static final String dateTimeNow()
        {
            return dateTimeNow(YYYYMMDDHHMMSS);
        }
    
        public static final String dateTimeNow(final String format)
        {
            return parseDateToStr(format, new Date());
        }
    
        public static final String dateTime(final Date date)
        {
            return parseDateToStr(YYYY_MM_DD, date);
        }
    
        public static final String parseDateToStr(final String format, final Date date)
        {
            return new SimpleDateFormat(format).format(date);
        }
    
        public static final Date dateTime(final String format, final String ts)
        {
            try
            {
                return new SimpleDateFormat(format).parse(ts);
            }
            catch (ParseException e)
            {
                throw new RuntimeException(e);
            }
        }
    
        /**
         * 日期路径 即年/月/日 如2018/08/08
         */
        public static final String datePath()
        {
            Date now = new Date();
            return DateFormatUtils.format(now, "yyyy/MM/dd");
        }
    
        /**
         * 日期路径 即年/月/日 如20180808
         */
        public static final String dateTime()
        {
            Date now = new Date();
            return DateFormatUtils.format(now, "yyyyMMdd");
        }
    
        /**
         * 日期型字符串转化为日期 格式
         */
        public static Date parseDate(Object str)
        {
            if (str == null)
            {
                return null;
            }
            try
            {
                return parseDate(str.toString(), parsePatterns);
            }
            catch (ParseException e)
            {
                return null;
            }
        }
        
        /**
         * 获取服务器启动时间
         */
        public static Date getServerStartDate()
        {
            long time = ManagementFactory.getRuntimeMXBean().getStartTime();
            return new Date(time);
        }
    
        /**
         * 计算两个时间差
         */
        public static String getDatePoor(Date endDate, Date nowDate)
        {
            long nd = 1000 * 24 * 60 * 60;
            long nh = 1000 * 60 * 60;
            long nm = 1000 * 60;
            // long ns = 1000;
            // 获得两个时间的毫秒时间差异
            long diff = endDate.getTime() - nowDate.getTime();
            // 计算差多少天
            long day = diff / nd;
            // 计算差多少小时
            long hour = diff % nd / nh;
            // 计算差多少分钟
            long min = diff % nd % nh / nm;
            // 计算差多少秒//输出结果
            // long sec = diff % nd % nh % nm / ns;
            return day + "天" + hour + "小时" + min + "分钟";
        }
    
    
        /**
         * 日期转化为cron表达式
         * @param date
         * @return
         */
        public static String getCron(java.util.Date  date){
            String dateFormat="ss mm HH * * ?";
            return  DateUtils.fmtDateToStr(date, dateFormat);
        }
    
        /**
         * cron表达式转为日期
         * @param cron
         * @return
         */
        public static Date getCronToDate(String cron) {
            String dateFormat="ss mm HH * * ?";
            SimpleDateFormat sdf = new SimpleDateFormat(dateFormat);
            Date date = null;
            try {
                date = sdf.parse(cron);
            } catch (ParseException e) {
                return null;
            }
            return date;
        }
    
        /**
         * Description:格式化日期,String字符串转化为Date
         *
         * @param date
         * @param dtFormat
         *            例如:yyyy-MM-dd HH:mm:ss yyyyMMdd
         * @return
         */
        public static String fmtDateToStr(Date date, String dtFormat) {
            if (date == null)
                return "";
            try {
                SimpleDateFormat dateFormat = new SimpleDateFormat(dtFormat);
                return dateFormat.format(date);
            } catch (Exception e) {
                e.printStackTrace();
                return "";
            }
        }
    }

**业务处理：**

import com.common.Utils.DateUtils;
 import com.common.core.text.Convert;
 import com.tyzn.project.job.core.CronTaskRegistrar;
 import com.tyzn.project.job.core.SchedulingRunnable;
 import com.tyzn.project.job.mapper.SysJobPOMapper;
 import com.tyzn.project.job.pojo.SysJobPO;
 import com.tyzn.project.job.service.ISysJobPOService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import javax.annotation.Resource;
 import java.util.List;
 
 /**
 * 定时任务Service业务层处理
 *
 * @author Uncle_liu
 * @date 2019-09-09
 */
 @Service
 @Transactional
 public class SysJobPOServiceImpl implements ISysJobPOService {
 private static final Logger logger = LoggerFactory.getLogger(SysJobPOServiceImpl.class);
 @Autowired
 private SysJobPOMapper sysJobPOMapper;
 @Resource
 private CronTaskRegistrar cronTaskRegistrar; //定时任务注册类
 
 /**
 * 查询定时任务
 *
 * @param jobid 定时任务ID
 * @return 定时任务
 */
 @Override
 public SysJobPO selectSysJobPOById(Long jobid) {
 return sysJobPOMapper.selectSysJobPOById(jobid);
 }
 
 /**
 * 查询定时任务列表
 *
 * @param sysJobPO 定时任务
 * @return 定时任务
 */
 @Override
 public List<SysJobPO> selectSysJobPOList(SysJobPO sysJobPO) {
 return sysJobPOMapper.selectSysJobPOList(sysJobPO);
 }
 
 /**
 * 新增定时任务
 *
 * @param sysJobPO 定时任务
 * @return 结果
 */
 @Override
 public int insertSysJobPO(SysJobPO sysJobPO) {
 sysJobPO.setCreateTime(DateUtils.getTime());
 int i = 0;
 try {
 i = sysJobPOMapper.insertSysJobPO(sysJobPO);
 //添加定时任务
 if (i > 0 && sysJobPO.getJobStatus() == 1) {
 SchedulingRunnable start = new SchedulingRunnable(sysJobPO.getBeanName(), sysJobPO.getStartMethodName(), sysJobPO.getMethodParams(),sysJobPO.getJobid());
 cronTaskRegistrar.addCronTask(start, sysJobPO.getStartCron());
 }
 } catch (Exception e) {
 e.printStackTrace();
 //手动回滚
 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
 logger.error("添加定时任务失败，执行回滚");
 return 0;
 }
 
 return i;
 }
 
 /**
 * 修改定时任务
 *
 * @param sysJobPO 定时任务
 * @return 结果
 */
 @Override
 public int updateSysJobPO(SysJobPO sysJobPO) {
 sysJobPO.setCreateTime(DateUtils.getTime());
 int i = 0;
 try {
 i = sysJobPOMapper.updateSysJobPO(sysJobPO);
 //定时任务
 if (i > 0 ) {
 //起始-------
 SchedulingRunnable start = new SchedulingRunnable(sysJobPO.getBeanName(), sysJobPO.getStartMethodName(), sysJobPO.getMethodParams(),sysJobPO.getJobid());
 //先移除起始
 cronTaskRegistrar.removeCronTask(start.jobNumber());
 if(sysJobPO.getJobStatus() == 1){
 //再添加起始
 cronTaskRegistrar.addCronTask(start, sysJobPO.getStartCron());
 }
 }
 } catch (Exception e) {
 //手动回滚
 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
 logger.error("修改定时任务失败，执行回滚");
 return 0;
 }
 
 return i;
 }
 
 /**
 * 删除定时任务对象
 *
 * @param ids 需要删除的数据ID
 * @return 结果
 */
 @Override
 public int deleteSysJobPOByIds(String ids) {
 String[] strings = Convert.toStrArray(ids);
 int result = 0;
 for (int i = 0; i < strings.length; i++) {
 try {
 long jobid = Long.parseLong(strings[i]);
 //根据id查询
 SysJobPO sysJobPO = sysJobPOMapper.selectSysJobPOById(jobid);
 //删除信息
 result = result + sysJobPOMapper.deleteSysJobPOById(jobid);
 if (sysJobPO.getJobStatus() == 1) {
 //删除起始定时任务
 cronTaskRegistrar.removeCronTask(sysJobPO.jobStartNumber());
 }
 } catch (Exception e) {
 //手动回滚
 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
 logger.error("删除定时任务失败，执行回滚");
 return 0;
 }
 }
 return result;
 }
 
 /**
 * 删除定时任务信息
 *
 * @param jobid 定时任务ID
 * @return 结果
 */
 public int deleteSysJobPOById(Long jobid) {
 return sysJobPOMapper.deleteSysJobPOById(jobid);
 }
 
 
 
 
 
 }

**启动项目时从数据库加载所有可用定时任务**

import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.tyzn.project.job.pojo.SysJobPO;
 import com.tyzn.project.job.service.ISysJobPOService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 
 /**
 * @author Unclue_liu
 * @organization tyzn
 * @date 2019/9/9 0009 13:58
 * @desc TODO 启动加载数据库正常状态的定时任务
 */
 @Service
 public class SysJobRunner implements CommandLineRunner {
 
 private static final Logger logger = LoggerFactory.getLogger(SysJobRunner.class);
 
 @Autowired
 private ISysJobPOService iSysJobPOService;
 
 @Autowired
 private CronTaskRegistrar cronTaskRegistrar;
 
 @Override
 public void run(String... args) {
 // 初始加载数据库里状态为正常的定时任务
 SysJobPO jobPO = new SysJobPO();
 jobPO.setJobStatus(1);
 List<SysJobPO> jobList = iSysJobPOService.selectSysJobPOList(jobPO);
 if (CollectionUtils.isNotEmpty(jobList)) {
 for (SysJobPO job : jobList) {
 //添加定时任务
 SchedulingRunnable start = new SchedulingRunnable(job.getBeanName(), job.getStartMethodName(), job.getMethodParams(),job.getJobid());
 cronTaskRegistrar.addCronTask(start, job.getStartCron());
 }
 
 logger.info("定时任务已加载完毕...");
 }
 }
 }