分布式系列教程(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>

参考博客:

目录
相关文章
|
9天前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要,常用于异步数据处理、自动化运维等场景。在单体应用中,利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而,进入微服务架构后,任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块,提供轻量级、高可用的分布式定时任务解决方案,支持防重复执行、分片运行等功能,并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案(如ShedLock)
|
3月前
|
消息中间件 NoSQL Java
Redis系列学习文章分享---第六篇(Redis实战篇--Redis分布式锁+实现思路+误删问题+原子性+lua脚本+Redisson功能介绍+可重入锁+WatchDog机制+multiLock)
Redis系列学习文章分享---第六篇(Redis实战篇--Redis分布式锁+实现思路+误删问题+原子性+lua脚本+Redisson功能介绍+可重入锁+WatchDog机制+multiLock)
181 0
|
13天前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
这篇文章介绍了如何在SpringBoot项目中整合Redis,并探讨了缓存穿透、缓存雪崩和缓存击穿的问题以及解决方法。文章还提供了解决缓存击穿问题的加锁示例代码,包括存在问题和问题解决后的版本,并指出了本地锁在分布式情况下的局限性,引出了分布式锁的概念。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
|
2月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
Spring Cloud Alibaba 发布了 Scheduling 任务调度模块 [#3732]提供了一套开源、轻量级、高可用的定时任务解决方案,帮助您快速开发微服务体系下的分布式定时任务。
14451 23
|
5天前
|
存储 消息中间件 移动开发
还在用crontab? 分布式定时任务了解一下
还在用crontab? 分布式定时任务了解一下
|
5天前
|
消息中间件 存储 Kafka
微服务实践之分布式定时任务
微服务实践之分布式定时任务
|
11天前
|
Dubbo Java 调度
揭秘!Spring Cloud Alibaba的超级力量——如何轻松驾驭分布式定时任务调度?
【8月更文挑战第20天】在现代微服务架构中,Spring Cloud Alibaba通过集成分布式定时任务调度功能解决了一致性和可靠性挑战。它利用TimerX实现任务的分布式编排与调度,并通过`@SchedulerLock`确保任务不被重复执行。示例代码展示了如何配置定时任务及其分布式锁,以实现每5秒仅由一个节点执行任务,适合构建高可用的微服务系统。
36 0
|
16天前
|
算法
分布式锁设计问题之重建节点锁信息时要分为多个阶段如何解决
分布式锁设计问题之重建节点锁信息时要分为多个阶段如何解决
|
16天前
分布式锁设计问题之节点A向节点C发起对R1的加锁请求如何解决
分布式锁设计问题之节点A向节点C发起对R1的加锁请求如何解决
|
2月前
|
负载均衡 NoSQL Java
下一篇
云函数