本篇内容介绍了“SpringBoot定时任务功能怎么实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!项目中需要一个可以动态新增定时定时任务的功能,现在项目中使用的是xxl-job定时任务调度系统,但是经过一番对xxl-job功能的了解,发现xxl-job对项目动态新增定时任务,动态删除定时任务的支持并不是那么好,所以需要自己手动实现一个定时任务的功能1 技术选择Timer
or ScheduledExecutorService
这两个都能实现定时任务调度,先看下Timer的定时任务调度在看下ScheduledThreadPoolExecutor的实现两个都能实现定时任务,那他们的区别呢,使用阿里p3c会给出建议和区别从建议上来看,是一定要选择ScheduledExecutorService
了,我们看看源码看看为什么Timer
出现问题会终止执行新建对象时,我们看到开启了一个线程,那么这个线程在做什么呢?一起看看我们看到,执行了 mainLoop()
,里面是 while (true)
方法无限循环,获取程序中任务对象中的时间和当前时间比对,相同就执行,但是一旦报错,就会进入finally中清除掉所有任务信息。这时候我们已经找到了答案,timer是在被实例化后,启动一个线程,不间断的循环匹配,来执行任务,他是单线程的,一旦报错,线程就终止了,所以不会执行后续的任务,而ScheduledThreadPoolExecutor是多线程执行的,就算其中有一个任务报错了,并不影响其他线程的执行。2 使用ScheduledThreadPoolExecutor从上面看,使用ScheduledThreadPoolExecutor
还是比较简单的,但是我们要实现的更优雅一些,所以选择 TaskScheduler
来实现TaskScheduler
是本次功能实现的核心类,但是他是一个接口Executionwillendoncetheschedulershutsdownorthereturned
*{@linkScheduledFuture}getscancelled.
*@paramtasktheRunnabletoexecutewheneverthetriggerfires
*@paramtriggeranimplementationofthe{@linkTrigger}interface,
*e.g.a{@linkorg.springframework.scheduling.support.CronTrigger}object
*wrappingacronexpression
*@returna{@linkScheduledFuture}representingpendingcompletionofthetask,
*or{@codenull}ifthegivenTriggerobjectneverfires(i.e.returns
*{@codenull}from{@linkTrigger#nextExecutionTime})
*@throws免费云主机域名org.springframework.core.task.TaskRejectedExceptionifthegiventaskwasnotaccepted
*forinternalreasons(e.g.apooloverloadhandlingpolicyorapoolshutdowninprogress)
*@seeorg.springframework.scheduling.support.CronTrigger
*/
@Nullable
ScheduledFuture>schedule(Runnabletask,Triggertrigger);前面的代码可以看到,我们在类中注入了这个类,但是他是接口,我们怎么知道是那个实现类呢,以往出现这种情况要在类上面加@Primany或者@Quality来执行实现的类,但是我们看到我的注入上并没有标记,因为是通过另一种方式实现的在spring初始化时就注册了Bean TaskScheduler,而我们可以看到他的实现是ThreadPoolTaskScheduler,在网上的资料中有人说ThreadPoolTaskScheduler是TaskScheduler的默认实现类,其实不是,还是需要我们去指定,而这种方式,当我们想替换实现时,只需要修改配置类就行了,很灵活。而为什么说他是更优雅的实现方式呢,因为他的核心也是通过ScheduledThreadPoolExecutor来实现的这次的实现过程中,我并没有选择xxl-job来进行实现,而是采用了TaskScheduler来实现,这也产生了一个问题,xxl-job是分布式的程序调度系统,当想要执行定时任务的应用使用xxl-job时,无论应用程序中部署多少个节点,xxl-job只会选择其中一个节点作为定时任务执行的节点,从而不会产生定时任务在不同节点上同时执行,导致重复执行问题,而使用TaskScheduler来实现,就要考虑多节点重复执行问题。当然既然有问题,就有解决方案 方案一 将定时任务功能拆出来单独部署,且只部署一个节点 方案二 使用redis setNx的形式,保证同一时间只有一个任务在执行我选择的是方案二来执行,当然还有一些方式也能保证不重复执行,这里就不多说了,一下是我的实现“SpringBoot定时任务功能怎么实现”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注百云主机网站,小编将为大家输出更多高质量的实用文章!
相关推荐: vue-cli3在main.js中console.log()会报错怎么解决
这篇文章主要讲解了“vue-cli3在main.js中console.log()会报错怎么解决”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“vue-cli3在main.js中con免费云主机域名sole.log…
免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。