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
数据库配置
 
运行的结果
 
这样我们可以通过直接修改数据库,执行周期就会改变,并且不需要我们重启应用,十分方便。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。