SpringCloud--分布式锁实现

一、简介

分布式锁其实就是控制分布式系统中不同进程共同访问共享资源的一种锁的实现。在分布式系统中各个微服务都是独立部署在不同的服务器上，如果多个服务同时操作同一个共享资源的话，就不能像单体服务那样通过synchronized或者Lock等同步机制保证一个代码块在同一时间只能由一个线程访问来实现共享资源的安全性。因为分布式系统中的不同服务已经不在是多线程之间的并发访问了，而是属于多进程之间的并发访问，所以就需要一种更加高级的锁机制，来处理这种跨JVM进程之间的线程安全问题。

二、主要特征

  1. 互斥性：在任意时刻，只有一个客户端能持有锁。
  2. 不会发生死锁：即使持有锁的客户端发生故障，也能保证锁最终会被释放。
  3. 具有容错性：只要大部分的 Redis 节点正常运行，客户端就可以加锁和解锁。
  4. 不乱解锁：加锁和解锁必须是同一个客户端，客户端自己不能把别人加的锁给解了。

三、实现方案

在 Java 中，实现分布式锁的方案有多种，常见的3中方案如下：

  1. 基于数据库实现：可以通过数据库的乐观锁或悲观锁实现分布式锁，但是由于数据库的 IO 操作比较慢，不适合高并发场景，而且可能存在死锁和超时等问题。
  2. 基于 Redis 实现：Redis 是一个高性能的内存数据库，支持分布式部署，可以通过Redis的原子操作实现分布式锁，支持key的过期时间设置，不容易发生死锁，而且具有高性能和高可用性。
  3. 基于 Lock4j 实现：Lock4j 是一个分布式锁组件，它提供了多种不同的支持以满足不同性能和环境的需求，基于Spring AOP的声明式和编程式分布式锁，支持RedisTemplate、Redisson、Zookeeper。
  4. 基于 ZooKeeper 实现：ZooKeeper 是一个高可用性的分布式协调服务，可以通过它来实现分布式锁。但是使用 ZooKeeper 需要部署额外的服务，增加了系统复杂度。
3.1 基于 Redis 实现

  1. 实现方式有以下几种：
    （1）setnx + expire：这种方式加锁操作和设置超时时间是分开的。如果在执行完setnx加锁后，正要执行expire设置过期时间时，进程挂掉了，那这个锁就永远不会过期了。
    （2）set的扩展命令：通过set(String key, String value, String nxxx, String expx, int time) 加锁的同时设置过期时间，再通过del(key)删除key。这种方式可能导致锁被别的线程误删，假设A获取锁后，由于业务还没执行完就过期释放了，然后立即就被B获取该锁执行业务逻辑，此时A执行完成后就会去释放这个锁，但此时这个锁已经被B占用了，也就是说A此时把B的锁给释放掉了。
    （3）set的扩展命令+唯一值校验：通过set(String key, String value, String nxxx, String expx, int time) 加锁的同时设置过期时间，再通过Lua 脚本去根据唯一值删除key。这种方式可以解决误删除别人的锁问题，但是还是存在锁过期释放了，业务还没执行完的问题。

  2. 添加redis依赖

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version>
</dependency>
  1. 创建一个redis配置类，用来设置redis连接信息，并创建JedisPool和RedisTemplate的实例。
