分布式系列教程(46) -分布式定时任务锁(ShedLock实现)

简介: 分布式系列教程(46) -分布式定时任务锁(ShedLock实现)

01 概述

定时任务经常被各个服务用到,比如定时清理日志,定时提醒,但是在分布式的环境下,一个任务会分配给多个微服务,每个微服务在某一时间可能会同时执行同一个事件,我们希望的是只有一个微服务去处理,这个时候需要用到了分布式定时任务锁,其中ShedLock是一种实现方式,本文来讲解。

备注:还可以使用xxl-job,有兴趣的童鞋可以参考之前写的博客《分布式系列教程(17) - 分布式任务调度平台XXL-JOB》)。

02 什么是ShedLock?

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

它的实现方式有如下几种:

  • Mongo
  • Redis
  • Hazelcast
  • ZooKeeper
  • 。。。。。。

接下来讲解使用JDBC锁。

03 使用方式

1.添加Maven依赖:

<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-spring</artifactId>
    <version>2.2.0</version>
</dependency>
<!-- 使用JDBC锁 -->
<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-provider-jdbc-template</artifactId>
    <version>2.2.0</version>
</dependency>

2.配置

@Configuration
public class ScheduledLockConfig
{
    @Bean
    public LockProvider lockProvider(DataSource dataSource) {
        return new JdbcTemplateLockProvider(dataSource);
    }
}

3.数据库中添加一张表(shedlock表):

类型 注释
name varchar 每个定时任务名字
lock_until timestamp 锁的结束时间
locked_at timestamp 锁的开始时间
locked_by varchar 服务名称

4.在启动类上加上注解EnableSchedulerLock,开启定时任务锁,指定一个默认的锁的时间:

@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
@SpringBootApplication
public class ScheduledLockApplication {
    public static void main(String[] args) {
        SpringApplication.run(ScheduledLockApplication.class, args);
    }
}

5.实现的代码(添加SchedulerLock注解):

@Component
public class ScheduledLock
{
    private static final int lockTime = 1000;
    @Scheduled(cron = "0/2 * * * * ?")
    @SchedulerLock(name = "TaskScheduler_scheduledTask", lockAtMostFor = lockTime, lockAtLeastFor = lockTime)
    public void run()
    {
        System.out.print(new Date().toString() + "\n");
    }
}
参数名 描述
name 定时任务的名字,就是数据库中的内个主键
lockAtMostFor 锁的最大时间单位为毫秒
lockAtMostForString 最大时间的字符串形式,例如:PT30S 代表30秒
lockAtLeastFor 锁的最小时间单位为毫秒
lockAtLeastForString 最小时间的字符串形式

执行结果(没有重复时间):

注意:如果要指定别的表名,可以配置第2步的LockProvider:

<bean id="lockProvider" class="net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider">
    <constructor-arg name="tableName" ref="dataSource"/>
</bean>

参考博客:

目录
相关文章
|
18天前
|
机器学习/深度学习 分布式计算 Python
OpenAI Gym 高级教程——分布式训练与并行化
OpenAI Gym 高级教程——分布式训练与并行化
47 1
|
22天前
|
NoSQL Java 数据库
分布式事务的锁
分布式事务的锁
17 0
分布式事务的锁
|
1月前
|
NoSQL 应用服务中间件 Redis
分布式锁【 基于synchronized锁解决超卖问题、分布式锁解决方案、悲观锁实现的分布式锁】(二)-全面详解(学习总结---从入门到深化)
分布式锁【 基于synchronized锁解决超卖问题、分布式锁解决方案、悲观锁实现的分布式锁】(二)-全面详解(学习总结---从入门到深化)
17 1
|
存储 关系型数据库 MySQL
分布式事物【悲观锁、乐观锁、读锁、写锁、间隙锁、临键锁 、 表锁、行锁、页面锁、 如何避免死锁】(二)-全面详解(学习总结---从入门到深化)
分布式事物【悲观锁、乐观锁、读锁、写锁、间隙锁、临键锁 、 表锁、行锁、页面锁、 如何避免死锁】(二)-全面详解(学习总结---从入门到深化)
30 0
|
1月前
|
监控 安全 Apache
Apache ZooKeeper - 使用ZK实现分布式锁(非公平锁/公平锁/共享锁 )
Apache ZooKeeper - 使用ZK实现分布式锁(非公平锁/公平锁/共享锁 )
42 1
|
2月前
|
应用服务中间件 Linux nginx
nginx分布式锁以及accept锁简单整理
nginx分布式锁以及accept锁简单整理
22 0
|
2月前
|
消息中间件 算法 Java
三面“有赞”Java岗斩获offer:Spring+JVM+并发锁+分布式+算法
年末离职,年初为面试也筹备挺长一段时间,找了不少复习资料,刷了很多题在网上投了很多简历最终面试了有赞,还有幸拿到offer!
|
2月前
|
存储 分布式计算 大数据
【云计算与大数据技术】分布式协同系统Chubby锁、ZooKeeper在HDFS中的使用讲解(图文解释 超详细)
【云计算与大数据技术】分布式协同系统Chubby锁、ZooKeeper在HDFS中的使用讲解(图文解释 超详细)
39 0
|
2月前
|
消息中间件 安全 Java
一起来探究@Schedule定时任务在分布式产生的问题
一起来探究@Schedule定时任务在分布式产生的问题
241 0
|
2月前
|
分布式计算 Hadoop Java
百度搜索:蓝易云【HBase分布式安装配置教程。】
以上是一个简要的HBase分布式安装和配置教程。需要注意的是,HBase的配置和部署涉及更多的细节和参数设置,取决于你的特定环境和需求。建议你参考HBase官方文档或其他可靠资源,以获得更详细和全面的指导。
32 6

热门文章

最新文章