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;igetAllScheduleTasks(){
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
*/
privateListcheckDataList(Listlist){
Stringmsg="";
for(inti=0;i数据库配置
运行的结果
这样我们可以通过直接修改数据库,执行周期就会改变,并且不需要我们重启应用,十分方便。
感谢你能够认真阅读完这篇文章,希望小编分享的“SpringBoot基于数据库如何实现定时任务”这篇文章对大家有帮助,同时也希望大家多多支持恰卡编程网,关注恰卡编程网行业资讯频道,更多相关知识等着你来学习!
推荐阅读
-
vue动态添加删除输入框(springboot vue怎么让数据库显示出来)
springbootvue怎么让数据库显示出来?一般情况下是前端调阅后端接口,来获取到数据库的数据,后端哪里会把数据库的数据整理...
-
springboot实现基于aop的切面日志
本文实例为大家分享了springboot实现基于aop的切面日志的具体代码,供大家参考,具体内容如下通过aop的切面方式实现日志...
-
SpringBoot定时任务功能怎么实现
-
SpringBoot中的@Import注解怎么使用
-
SpringBoot整合Lombok及常见问题怎么解决
SpringBoot整合Lombok及常见问题怎么解决这篇文章主要...
-
springboot图片验证码功能模块怎么实现
springboot图片验证码功能模块怎么实现本篇内容主要讲解“s...
-
Springboot+SpringSecurity怎么实现图片验证码登录
-
SpringBoot注解的知识点有哪些
SpringBoot注解的知识点有哪些这篇“SpringBoot注...
-
SpringBoot2.x中management.security.enabled=false无效怎么解决
SpringBoot2.x中management.security.enabled=false无效怎么解决...
-
springboot怎么禁用某项健康检查
springboot怎么禁用某项健康检查今天小编给大家分享一下sp...
