个人中心
gpt4 book ai didi

Spring Cloud分布式定时器之ShedLock的实现

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Spring Cloud分布式定时器之ShedLock的实现由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

在实际的项目开发工作中，我们经常会遇到需要做一些定时任务的工作，那么在Spring Cloud中是如何实现的？今天来介绍下其中的一种解决方案——轻量级分布式定时锁ShedLock 。

ShedLock

ShedLock是一个在分布式环境中使用的定时任务框架，用于解决在分布式环境中的多个实例的相同定时任务在同一时间点重复执行的问题.

解决思路是通过对公用的数据库中的某个表进行记录和加锁，使得同一时间点只有第一个执行定时任务并成功在数据库表中写入相应记录的节点能够成功执行而其他节点直接跳过该任务。 目前已经实现的支持数据存储类型不仅仅只有关系型数据库，还包括MongoDB，Zookeeper，Redis，Hazelcast.

1. pom文件添加相关依赖

在pom文件中添加shedLock相关依赖 。

?
1
2
3
4
5
6
7
8
9
10
11
<!--shedlock-->
    < dependency >
      < groupId >net.javacrumbs.shedlock</ groupId >
      < artifactId >shedlock-spring</ artifactId >
      < version >2.2.0</ version >
    </ dependency >
    < dependency >
      < groupId >net.javacrumbs.shedlock</ groupId >
      < artifactId >shedlock-provider-jdbc-template</ artifactId >
      < version >2.2.0</ version >
    </ dependency >

2. 添加相关配置

在启动类添加@EnableScheduling和@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")注解，表示要启动ShedLock定时任务 。

defaultLockAtMostFor要设置值，不设置会报错；设置值一般设置比定时任务大点值，一般在每个定时任务中都会配置defaultLockAtMostFor值，会覆盖启动类中的值 。

?
1
2
3
4
5
6
7
8
@EnableScheduling
@EnableSchedulerLock (defaultLockAtMostFor = "PT30S" )
public class OneStopServiceApplication {
   public static void main(String[] args) {
     SpringApplication.run(OneStopServiceApplication. class , args);
   }
 
}

3.添加ShedLock配类

shedLock支持关系型数据库，以mysql为例，配置mysql以及表名；shedLock默认表名为shedlock,可以设置自定义表名.

?
1
2
3
4
5
6
7
8
@Configuration
public class ScheduledLockConfig {
   @Bean
   public LockProvider lockProvider(DataSource dataSource) {
     //自定义表名
     return new JdbcTemplateLockProvider(dataSource, "ccsy_shedlock" );
   }
}

4.ShedLock定时任务

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@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注解一共支持五个参数，分别是 。

  • name 用来标注一个定时服务的名字，被用于写入数据库作为区分不同服务的标识，如果有多个同名定时任务则同一时间点只有一个执行成功
  • lockAtMostFor 成功执行任务的节点所能拥有独占锁的最长时间，单位是毫秒ms
  • lockAtMostForString 成功执行任务的节点所能拥有的独占锁的最长时间的字符串表达，例如“PT14M”表示为14分钟
  • lockAtLeastFor 成功执行任务的节点所能拥有独占所的最短时间，单位是毫秒ms
  • lockAtLeastForString 成功执行任务的节点所能拥有的独占锁的最短时间的字符串表达，例如“PT14M”表示为14分钟

5.创建mysql数据库中定时任务ccsy_shedlock表

?
1
2
3
4
5
6
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分布式定时器内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。

原文链接：https://juejin.cn/post/6937471031065968671 。

最后此篇关于Spring Cloud分布式定时器之ShedLock的实现的文章就讲到这里了,如果你想了解更多关于Spring Cloud分布式定时器之ShedLock的实现的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： ActiveMQ结合Spring收发消息的示例代码
文章推荐： C++ STL 四种智能指针的用法详解
文章推荐： 深入浅析SSH的三个组件ssh、sftp、scp
文章推荐： JetBrains IntelliJ IDEA 优化教程超详细
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com