SpringBoot實(shí)現(xiàn)動態(tài)定時任務(wù)

package com.allcom.service;
 
import com.allcom.dao.MySQLDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
 
/**
* @Author: zy
* @Description: 定時任務(wù)
* @Date: 2018/7/12_15:15
**/
@Service
public class TaskService {
 
  @Autowired
  private MysqlDao mysqlDao;
 
  @Scheduled(fixedRate = 5*1000)
  public void deleteInvalidCheckCode() {
    mysqlDao.deleteInvalidCheckCode();
  }
 
}

package com.allcom.task;
 
import com.allcom.service.TaskService;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
 
 
 
import java.util.Date;
 
 
@Configuration
public class MyScheduledTask implements SchedulingConfigurer {
 
  @Mapper
  public interface CronMapper {
    @Select("select cron from user_cron limit 1")
    String getCron();
  }
 
  @Autowired
  @SuppressWarnings("all")
  CronMapper cronMapper;
 
 
  @Autowired
  @SuppressWarnings("all")
  private TaskService taskService;
 
  @Override
  public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
      scheduledTaskRegistrar.addTriggerTask(new Runnable() {
        @Override
        public void run() {
          try {
            taskService.deleteInvalidCheckCode(); //異步定時操作
          } catch (Exception e) {
            e.printStackTrace();
          }
        }
      }, new Trigger() {
        @Override
        public Date nextExecutionTime(TriggerContext triggerContext) {
          String cron =cronMapper.getCron();
          if("".equals(cron)||cron==null)
            return null;
          //定時任務(wù)觸發(fā),可修改定時任務(wù)的執(zhí)行周期
          CronTrigger trigger=new CronTrigger(cron);
          Date nextExecDate= trigger.nextExecutionTime(triggerContext);
          return nextExecDate;
        }
      });
  }
}

/**
* @Author: zy
* @Description: 刪除用戶過期的校驗(yàn)碼
* @Date: 2018/7/12_15:20
**/
@Delete("DELETE from registinfo where id in (select id from (SELECT id FROM registinfo WHERE TIMESTAMPDIFF(MINUTE,lastupdatetime,NOW()) >= 15)a )")
void deleteInvalidCheckCode();