全站资源开放下载,感谢广大网友的支持
链接失效请移步职涯宝平台的学习路线|资源下载分类
支持用户留言评论_客服实时在线_问题解决更快
非盈利平台

非盈利平台

只为分享一些优质内容

Java帮帮-微信公众号

Java帮帮-微信公众号

将分享做到极致

微信小程序

微信小程序

更方便的阅读

百度小程序

百度小程序

搜索便捷阅读

支付宝小程序

支付宝小程序

支付也能阅读

程序员生活志-公众号

程序员生活志-公众号

程序员生活学习圈,互联网八卦黑料

支付宝赞助-Java帮帮社区
微信赞助-Java帮帮社区

Spring Boot Redis实现分布式锁,真香!!

10
发表时间:2020-07-16 09:08

免费学习视频欢迎关注云图智联:https://e.yuntuzhilian.com/

之前看很多人手写分布式锁,其实 Spring Boot 现在已经做的足够好了,开箱即用,支持主流的 Redis、Zookeeper 中间件,另外还支持 JDBC。

本篇栈长以 Redis 为例(这也是用得最多的方案),教大家如何利用 Spring Boot 集成 Redis 实现缓存,如何简单、快速实现 Redis 分布式锁。

分布式锁介绍

Spring Boot 实现 Redis 分布式锁在 spring-integration 这个项目中,参考:

https://docs.spring.io/spring-integration/docs/5.3.1.RELEASE/reference/html/redis.html#redis-lock-registry

首先来看下 LockRegistry 锁注册接口的所有实现类结构图:

DefaultLockRegistry 就是纯单机的可重入锁,PassThruLockRegistry 是一个空实现类,也都没有什么利用价值。

Spring Integration 4.0 引入了基于 Redis 的分布式锁:RedisLockRegistry,并且从 5.0 开始实现了 ExpirableLockRegistry 接口,用来移除超时且没有用的锁。

分布式锁实战

添加依赖

上面提到 Spring Boot 实现 Redis 分布式锁在 spring-integration 这个项目中,所以需要这三个依赖:

  • spring-boot-starter-data-redis

  • spring-boot-starter-integration

  • spring-integration-redis

  1. <dependency>  

  2. <groupId>org.springframework.boot</groupId>  

  3. <artifactId>spring-boot-starter-data-redis</artifactId>  

  4. </dependency>  

  5. <dependency>  

  6. <groupId>org.springframework.boot</groupId>  

  7. <artifactId>spring-boot-starter-integration</artifactId>

  8. </dependency>  

  9. <dependency>  

  10. <groupId>org.springframework.integration</groupId>  

  11. <artifactId>spring-integration-redis</artifactId>  

  12. </dependency>

Spring Boot 基础知识就不介绍了,不熟悉的可以关注公众号Java技术栈,在后台回复:boot,可以阅读我写的历史实战教程。

配置分布式锁

  1. @Bean(destroyMethod = "destroy")  

  2. public RedisLockRegistry redisLockRegistry(RedisConnectionFactory redisConnectionFactory) {  

  3.     return new RedisLockRegistry(redisConnectionFactory, "lock");  

  4. }

使用示例

  1. @GetMapping("/redis/lock")  

  2. public String lock(@RequestParam("key") String key) {  

  3.     for (int i = 0; i < 10; i++) {  

  4.         new Thread(() -> {  

  5.             redisLockService.lock(key);  

  6.             try {  

  7.                 Thread.sleep(3000L);  

  8.             } catch (InterruptedException e) {  

  9.                 e.printStackTrace();  

  10.             }  

  11.             System.out.println(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));  

  12.             redisLockService.unlock(key);  

  13.         }  

  14.         ).start();  

  15.     }  

  16.     return "OK";  

  17. }

RedisLockService 是我封装了的一个 Redis 锁服务,代码有点多,这里就不贴了,完整的代码示例在 Github 上,大家可以 Star 一下:

https://github.com/javastacks/spring-boot-best-practice

测试:

http://localhost:8080/redis/lock?key=yeah

