SpringBoot基于数据库如何实现定时任务

这篇文章主要介绍了SpringBoot基于数据库如何实现定时任务,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。

创新互联是一家集网站建设,砀山企业网站建设,砀山品牌网站建设,网站定制,砀山网站建设报价,网络营销,网络优化,砀山网站推广为一体的创新建站企业,帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿,时刻以成就客户成长自我,坚持不断学习、思考、沉淀、净化自己,让我们为更多的企业打造出实用型网站。

在我们平时开发的项目中,定时任务基本属于必不可少的功能,那大家都是怎么做的呢?但我知道的大多都是静态定时任务实现。

基于注解来创建定时任务非常简单,只需几行代码便可完成。实现如下:

@Configuration
@EnableScheduling
public class SimpleScheduleTask {
 
  //10秒钟执行一次
  @Scheduled(cron = "0/10 * * * * ?")
  private void tasks() {
    System.out.println("【定时任务】 每10秒执行一次!");
  }
}

Cron表达式参数分别表示(从左到右):
秒(0~59) 如0/5表示每5秒
分(0~59)
时(0~23)
日(0~31) 月的某一天
月(0~11)
周几( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)

就上面几行代码,就能搞定一个定时任务。显然,使用Scheduled 确实特别的方便,但有很大的缺点和局限,就是当我们调整了执行计划的时间时,需要重启服务才能生效,这就有些不方便。为了达到实时生效的效果,可以通过数据库来动态实现定时任务。

基于数据库的动态定时任务实现

将定时任务配置在数据库,启动项目的时候,用mybatis读取数据库,实例化对象,并设定定时任务。如果需要新增,减少,修改定时任务,仅需要修改数据库资料,并重启项目即可,无需改代码。

@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("【定时任务启动】 启动任务数:"+tasks.size()+"; time="+sdf.format(new Date()));
 
    //校验数据
    checkDataList(tasks);
    //通过校验的数据执行定时任务
    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()));
  };
 
 /**
 * 获取要执行的所有任务
 * @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;
      }
    };
  }
  
 /**
 * 校验数据
 *
 * @param list
 * @return
 */
  private List checkDataList(List list) {
    String msg="";
    for(int i=0;i

数据库配置

SpringBoot基于数据库如何实现定时任务

运行的结果

SpringBoot基于数据库如何实现定时任务

这样我们可以通过直接修改数据库,执行周期就会改变,并且不需要我们重启应用,十分方便。

感谢你能够认真阅读完这篇文章,希望小编分享的“SpringBoot基于数据库如何实现定时任务”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!


分享文章:SpringBoot基于数据库如何实现定时任务
链接分享:http://cdiso.cn/article/gdisjj.html

其他资讯