這篇文章主要介紹了SpringBoot基于數(shù)據(jù)庫如何實(shí)現(xiàn)定時(shí)任務(wù)，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),碭山企業(yè)網(wǎng)站建設(shè),碭山品牌網(wǎng)站建設(shè),網(wǎng)站定制,碭山網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,碭山網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

在我們平時(shí)開發(fā)的項(xiàng)目中，定時(shí)任務(wù)基本屬于必不可少的功能，那大家都是怎么做的呢？但我知道的大多都是靜態(tài)定時(shí)任務(wù)實(shí)現(xiàn)。

基于注解來創(chuàng)建定時(shí)任務(wù)非常簡單，只需幾行代碼便可完成。實(shí)現(xiàn)如下：

@Configuration
@EnableScheduling
public class SimpleScheduleTask {
 
  //10秒鐘執(zhí)行一次
  @Scheduled(cron = "0/10 * * * * ?")
  private void tasks() {
    System.out.println("【定時(shí)任務(wù)】 每10秒執(zhí)行一次！");
  }
}

Cron表達(dá)式參數(shù)分別表示（從左到右）：
秒（0~59） 如0/5表示每5秒
分（0~59）
時(shí)（0~23）
日（0~31) 月的某一天
月（0~11）
周幾（ 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT）

就上面幾行代碼，就能搞定一個(gè)定時(shí)任務(wù)。顯然，使用Scheduled 確實(shí)特別的方便，但有很大的缺點(diǎn)和局限，就是當(dāng)我們調(diào)整了執(zhí)行計(jì)劃的時(shí)間時(shí)，需要重啟服務(wù)才能生效，這就有些不方便。為了達(dá)到實(shí)時(shí)生效的效果，可以通過數(shù)據(jù)庫來動(dòng)態(tài)實(shí)現(xiàn)定時(shí)任務(wù)。

基于數(shù)據(jù)庫的動(dòng)態(tài)定時(shí)任務(wù)實(shí)現(xiàn)

將定時(shí)任務(wù)配置在數(shù)據(jù)庫，啟動(dòng)項(xiàng)目的時(shí)候，用mybatis讀取數(shù)據(jù)庫，實(shí)例化對象，并設(shè)定定時(shí)任務(wù)。如果需要新增，減少，修改定時(shí)任務(wù)，僅需要修改數(shù)據(jù)庫資料，并重啟項(xiàng)目即可，無需改代碼。

@Lazy(value = false)
@Component
public class ScheduleTask implements SchedulingConfigurer {
 
  protected static Logger logger = LoggerFactory.getLogger(ScheduleTask.class);
  private SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
  @Autowired
  private ScheduleTaskMapper scheduleTaskMapper;
 
  @Override
  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    List tasks = getAllScheduleTasks();
    logger.info("【定時(shí)任務(wù)啟動(dòng)】 啟動(dòng)任務(wù)數(shù)："+tasks.size()+"; time="+sdf.format(new Date()));
 
    //校驗(yàn)數(shù)據(jù)
    checkDataList(tasks);
    //通過校驗(yàn)的數(shù)據(jù)執(zhí)行定時(shí)任務(wù)
    int count = 0;
    if(tasks.size()>0) {
      for (int i = 0; i < tasks.size(); i++) {
        try {
          taskRegistrar.addTriggerTask(getRunnable(tasks.get(i)), getTrigger(tasks.get(i)));
          count++;
        } catch (Exception e) {
          logger.error("task start error:" + tasks.get(i).getClassName() + ";" + tasks.get(i).getMethodName() + ";" + e.getMessage());
        }
      }
    }
    logger.info("started task number="+count+"; time="+sdf.format(new Date()));
  };
 
 /**
 * 獲取要執(zhí)行的所有任務(wù)
 * @return
 */
  private List getAllScheduleTasks() {
    ScheduleTaskExample example=new ScheduleTaskExample();
    example.createCriteria().andIsDeleteEqualTo((byte) 0);
    return scheduleTaskMapper.selectByExample(example);
  }
  
 /**
 * 獲取Runnable
 *
 * @param task
 * @return
 */
  private Runnable getRunnable(ScheduleTask task){
    return new Runnable() {
      @Override
      public void run() {
        try {
          Object obj = SpringUtil.getBean(task.getClassName());
          Method method = obj.getClass().getMethod(task.getMethodName(),null);
          method.invoke(obj);
        } catch (InvocationTargetException e) {
          logger.error("refect exception:"+task.getClassName()+";"+task.getMethodName()+";"+ e.getMessage());
        } catch (Exception e) {
          logger.error(e.getMessage());
        }
      }
    };
  }
 
 /**
 * 獲取Trigger
 *
 * @param task
 * @return
 */
  private Trigger getTrigger(ScheduleTask task){
    return new Trigger() {
      @Override
      public Date nextExecutionTime(TriggerContext triggerContext) {
        //將Cron 0/1 * * * * ?
        CronTrigger trigger = new CronTrigger(task.getCron());
        Date nextExec = trigger.nextExecutionTime(triggerContext);
        return nextExec;
      }
    };
  }
  
 /**
 * 校驗(yàn)數(shù)據(jù)
 *
 * @param list
 * @return
 */
  private List checkDataList(List list) {
    String msg="";
    for(int i=0;i
數(shù)據(jù)庫配置
運(yùn)行的結(jié)果
這樣我們可以通過直接修改數(shù)據(jù)庫，執(zhí)行周期就會(huì)改變，并且不需要我們重啟應(yīng)用，十分方便。
感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“SpringBoot基于數(shù)據(jù)庫如何實(shí)現(xiàn)定時(shí)任務(wù)”這篇文章對大家有幫助，同時(shí)也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來學(xué)習(xí)!
            
            
                        

            分享標(biāo)題：SpringBoot基于數(shù)據(jù)庫如何實(shí)現(xiàn)定時(shí)任務(wù)            

            本文來源：http://weahome.cn/article/gdisjj.html