输出:

  1. 2020-06-23 11:15:34  

  2. 2020-06-23 11:15:37  

  3. 2020-06-23 11:15:40  

  4. 2020-06-23 11:15:43  

  5. 2020-06-23 11:15:46  

  6. 2020-06-23 11:15:49  

  7. 2020-06-23 11:15:52  

  8. 2020-06-23 11:15:55

  9. 2020-06-23 11:15:58  

  10. 2020-06-23 11:16:01

可以看到每个线程需要等上一个线程休眠 3 秒后才能获取到锁。

源码分析

集成完了,会使用了,还得研究下 RedisLockRegistry 的源码,不然遇到什么坑还得再踩一篇。

RedisLockRegistry 有两个类构造器:



  • connectionFactory:Redis 连接工厂

  • registryKey:锁前缀

  • expireAfter:失效时间(非必须项,默认60秒)

所以,我们要注册 expireAfter 这个选项,默认 60 秒是否满足业务需要,如果超过默认的 60 少时间,否则将导致锁失效。

还有两个和 RedisLockRegistry   相关且很重要的成员变量:


  1. private final String clientId = UUID.randomUUID().toString();  

  2. private final Map<String, RedisLock> locks = new ConcurrentHashMap<>();

  • clientId:

首先用来标识当前 RedisLockRegistry 实例ID,并且在设置、移除锁的时候都会要用到,用来判断是不是当前的锁注册实例。

  • locks:

用来在内存中缓存当前锁注册实例所有锁对象。

获取锁对象

如下面获取锁对象源码所示:

每个 key 在内存中(ConcurrentHashMap)都对应一个锁对象,锁对象有生成过就直接返回,没有就生成再返回,有了这个锁对象才能进行上锁和解锁操作。

这个锁对象(RedisLock)其实也是实现了 Java 中的 java.util.concurrent.locks.Lock 锁接口:

锁对象(RedisLock)也有两个很重要的成员变量:

  1. private final ReentrantLock localLock = new ReentrantLock();  

  2. private volatile long lockedAt;

  • localLock:

localLock 是一个本地内存可重入锁,每次去 Redis 上锁前,都要用本地 localLock 上锁先,这样能做到尽可能的少往 Redis 上锁,也能从一方面提升锁的性能。

  • lockedAt:

lockedAt 上锁时间,移除过时锁会用到。

阻塞上锁

RedisLock#lock():

每隔 100 毫秒尝试获取一次锁,直到获取锁成功为止,不接受打断异常,遇到其他异常会释放本地锁返回异常并结束。

主要看下设置 Redis 锁的 Lua 脚本:

根据 key 查询其对应的值:clientId,如果和当前 clientId 一致则延长失效时间,如果 clientId 不存在就直接上锁,以上都不成立返回 false。

这样做的好处是,可以将整个 Redis Lua 脚本作为一个原子执行,而不用考虑并发及事务影响。

好了,核心的源码分析完了,其实也很简单,大家还不懂的或者有兴趣的可以再研究下。

本文完整示例源代码和上篇 Spring Boot 快速集成 Redis 的示例代码一起上传到了 Github,欢迎大家 Star 关注学习。

https://github.com/javastacks/spring-boot-best-practice

所以,你还在手写分布式锁吗?赶快 Get 起来吧!

免费学习视频欢迎关注云图智联:https://e.yuntuzhilian.com/


Java帮帮学习群生态

Java帮帮学习群生态

总有一款能帮到你

Java学习群

Java学习群

与大牛一起交流

大数据学习群

大数据学习群

在数据中成长

九点编程学习群

九点编程学习群

深夜九点学编程

python学习群

python学习群

人工智能,爬虫

测试学习群

测试学习群

感受测试的魅力

Java帮帮生态承诺

Java帮帮生态承诺

一直坚守,不负重望

初心
勤俭
诚信
正义
分享
友链交换:加帮主QQ2524138991 留言即可 24小时内答复  
满吉教育资讯
会员登录
获取验证码
登录
登录
我的资料
留言
回到顶部