@Configuration
public class RedisConfig {@Value("${spring.redis.host}")private String host;@Value("${spring.redis.port}")private int port;@Value("${spring.redis.timeout}")private int timeout;@Value("${spring.redis.password}")private String password;@Value("${spring.redis.pool.maxTotal}")private int maxTotal;@Value("${spring.redis.pool.maxWait}")private int maxWait;@Value("${spring.redis.pool.maxIdle}")private int maxIdle;@Value("${spring.redis.pool.minIdle}")private int minIdle;@Value("${spring.redis.blockWhenExhausted}")private Boolean blockWhenExhausted;@Value("${spring.redis.JmxEnabled}")private Boolean JmxEnabled;/*** 创建JedisPool实例* * @return JedisPool*/@RefreshScope@Beanpublic JedisPool jedisPoolFactory() {JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();jedisPoolConfig.setMaxTotal(maxTotal);jedisPoolConfig.setMaxIdle(maxIdle);jedisPoolConfig.setMinIdle(minIdle);jedisPoolConfig.setMaxWaitMillis(maxWait);// 连接耗尽时是否阻塞, false报异常,true阻塞直到超时, 默认truejedisPoolConfig.setBlockWhenExhausted(blockWhenExhausted);// 是否启用pool的jmx管理功能, 默认truejedisPoolConfig.setJmxEnabled(JmxEnabled);return new JedisPool(jedisPoolConfig, host, port, timeout, password);}/*** redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类** @return redisTemplate*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// 使用Jackson2JsonRedisSerialize 替换默认序列化@SuppressWarnings({ "rawtypes", "unchecked" })Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);// 设置value的序列化规则和 key的序列化规则redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}
}
  1. 编写redis的工具类，使用（set的扩展命令+唯一值校验）的方式创建获取和释放分布式锁相应的方法。
@Slf4j
@Component
public class RedisUtil {@Resourceprivate RedisTemplate<String, Object> redisTemplate;@Resourceprivate StringRedisTemplate stringRedisTemplate;private static final String LOCK_SUCCESS = "OK";/*** NX: 仅在键不存在时设置键* XX: 只有在键已存在时才设置*/private static final String SET_IF_NOT_EXIST = "NX";/*** 过期时间单位* EX: seconds* PX: milliseconds*/private static final String SET_WITH_EXPIRE_TIME = "EX";private static final Long RELEASE_SUCCESS = 1L;/*** 尝试获取分布式锁** @param lockKey    分布式锁的key，想要获取锁时，判断这个key是否存在于redis中，存在则说明获取分布式锁失败，否则成功获取锁* @param requestId  每个请求的全局唯一id，用于释放锁时只能释放自己持有的锁* @param expireTime 超期时间,单位：秒* @return boolean   是否获取成功*/public boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {if (jedis == null) {return false;}String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);if (LOCK_SUCCESS.equals(result)) {log.info("========================================获取分布式锁成功, lockKey is：{}, requestId is:{}", lockKey, requestId);return true;}log.info("========================================获取分布式锁失败, lockKey is：{}, requestId is:{}", lockKey, requestId);return false;}/*** 释放分布式锁** @param jedis     Redis客户端* @param lockKey   分布式锁的key* @param requestId 每个请求的全局唯一id* @return 是否释放成功*/public boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {if (jedis == null) {log.info("========================================分布式锁释放失败,Jedis为空, lockKey is：{}, requestId is:{}", lockKey, requestId);return false;}// 通过Lua 脚本保证只释放requestId对应的lockKeyString script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));if (RELEASE_SUCCESS.equals(result)) {log.info("========================================分布式锁释放成功, lockKey is：{}, requestId is:{}", lockKey, requestId);return true;}log.info("========================================分布式锁释放失败, lockKey is：{}, requestId is:{}", lockKey, requestId);return false;}
}
  1. 案例实现
	/*** 通过分布式锁来生成全局订单唯一的id* * @param type 订单类型* @return String 订单唯一的id*/@Overridepublic String generate(String type) {String orderId = null;log.info("========================================要生成的订单类型为：{}", type);if (StringUtils.isBlank(type)) {return null;}// 开始获取分布式锁Jedis jedis = jedisPool.getResource();String lockKey = redisUtils.getRedisKey(RedisTemplateConstant.DISTRIBUTED_LOCK_KEY_TYPE, type);String requestId = CommonUtil.getUUID();try {if (redisUtils.tryGetDistributedLock(jedis, lockKey, requestId, expireTime)) {// 生成订单idorderId = getOrderId(type);}} catch (Exception e) {log.info("========================================组装id出错================================");} finally {// 释放分布式锁redisUtils.releaseDistributedLock(jedis, lockKey, requestId);if (jedis != null) {jedis.close();}}return orderId;}
3.2 基于 Redisson + RedLock
  1. Redisson：
    对于可能存在锁过期释放，业务没执行完的问题。Redisson的处理逻辑是：只要客户端一加锁成功，就会启动一个watch dog看门狗，它是一个后台线程，会每隔10秒检查一下，如果当前线程还持有锁，那么就会不断的延长锁key的生存时间。因此，Redisson就是使用 watch dog 解决了锁过期释放，业务没执行完问题。
  2. RedLock：
    由于Redis一般都是集群部署，如果客户端A在Redis的master节点上拿到了锁，但是加锁的key还没同步到slave节点。恰好这时，master节点发生故障，一个slave节点就会升级为master节点。客户端B就可以顺理成章获取同个key的锁了，但客户端A早在故障的master节点已经拿到这个锁了，从而导致分布式锁在这种情况下失效了。因此，可通过 redLock 红锁，一种相对安全的分布式锁实现方式，采用主节点过半机制，当客户端申请分布式锁的时候，需要向所有的redis实例发出申请，只有超过半数的redis实例报告获取锁成功，才能算真正获取到锁。也因此redis集群部署的节点数一般都为奇数。
  3. RedLock 已经在最新本的 Redisson 中被弃用了：
    其实红锁其实也并不能解决根本问题，只是降低问题发生的概率。因为完全相互独立的redis，每一台至少也要保证高可用，还是会有主从节点。既然有主从节点，在持续的高并发下，master还是可能会宕机，从节点可能还没来得及同步锁的数据。在实际场景中，红锁是很少使用的。这是因为使用了红锁后会影响高并发环境下的性能，使得程序的体验更差。同时，使用红锁后，当加锁成功的RLock个数不超过总数的一半时，会返回加锁失败，即使在业务层面任务加锁成功了，但是红锁也会返回加锁失败的结果。另外实现红锁需要提供多套Redis的主从部署架构，并且这多套Redis主从架构中的Master节点必须都是独立的，相互之间没有任何数据交互。
  4. 引入依赖
<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.20.0</version>
</dependency>
  1. 编写分布式锁工具类
@Slf4j
@Component
public class RedissonUtil {@Resourceprivate Redisson redisson;/*** 加锁** @param key     分布式锁的 key* @param timeout 超时时间* @param unit    时间单位* @return*/public boolean tryLock(String key, long timeout, TimeUnit unit) {RLock lock = redisson.getLock(key);try {return lock.tryLock(timeout, unit);} catch (InterruptedException e) {Thread.currentThread().interrupt();return false;}}/*** 释放分布式锁** @param key 分布式锁的 key*/public void unlock(String key) {RLock lock = redisson.getLock(key);lock.unlock();}
}
3.3 基于 Lock4j 实现
  1. 引入依赖

<!-- 若使用redisTemplate作为分布式锁底层，则需要引入 -->
<dependency><groupId>com.baomidou</groupId><artifactId>lock4j-redis-template-spring-boot-starter</artifactId><version>2.2.4</version>
</dependency>
<!-- 若使用redisson作为分布式锁底层，则需要引入 -->
<dependency><groupId>com.baomidou</groupId><artifactId>lock4j-redisson-spring-boot-starter</artifactId><version>2.2.4</version>
</dependency>
  1. 简单使用实例
@Slf4j
@RestController
@RequestMapping("/redisLock")
public class RedisLockController {@Autowiredprivate LockTemplate lockTemplate;/*** 使用 lock4j 注解加锁*/@Lock4j(keys = {"#key"}, acquireTimeout = 1000, expire = 10000)@GetMapping("/testAnnotate")public R<String> testAnnotate(String key) {try {Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}return R.ok(key);}/*** 使用LockTemplate模板加锁*/@GetMapping("/testLock4jLockTemplate")public R<String> testLock4jLockTemplate(String key) {final LockInfo lockInfo = lockTemplate.lock(key, 30000L, 5000L, RedissonLockExecutor.class);if (null == lockInfo) {throw new RuntimeException("业务繁忙,请稍后再试!");}// 获取锁成功，处理业务try {try {Thread.sleep(8000);} catch (InterruptedException e) {//}System.out.println("当前线程:" + Thread.currentThread().getName());} finally {//释放锁lockTemplate.releaseLock(lockInfo);}return R.ok(key);}
}
3.4 基于 ZooKeeper 实现
  1. 引入依赖
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>latest</version>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>latest</version>
</dependency>
<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>latest</version>
</dependency>
  1. 配置 ZooKeeper 连接
spring:zookeeper:connect-string: localhost:8081namespace: test
  1. 编写分布式锁工具类
@Component
public class ZkLockUtil {@Autowiredprivate CuratorFramework curatorFramework;/*** 获取分布式锁** @param lockPath  锁路径* @param waitTime  等待时间* @param leaseTime 锁持有时间* @param timeUnit  时间单位* @return 锁对象* @throws Exception 获取锁异常*/public InterProcessMutex acquire(String lockPath, long waitTime, long leaseTime, TimeUnit timeUnit) throws Exception {InterProcessMutex lock = new InterProcessMutex(curatorFramework, lockPath);if (!lock.acquire(waitTime, timeUnit)) {throw new RuntimeException("获取分布式锁失败");}if (leaseTime > 0) {lock.acquire(leaseTime, timeUnit);}return lock;}/*** 释放分布式锁** @param lock 锁对象* @throws Exception 释放锁异常*/public void release(InterProcessMutex lock) throws Exception {if (lock != null) {lock.release();}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/153034.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

深入探索 PaddlePaddle 中的计算图

深入探索 PaddlePaddle 中的计算图

**引言** 计算图是深度学习平台 PaddlePaddle 的核心组件之一&#xff0c;它提供了一种图形化的方式来表示和执行深度学习模型。通过了解和理解 PaddlePaddle 中的计算图&#xff0c;我们可以更好地理解深度学习的工作原理&#xff0c;并且能够更加灵活和高效地构建和训练复杂…
阅读更多...
stable diffusion十七种controlnet详细使用方法总结

stable diffusion十七种controlnet详细使用方法总结

个人网站&#xff1a;https://tianfeng.space 前言 最近不知道发点什么&#xff0c;做个controlnet 使用方法总结好了&#xff0c;如果你们对所有controlnet用法&#xff0c;可能了解但是有点模糊&#xff0c;希望能对你们有用。 一、SD controlnet 我统一下其他参数&#…
阅读更多...
PLC梯形图实操——风扇正反转

PLC梯形图实操——风扇正反转

文章目录 1.项目内创建函数块&#xff08;FB&#xff09;2.项目内创建数据块&#xff08;DB&#xff09;2.1去除优化块访问2.2去除优化块的访问后对数据块进行编译 3.在函数块&#xff08;FB&#xff09;内实现正转反转的自锁与互锁3.1在函数块内实现电机正反转的梯形图 4.主函…
阅读更多...
2 Redis的高级数据结构

2 Redis的高级数据结构

1、Bitmaps 首先&#xff0c;最经典的应用场景就是用户日活的统计&#xff0c;比如说签到等。 字段串&#xff1a;“dbydc”&#xff0c;根据对应的ASCII表&#xff0c;最后可以得到对应的二进制&#xff0c;如图所示 一个字符占8位&#xff08;bit&#xff09;&#xff0c;…
阅读更多...
解决SpringBoot中的MyBatis驼峰命名映射报错column不匹配问题

解决SpringBoot中的MyBatis驼峰命名映射报错column不匹配问题

使用MyBatis-Plus映射出现与数据库column匹配不上的报错 Cause: java.sql.SQLSyntaxErrorException: Unknown column ‘register_time’ in ‘field list’ 源代码&#xff1a; Data TableName("db_account") public class Account {TableId(type IdType.AUTO)Inte…
阅读更多...
Java的包，import

Java的包，import

包名定义&#xff1a; &#xff08;1&#xff09;名字全部小写 &#xff08;2&#xff09;中间用.隔开 &#xff08;3&#xff09;一般都是公司域名倒着写 &#xff1a; com.jd com.msb &#xff08;4&#xff09;加上模块名字&#xff1a; com.jd.login com.jd.re…
阅读更多...
mysql mvcc介绍

mysql mvcc介绍

一、什么是mvcc MVCC&#xff0c;即Multi-Version Concurrency Control &#xff08;多版本并发控制&#xff09;。它是一种并发控制的方法&#xff0c;一般在数据库管理系统中&#xff0c;实现对数据库的并发访问&#xff0c;在编程语言中实现事务内存。 二、什么时候会出现…
阅读更多...
HTTP1.1升级HTTP2.0

HTTP1.1升级HTTP2.0

HTTP1.1升级HTTP2.0 一&#xff0c;前言介绍 1.为什么要升级http2.0 HTTP2.0相比于HTTP1.x有以下几个优点&#xff1a; 二进制分帧&#xff1a;HTTP2.0将所有传输的信息分割为更小的消息和帧&#xff0c;并采用二进制格式对它们进行编码&#xff0c;这样可以更好地对数据进行…
阅读更多...
【Rust】快速教程——模块mod与跨文件

【Rust】快速教程——模块mod与跨文件

前言 道尊&#xff1a;没有办法&#xff0c;你的法力已经消失&#xff0c;我的法力所剩无几&#xff0c;除非咱们重新修行&#xff0c;在这个世界里取得更多法力之后&#xff0c;或许有办法下降。——《拔魔》 \;\\\;\\\; 目录 前言跨文件mod多文件mod 跨文件mod //my_mod.rs…
阅读更多...
单机版-redis（手动部署）

单机版-redis（手动部署）

单机版-redis部署 部署模式:单机版-redis部署 Redis版本&#xff1a;redis-4.0.1 部署redis方式&#xff1a;手动部署 解决GCC问题 linux升级gcc版本详细教程_gcc升级-CSDN博客 在完成第三步时已完成配置&#xff0c;后续为操作命令以及注意事项&#xff1b; 在进行操作数…
阅读更多...
一文彻底搞懂 JS 闭包

一文彻底搞懂 JS 闭包

闭包 定义 闭包是指一个引用了另一个函数作用域中变量的函数&#xff0c;由于 JS 中作用域的特性&#xff0c;闭包常用于嵌套函数。 特性 保存性保护性 保存性 保存性是指闭包函数所访问的那些变量不会立即被清除&#xff0c;这是由于 IE6、7 所使用的内存回收机制导致的…
阅读更多...
单例模式（饱汉式和饿汉式）

单例模式（饱汉式和饿汉式）

饱汉式 在真正需要使用的时候才进行构建&#xff0c;而不是在一开始就创建。如果要保证线程安全&#xff0c;需要使用一个mutex来保证。 饿汉式 类加载时即创建对象&#xff0c;线程安全优点&#xff1a;执行效率高缺点&#xff1a;类加载时就初始化&#xff0c;浪费内存资源…
阅读更多...
【数据结构】——双链表（增删查改）

【数据结构】——双链表（增删查改）

目录 前言&#xff1a; 一&#xff1a;双链表的定义 ​编辑 二&#xff1a;双向链表的实现 2.1&#xff1a;链表的构造 2.2&#xff1a;创建头节点 2.3&#xff1a;创建节点 2.4&#xff1a;链表的尾插 2.5&#xff1a;链表的打印 2.6&#xff1a;链表的尾删 2.7&a…
阅读更多...
不同content-type对应的前端请求参数处理格式

不同content-type对应的前端请求参数处理格式

前端请求参数的处理格式会根据不同的Content-Type&#xff08;内容类型&#xff09;而有所不同。以下是几种常见的Content-Type及其对应的请求参数处理格式&#xff1a; Content-Type: application/json&#xff1a; 请求参数需要以JSON格式发送&#xff0c;通常在请求体&…
阅读更多...
[计算机网络]网络层概述

[计算机网络]网络层概述

呼,写了这么久终于重新开始啦! 自己落下了太多东西了.....是时候应该重新拾掇起来了. 关于后面的代码项目,我的想法是vilas.js仍然使用js来进行编写,但是后续其他的项目会开始尝试使用ts来进行书写了. 就算是前端也需要点规范吧..... 0.写在前面 这篇文章要和大家道个歉,首…
阅读更多...
2023年中职“网络安全“—Linux系统渗透提权③

2023年中职“网络安全“—Linux系统渗透提权③

2023年中职"网络安全"—Linux系统渗透提权③ Linux系统渗透提权任务环境说明&#xff1a;1. 使用渗透机对服务器信息收集&#xff0c;并将服务器中SSH服务端口号作为flag提交&#xff1b;2. 使用渗透机对服务器信息收集&#xff0c;并将服务器中主机名称作为flag提交…
阅读更多...
访问限制符说明面向对象的封装性

访问限制符说明面向对象的封装性

1 问题 Java中4种“访问控制符”分别为private、default、protected、public&#xff0c;它们说明了面向对象的封装性&#xff0c;所以我们要利用它们尽可能的让访问权限降到最低&#xff0c;从而提高安全性。 private表示私有&#xff0c;只有自己类能访问&#xff0c;属性可以…
阅读更多...
​软考-高级-系统架构设计师教程（清华第2版）【第13章 层次式架构设计理论与实践（P466~495）-思维导图】​

​软考-高级-系统架构设计师教程（清华第2版）【第13章 层次式架构设计理论与实践（P466~495）-思维导图】​

软考-高级-系统架构设计师教程&#xff08;清华第2版&#xff09;【第13章 层次式架构设计理论与实践&#xff08;P466~495&#xff09;-思维导图】 课本里章节里所有蓝色字体的思维导图
阅读更多...
C#匿名方法介绍Action、Func、柯里化Currying

C#匿名方法介绍Action、Func、柯里化Currying

在C#中&#xff0c;匿名方法是一种没有名称的方法&#xff0c;可以被用作委托的参数或者赋值给委托类型的变量。匿名方法主要有两种形式&#xff1a;匿名方法和lambda表达式。 一、匿名方法 匿名方法是C# 2.0引入的特性。匿名方法用delegate关键字定义&#xff0c;它可以有参…
阅读更多...
Figma 插件学习（一）

Figma 插件学习（一）

一.插件介绍 插件在文件中运行&#xff0c;执行一个或多个用户操作&#xff0c;并允许用户自定义其体验或创建更高效的工作流程。 插件通过专用插件API与Figma的编辑器交互。还可以利用外部Web API。 1.插件API 插件API支持读写功能&#xff0c;允许查看、创建和修改文件的…
阅读更多...
最新文章

Copyright @ 2022~2023