一：ShedLock 简介
ShedLock是一个在分布式环境中使用的定时任务框架，用于解决在分布式环境中的多个实例的相同定时任务在同一时间点重复执行的问题。ShedLock确保计划的任务最多同时执行一次。如果一个任务正在一个节点上执行，它会获得一个锁，该锁将阻止从另一个节点（或线程）执行同一任务。请注意，如果一个任务已经在一个节点上执行，则在其他节点上的执行不会等待，只是将其跳过。。简单来说，ShedLock本身只做一件事情：保证一个任务最多同时执行一次。所以如官网所说的，ShedLock不是一个分布式调度器，只是一个锁!
注意：ShedLock支持Mongo，Redis，Hazelcast，ZooKeeper以及任何带有JDBC驱动程序的东西。本例子使用的是基于Redis的方式。之所以不适用基于jdbc存储的主要原因是考虑到大量数据下的数据库压力的原因，若本身基于jdbc等，可直接参考官网给出的提示：
创建对应的表结构。
CREATE TABLE shedlock(
name VARCHAR(64),
lock_until TIMESTAMP(3) NULL,
locked_at TIMESTAMP(3) NULL,
locked_by VARCHAR(255),
PRIMARY KEY (name)
)二：配置maven 依赖
<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-redis-spring</artifactId>
<version>2.3.0</version>
</dependency>
<!--spring2.0集成redis所需common-pool2 -->
<!-- 必须加上，jedis依赖此 若项目中已经引入jedis 请忽略此步骤-->
<!-- spring boot 2.0 的操作手册有标注 大家可以去看看 地址是：https://docs.spring.io/spring-boot/docs/2.0.3.RELEASE/reference/htmlsingle/ -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>添加jedis 依赖 若项目中已经引入jedis 请忽略此步骤
<!--spring2.0集成redis所需common-pool2 -->
<!-- 必须加上，jedis依赖此 若项目中已经引入jedis 请忽略此步骤-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>三：SchedulerLock 基于 Redis 的配置
配置 lockProvider 并且开启 @EnableSchedulerLock 标签
import net.javacrumbs.shedlock.core.LockProvider;
import net.javacrumbs.shedlock.provider.redis.spring.RedisLockProvider;
import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
@Configuration
//defaultLockAtMostFor 指定在执行节点结束时应保留锁的默认时间使用ISO8601 Duration格式
//作用就是在被加锁的节点挂了时，无法释放锁，造成其他节点无法进行下一任务
//这里默认55s
//关于ISO8601 Duration格式用的不到，具体可上网查询下相关资料，应该就是一套规范，规定一些时间表达方式
@EnableSchedulerLock(defaultLockAtMostFor = "PT55S")
public class ShedLockRedisConfig {
@Value("${spring.profiles.active}")
private String env;
@Bean
public LockProvider lockProvider(RedisConnectionFactory connectionFactory) {
//环境变量 -需要区分不同环境避免冲突，如dev环境和test环境，两者都部署时，只有一个实例进行，此时会造成相关环境未启动情况
return new RedisLockProvider(connectionFactory, env);
}
}四：在启动类中添加 @EnableScheduling 标签
注意，要在启动类上添加 @EnableScheduling ，表明开启定时器服务。若不加定时器是不会起效的。
@SpringBootApplication
@EnableScheduling
public class EpidemicMessageApplication {
public static void main(String[] args) {
SpringApplication.run(EpidemicMessageApplication.class, args);
}
}五：test 测试案例
//区分服务
@Value("${server.port}")
private String port;
@Scheduled(cron = "0 */1 * * * ?")
@SchedulerLock(name = "scheduledController_notice", lockAtLeastForString = "PT15M", lockAtMostForString = "PT14M")
public StandardResult notice() {
try {
logger.info(port + "- 执行定时器 scheduledController_notice");
return StandardResult.ok();
} catch (Exception e) {
logger.error("异常信息:", e);
return StandardResult.faild("异常信息", e);
}
}SchedulerLock注解说明
@SchedulerLock注解一共支持五个参数，分别是
name：用来标注一个定时服务的名字，被用于写入数据库作为区分不同服务的标识，如果有多个同名定时任务则同一时间点只有一个执行成功
lockAtMostFor：成功执行任务的节点所能拥有独占锁的最长时间，单位是毫秒ms
lockAtMostForString：成功执行任务的节点所能拥有的独占锁的最长时间的字符串表达，例如“PT14M”表示为14分钟，单位可以是S,M,H
lockAtLeastFor：成功执行任务的节点所能拥有独占所的最短时间，单位是毫秒ms
lockAtLeastForString：成功执行任务的节点所能拥有的独占锁的最短时间的字符串表达，例如“PT14M”表示为14分钟,单位可以是S,M,H
到此这篇关于SpringBoot 集成 ShedLock 分布式锁的文章就介绍到这了,更多相关SpringBoot 分布式锁ShedLock内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
