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看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。
当前文章:SpringBoot中怎么利用数据库实现一个定时任务
路径分享:http://cdxtjz.cn/article/poccpi.html