SpringBoot基于数据库实现定时任务过程解析
这篇文章主要介绍了SpringBoot基于数据库实现定时任务过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
在我们平时开发的项目中,定时任务基本属于必不可少的功能,那大家都是怎么做的呢?但我知道的大多都是静态定时任务实现。
基于注解来创建定时任务非常简单,只需几行代码便可完成。实现如下:
@Configuration @EnableScheduling publicclassSimpleScheduleTask{ //10秒钟执行一次 @Scheduled(cron="0/10****?") privatevoidtasks(){ 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 publicclassScheduleTaskimplementsSchedulingConfigurer{ protectedstaticLoggerlogger=LoggerFactory.getLogger(ScheduleTask.class); privateSimpleDateFormatsdf=newSimpleDateFormat("yyyy-MM-ddHH:mm:ss"); @Autowired privateScheduleTaskMapperscheduleTaskMapper; @Override publicvoidconfigureTasks(ScheduledTaskRegistrartaskRegistrar){ Listtasks=getAllScheduleTasks(); logger.info("【定时任务启动】启动任务数:"+tasks.size()+";time="+sdf.format(newDate())); //校验数据 checkDataList(tasks); //通过校验的数据执行定时任务 intcount=0; if(tasks.size()>0){ for(inti=0;i getAllScheduleTasks(){ ScheduleTaskExampleexample=newScheduleTaskExample(); example.createCriteria().andIsDeleteEqualTo((byte)0); returnscheduleTaskMapper.selectByExample(example); } /** *获取Runnable * *@paramtask *@return */ privateRunnablegetRunnable(ScheduleTasktask){ returnnewRunnable(){ @Override publicvoidrun(){ try{ Objectobj=SpringUtil.getBean(task.getClassName()); Methodmethod=obj.getClass().getMethod(task.getMethodName(),null); method.invoke(obj); }catch(InvocationTargetExceptione){ logger.error("refectexception:"+task.getClassName()+";"+task.getMethodName()+";"+e.getMessage()); }catch(Exceptione){ logger.error(e.getMessage()); } } }; } /** *获取Trigger * *@paramtask *@return */ privateTriggergetTrigger(ScheduleTasktask){ returnnewTrigger(){ @Override publicDatenextExecutionTime(TriggerContexttriggerContext){ //将Cron0/1****? CronTriggertrigger=newCronTrigger(task.getCron()); DatenextExec=trigger.nextExecutionTime(triggerContext); returnnextExec; } }; } /** *校验数据 * *@paramlist *@return */ privateList checkDataList(List list){ Stringmsg=""; for(inti=0;i 数据库配置
运行的结果
这样我们可以通过直接修改数据库,执行周期就会改变,并且不需要我们重启应用,十分方便。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。