在实际的项目开发工作中，我们经常会遇到需要做一些定时任务的工作，那么在Spring Cloud中是如何实现的？今天来介绍下其中的一种解决方案——轻量级分布式定时锁ShedLock
ShedLock是一个在分布式环境中使用的定时任务框架，用于解决在分布式环境中的多个实例的相同定时任务在同一时间点重复执行的问题。
解决思路是通过对公用的数据库中的某个表进行记录和加锁，使得同一时间点只有第一个执行定时任务并成功在数据库表中写入相应记录的节点能够成功执行而其他节点直接跳过该任务。
目前已经实现的支持数据存储类型不仅仅只有关系型数据库，还包括MongoDB，Zookeeper，Redis，Hazelcast。
在pom文件中添加shedLock相关依赖
net.javacrumbs.shedlock
shedlock-spring
2.2.0
net.javacrumbs.shedlock
shedlock-provider-jdbc-template
2.2.0
在启动类添加@EnableScheduling和@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")注解，表示要启动ShedLock定时任务
defaultLockAtMostFor要设置值，不设置会报错；设置值一般设置比定时任务大点值，一般在每个定时任务中都会配置defaultLockAtMostFor值，会覆盖启动类中的值
@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
public class OneStopServiceApplication {
public static void main(String[] args) {
SpringApplication.run(OneStopServiceApplication.class, args);
}
}
shedLock支持关系型数据库，以mysql为例，配置mysql以及表名；shedLock默认表名为shedlock,可以设置自定义表名。
@Configuration
public class ScheduledLockConfig {
@Bean
public LockProvider lockProvider(DataSource dataSource) {
//自定义表名
return new JdbcTemplateLockProvider(dataSource,"ccsy_shedlock");
}
}
@Component
public class HourTask {
/**
* 最小锁定时间,一般设置成定时任务小一点
*/
private static final int MIN_LOCK_TIME = 1000;//单位毫秒
/**
* 最大锁定时间,一般设置成比正常执行时间长的值
*/
private static final int MAX_LOCK_TIME = 1000 * 2;//单位毫秒
@Scheduled(cron = "0/1 * * * * ? ")
@SchedulerLock(name = "测试", lockAtMostFor = MAX_LOCK_TIME, lockAtLeastFor = MIN_LOCK_TIME)
public void visitCountTaskByTwoHour() {
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("现在时间是" + format.format(new Date())+ Thread.currentThread().getName());
}
}
@SchedulerLock注解一共支持五个参数，分别是
CREATE TABLE ccsy_shedlock ( NAME VARCHAR ( 64 ), lock_until TIMESTAMP ( 3 ) NULL, locked_at TIMESTAMP ( 3 ) NULL, locked_by VARCHAR ( 255 ), PRIMARY KEY ( NAME ))
到此这篇关于Spring Cloud分布式定时器之ShedLock的实现的文章就介绍到这了,更多相关Spring Cloud分布式定时器内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
京公网安备 11010802040832号 | 京ICP备19059560号-6 