SpringBoot中怎么利用数据库实现一个定时任务

SpringBoot中怎么利用数据库实现一个定时任务，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：域名注册、虚拟空间、营销软件、网站建设、灵台网站维护、网站推广。

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

@Configuration@EnableSchedulingpublic 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)@Componentpublic 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

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。