shedLock介绍:
当我们的服务是集群部署时,我们代码中的定时任务在每个节点都有,每个节点都去跑定时任务很显然不大合适,这就是我们要解决的问题。
因为在项目中有用到,所以记录一下SpringBoot怎么集成ShedLock,还有shedLock是如何实现分布式定时的。
使用方法:
第一步:引入依赖
<dependency>
<groupId>net.javacrumbs.shedlock</groupId>
<artifactId>shedlock-spring</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>net.javacrumbs.shedlock</groupId>
<artifactId>shedlock-provider-jdbc-template</artifactId>
<version>2.3.0</version>
</dependency>
第二步:在定时的方法上使用2个注解
@Scheduled(cron = "0 0/15 * * * ?")
@SchedulerLock(name = "syncOrder",
lockAtMostFor = 10 * 60 * 1000, lockAtLeastFor = 5 * 60 * 1000)
public void execute() {
orderSyncService.syncOrder();
}
注解参数说明:
* 定时任务使用的是shedLock --jdbc分布式锁,当任务执行的时,
* 当前节点获取到锁,存储到sehdlock表中,表由框架维护,无需我们设置
* @Scheduled 定时任务时间表达式
* @SchedulerLock任务锁---
* name->锁名称
* lockAtMostFor-->设置锁的最大持续时间,防止当某个节点宕机,没有释放,导致其他节点不能执行下一次任务
* lockAtLeastFor-->保留锁的最短时间,防止如果定时的执行时间短,不同节点之间的服务器时间存在差异,导致定时重复执行;
第三步:在SpringBoot的入口类上添加启用定时注解
@SpringBootApplication
@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
public class Application {
至此,集成结束,直接就能使用啦
只做了这么些,shedLock是如何保证定时只会在一个节点上执行呢?
shedLock 当多个节点都有定时,某个节点启动后,会获得数据中shedLock表中的锁,其他的定时再来时,无法获取锁对象,认为其他的节点已经在执行了,所以就不在去执行。这个表是shedLock自带的表,无需程序员自己维护
非常地方便。
网友评论