2.6 定時(shí)任務(wù)管理實(shí)現(xiàn)類

@Slf4j
 @Service
 public class ScheduledTaskServiceImpl implements ScheduledTaskService {
 
     /**
      * 可重入鎖
      */
    private ReentrantLock lock = new ReentrantLock();
 
     /**
      * 定時(shí)任務(wù)線程池
      */
     @Autowired
     private ThreadPoolTaskScheduler threadPoolTaskScheduler;
 
     /**
      * 啟動(dòng)狀態(tài)的定時(shí)任務(wù)集合
      */
     public Map<String, ScheduledFuture> scheduledFutureMap = new ConcurrentHashMap<>();
 
     @Autowired
     private ScheduledJobService scheduledJobService;
 
     @Override
     public Boolean start(ScheduledJob scheduledJob) {
         String jobKey = scheduledJob.getJobKey();
         log.info("啟動(dòng)定時(shí)任務(wù)"+jobKey);
         //添加鎖放一個(gè)線程啟動(dòng)，防止多人啟動(dòng)多次
         lock.lock();
         log.info("加鎖完成");
 
         try {
             if(this.isStart(jobKey)){
                 log.info("當(dāng)前任務(wù)在啟動(dòng)狀態(tài)中");
                 return false;
             }
             //任務(wù)啟動(dòng)
             this.doStartTask(scheduledJob);
         } finally {
             lock.unlock();
             log.info("解鎖完畢");
         }
 
         return true;
     }
 
     /**
      * 任務(wù)是否已經(jīng)啟動(dòng)
      */
     private Boolean isStart(String taskKey) {
         //校驗(yàn)是否已經(jīng)啟動(dòng)
         if (scheduledFutureMap.containsKey(taskKey)) {
             if (!scheduledFutureMap.get(taskKey).isCancelled()) {
                 return true;
             }
         }
         return false;
     }
 
     @Override
     public Boolean stop(String jobKey) {
         log.info("停止任務(wù) "+jobKey);
         boolean flag = scheduledFutureMap.containsKey(jobKey);
         log.info("當(dāng)前實(shí)例是否存在 "+flag);
         if(flag){
             ScheduledFuture scheduledFuture = scheduledFutureMap.get(jobKey);
 
             scheduledFuture.cancel(true);
 
             scheduledFutureMap.remove(jobKey);
         }
         return flag;
     }
 
     @Override
     public Boolean restart(ScheduledJob scheduledJob) {
         log.info("重啟定時(shí)任務(wù)"+scheduledJob.getJobKey());
         //停止
         this.stop(scheduledJob.getJobKey());
 
         return this.start(scheduledJob);
     }
 
     /**
      * 執(zhí)行啟動(dòng)任務(wù)
      */
     public void doStartTask(ScheduledJob sj){
         log.info(sj.getJobKey());
         if(sj.getStatus().intValue() != 1)
             return;
         Class? clazz;
         ScheduledOfTask task;
         try {
             clazz = Class.forName(sj.getJobKey());
             task = (ScheduledOfTask) SpringContextUtil.getBean(clazz);
         } catch (ClassNotFoundException e) {
             throw new IllegalArgumentException("spring_scheduled_cron表數(shù)據(jù)" + sj.getJobKey() + "有誤", e);
         }
         Assert.isAssignable(ScheduledOfTask.class, task.getClass(), "定時(shí)任務(wù)類必須實(shí)現(xiàn)ScheduledOfTask接口");
         ScheduledFuture scheduledFuture = threadPoolTaskScheduler.schedule(task,(triggerContext -> new CronTrigger(sj.getCronExpression()).nextExecutionTime(triggerContext)));
         scheduledFutureMap.put(sj.getJobKey(),scheduledFuture);
     }
 
     @Override
     public void initTask() {
         List

2.8 上面用到的獲取Bean的工具類SpringContextUtil

@Component
 public class SpringContextUtil implements ApplicationContextAware {
 
 
     private static ApplicationContext applicationContext = null;
     @Override
     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
         if(SpringContextUtil.applicationContext == null){
             SpringContextUtil.applicationContext  = applicationContext;
         }
     }
 
     public static ApplicationContext getApplicationContext() {
         return applicationContext;
     }
 
     public static Object getBean(String name){
         return getApplicationContext().getBean(name);
     }
 
     public static

2.9 表操作對(duì)應(yīng)的一些類

Pojo

@Data
 @TableName("scheduled_job")
 public class ScheduledJob {
 
     @TableId(value = "job_id",type = IdType.AUTO)
     private Integer jobId;
 
     private String jobKey;
 
     private String cronExpression;
 
     private String taskExplain;
 
     private Integer status;
 
 }

ScheduledJobMapper

public interface ScheduledJobMapper extends BaseMapper<ScheduledJob> {
 }

ScheduledJobService

public interface ScheduledJobService extends IService<ScheduledJob> {
 
     /**
      * 修改定時(shí)任務(wù)，并重新啟動(dòng)
      * @param scheduledJob
      * @return
      */
     boolean updateOne(ScheduledJob scheduledJob);
 }

@Service
 @Slf4j
 public class ScheduledJobServiceImpl extends ServiceImpl

2.10 修改定時(shí)任務(wù)的接口

@RestController
 @RequestMapping("/job")
 public class ScheduledJobController {
 
     @Autowired
     private ScheduledJobService scheduledJobService;
 
     @PostMapping(value = "/update")
     public CallBackResult update(HttpServletRequest request, ScheduledJob scheduledJob){
          if(scheduledJobService.updateOne(scheduledJob))
              return new CallBackResult(true,"修改成功");
          return new CallBackResult(false,"修改失敗");
     }
 
 }

3、測(cè)試結(jié)果

3.1 啟動(dòng)項(xiàng)目，看下定時(shí)任務(wù)的執(zhí)行結(jié)果，控制臺(tái)輸出結(jié)果

我們可以看到任務(wù)1是每5秒執(zhí)行一次，任務(wù)2是12秒執(zhí)行一次

3.2 修改任務(wù)1的cron參數(shù)或者狀態(tài)

3.2.1 修改cron，執(zhí)行周期改為20秒執(zhí)行一次，狀態(tài)不變

再看控制臺(tái)輸出結(jié)果，任務(wù)2沒(méi)變化，任務(wù)1由5秒一次變成了20秒一次了

3.2.1 修改狀態(tài)

再看控制臺(tái)輸出結(jié)果，任務(wù)2沒(méi)變化，任務(wù)1已經(jīng)不再執(zhí)行了

最后

第二種方式支持通過(guò)接口的方式去改動(dòng)，并且不需要重啟，當(dāng)然啦，也可以直接在數(shù)據(jù)庫(kù)中添加或修改數(shù)據(jù)后重啟項(xiàng)目，配置更加靈活一點(diǎn)。

如果是一個(gè)固定的需求，執(zhí)行周期一定不會(huì)變的了，推薦還是第一種寫法，畢竟簡(jiǎn)單嘛。

如果覺(jué)得寫得還不錯(cuò)的話，給個(gè)推薦鼓勵(lì)一下吧。