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>
第二步:
建表
CREATE TABLE `shedlock` (
`name` varchar(64) COLLATE utf8mb4_bin NOT NULL,
`lock_until` timestamp(3) NULL DEFAULT NULL,
`locked_at` timestamp(3) NULL DEFAULT NULL,
`locked_by` varchar(255) COLLATE utf8mb4_bin DEFAULT NULL,
PRIMARY KEY (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
第三步:在定时的方法上使用2个注解
参数说明
* 定时任务使用的是shedLock --jdbc分布式锁,当任务执行的时,
* 当前节点获取到锁,存储到sehdlock表中,表由框架维护,无需我们设置
* @Scheduled 定时任务时间表达式
* @SchedulerLock任务锁---
* name->锁名称
* lockAtMostFor-->设置锁的最大持续时间,防止当某个节点宕机,没有释放,导致其他节点不能执行下一次任务
* lockAtLeastFor-->保留锁的最短时间,防止如果定时的执行时间短,不同节点之间的服务器时间存在差异,导致定时重复执行;
定时任务执行类
@Scheduled(cron = "0 0/15 * * * ?")
@SchedulerLock(name = "syncOrder",
lockAtMostFor = 10 * 60 * 1000, lockAtLeastFor = 5 * 60 * 1000)
public void execute() {
orderSyncService.syncOrder();
}
第四步:配置类
package com.rk.iam.sys.config;
import net.javacrumbs.shedlock.core.LockProvider;
import net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider;
import net.javacrumbs.shedlock.spring.ScheduledLockConfiguration;
import net.javacrumbs.shedlock.spring.ScheduledLockConfigurationBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import javax.sql.DataSource;
import java.time.Duration;
/**
* @author wdy
* @version 1.0
* @date 2022/3/31 16:04
*/
@Configuration
@EnableScheduling
public class ShedlockConfig {
@Bean
public LockProvider lockProvider(DataSource dataSource) {
return new JdbcTemplateLockProvider(dataSource);
}
@Bean
public ScheduledLockConfiguration scheduledLockConfiguration(LockProvider lockProvider) {
return ScheduledLockConfigurationBuilder
.withLockProvider(lockProvider)
.withPoolSize(10)
.withDefaultLockAtMostFor(Duration.ofMinutes(10))
.build();
}
}
?
至此,集成结束,直接就能使用啦
只做了这么些,shedLock是如何保证定时只会在一个节点上执行呢? shedLock 当多个节点都有定时,某个节点启动后,会获得数据中shedLock表中的锁,其他的定时再来时,无法获取锁对象,认为其他的节点已经在执行了,所以就不在去执行。这个表是shedLock自带的表,无需程序员自己维护
?
|