服务器之家:专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

服务器之家 - 数据库 - Redis - Redis怎么实现分布式锁

Redis怎么实现分布式锁

2022-01-06 20:51今日头条DNF搬砖摸金达人 Redis

阿粉最近迷上了 Redis,为什么呢?感觉 Redis 确实功能很强大呀,一个基于内存的系统 Key-Value 存储的数据库,竟然有这么多的功能,而阿粉也要实实在在地把 Redis 来弄一下,毕竟面试的时候,Redis 可以说是一个非常不错的加分项。

阿粉最近迷上了 Redis,为什么呢?感觉 Redis 确实功能很强大呀,一个基于内存的系统 Key-Value 存储的数据库,竟然有这么多的功能,而阿粉也要实实在在地把 Redis 来弄一下,毕竟面试的时候,Redis 可以说是一个非常不错的加分项。

Redis怎么实现分布式锁

分布式锁

为什么需要分布式锁?

目前很多的大型项目全部都是基于分布式的,而分布式场景中的数据一致性问题一直是一个不可忽视的问题,大家知道关于分布式的 CAP 理论么?

CAP 理论就是说任何一个分布式系统都无法同时满足一致性(Consistency)、可用性(Availability)和分区容错性(Partition tolerance),最多只能同时满足两项。

而我们的系统最终满足的永远都是最终一致性,而这种最终一致性,有些时候有人会喜欢问关于分布式事务,而有些人则偏重在分布式锁上。

分布式锁的种类

  1. 数据库实现分布式锁
  2. 缓存实现分布式锁
  3. Zookeeper实现分布式锁

但是阿粉选择的就是使用缓存来实现分布式锁,也就是我们在项目中最经常使用的 Redis ,谈到 Redis,那真是可以用在太多地方了,比如说:

  • 会话缓存
  • 消息队列
  • 分布式锁
  • 发布,订阅消息
  • 商品列表,评论列表

我们今天就来实现用 Redis 来实现分布式锁,并且要学会怎么使用。

准备工作

1.准备使用 Jedis 的 jar 包,在项目中导入 jar 包。

 

  1. <!--jedis--> 
  1.  
  2. <dependency> 
  3.     <groupId>redis.clients</groupId> 
  4.     <artifactId>jedis</artifactId> 
  5.     <version>2.9.0</version> 
  6. </dependency> 

直接来写个工具类吧!

  1. public class RedisPoolUtil { 
  2.  
  3.     private static final String LOCK_SUCCESS = "OK"
  4.     private static final String SET_IF_NOT_EXIST = "NX"
  5.     private static final String SET_WITH_EXPIRE_TIME = "PX"
  6.  
  7.     private RedisPoolUtil(){} 
  8.     /** 
  9.      *  
  10.      * @param jedis  
  11.      * @param lockKey 加锁 
  12.      * @param requestId 请求的标志位 
  13.      * @param expireTime 超时时间 
  14.      * @return 
  15.      */ 
  16.     public static boolean tryGetDistributedLock(Jedis jedis,String lockKey, String requestId, int expireTime) { 
  17.  
  18.         String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime); 
  19.  
  20.         if (LOCK_SUCCESS.equals(result)) { 
  21.             return true
  22.         }else
  23.             try{ 
  24.                 Thread.sleep(10);//休眠100毫秒 
  25.             }catch(Exception e){ 
  26.                 e.printStackTrace(); 
  27.             } 
  28.         } 
  29.         return false
  30.     } 

jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime); 这个加锁的姿势才是我们最需要了解的,不然你用的时候都不知道怎么使用。

key:加锁的键,实际上就是相当于一个唯一的标志位,不同的业务,你可以使用不同的标志位进行加锁。

requestId:这个东西实际上就是用来标识他是哪一个请求进行的加锁,因为在分布式锁中,我们要知道一件事,就是加锁的和解锁的,必须是同一个客户端才可以。

而且还有一种比较经典的就是 B 把 A 的锁给释放了,导致释放混乱,如果你不加相同的请求,A 线程处理业务,执行了加锁,锁的过期时间是5s, B线程尝试获取锁,如果 A 处理业务时间超过5s,这时候 A 就要开始释放锁,而B在这时候没有检测到这个锁,从而进行了加锁,这时候加锁的时候,A还没处理完对应业务,当他处理完了之后,再释放锁的话,要是就是直接把 B 刚加的锁释放了,要么就是压根都没办法释放锁。

SET_IF_NOT_EXIST:看字面意思,如果 key 不存在,我们进行Set操作,如果存在,啥都不干,也就不在进行加锁。

SET_WITH_EXPIRE_TIME:是否过期

expireTime:这是给 key 设置一个过期的时间,万一你这业务一直被锁着了,然后之后的业务想加锁,你直接给一直持有这个这个锁,不进行过期之后的释放,那岂不是要凉了。

上面的方法中 tryGetDistributedLock 这个方法也就是我们通常使用的加锁的方法。

解锁 

  1. public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) { 
  2.  
  3.         String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end"
  4.         Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId)); 
  5.  
  6.         if ("OK".equals(result)) { 
  7.             return true
  8.         } 
  9.         return false
  10.  
  11.     } 

大家看到这个 script的时候,会感觉有点奇怪,实际上他就是一个 Lua 的脚本,而 Lua 脚本的意思也比较简单。

  1. 先获取锁对应的value值,检查是否与requestId相等
  2. 如果相等则删除锁(解锁)
  3. 执行eval()方法

其实这时候就有些人说,直接 del 删除不行么?你试试你如果这么写的话,你们的领导会不会把你的腿给你打断。

这种不先判断锁的拥有者而直接解锁的方式,会导致任何客户端都可以随时进行解锁,也就是说,这锁就算不是我加的,我都能开,这怎么能行呢?

Redis怎么实现分布式锁

在这里给大家放一段使用的代码,比较简单,但是可以直接用到你们的项目当中。

  1. try{ 
  2. Boolean result = RedisPoolUtil.tryGetDistributedLock(jedis, "xxxxx", uuid, 5000); 
  3.  
  4. if(result) { 
  5.         xxxx代码片段 
  6. }else
  7.  
  8.  
  9. }catch(){ 
  10.  
  11. }finally{ 
  12. RedisPoolUtil.releaseDistributedLock(jedis,"xxxxx", uuid); 

分布式锁的要求

  1. 满足互斥性。也就是说不管在什么时候,只有一个客户端能够持有锁,不能是多个客户端。
  2. 不能出现死锁。就是说,如果要实现分布式锁,不能说当一个锁没有释放的时候,其他的客户端不能进行加锁,要保证不影响其他的客户端加锁。
  3. 加锁和解锁必须是同一个客户端

分布式的CAP理论

我们先把这个实现方式实现了,然后我们再来说说大家最不愿意看的理论知识,毕竟这理论知识是你面试的时候经常会被问到的。

分布式CAP理论:

加州大学伯克利分校的 Eric Brewer 教授在 ACM PODC 会议上提出 CAP 猜想。2年后,麻省理工学院的 Seth Gilbert 和 Nancy Lynch 从理论上证明了 CAP。之后,CAP 理论正式成为分布式计算领域的公认定理。

也就是说,在二十年前的时候,CAP 理论只是个猜想。结果两年之后被证实了,于是,大家在考虑分布式的时候,就有根据来想了,不再是空想了。

什么是分布式的 CAP 理论 ?

一个分布式系统最多只能同时满足一致性(Consistency)、可用性(Availability)和分区容错性(Partition tolerance)这三项中的两项。

Redis怎么实现分布式锁

这个和(Atomicity)不太一样,因为之前看有些人说,在 CAP 理论中的 A 和数据库事务中的 A 是一样的,单词都不一样,那能一样么?

Availability :分布式中的 A 表示的是可用性,也就是说服务一直可用,而且是正常响应时间。

而你在搭建分布式系统的时候,要保证每个节点都是稳定的,不然你的可用性就没有得到相对应的保证,也谈不上是什么分布式了。只能称之为一个伪分布式。

Consistency: 一致性

也就是说你的更新操作成功并返回客户端完成后,所有节点在同一时间的数据完全一致,这个如果你在使用 Redis 做数据展示的时候,很多面试官都会问你,那你们是怎么保证数据库和缓存的一致性的呢?

毕竟你只是读取的话,没什么问题,但是设计到更新的时候,不管是先写数据库,再删除缓存;还是先删除缓存,再写库,都有可能出现数据不一致的情况。

所以如果你对这个很感兴趣,可以研究一下,比如说:

  1. 延时双删策略
  2. 懒加载 懒加载可采取双删+TTL失效来实现
  3. 主动加载

如果你能在面试的时候把这些都给面试官说清楚,至少感觉你应该能达到你自己的工资要求。

Partition tolerance:分区容错性

分布式系统在遇到某节点或网络分区故障的时候,仍然能够对外提供满足一致性和可用性的服务。

其实在 CAP 理论当中,我们是没有办法同时满足一致性、可用性和分区容错性这三个特性,所以有所取舍就可以了。

关于使用 Redis 分布式锁,大家学会了么?

原文链接:https://www.toutiao.com/a7049883684295426573/

延伸 · 阅读

精彩推荐
  • Redis超强、超详细Redis数据库入门教程

    超强、超详细Redis数据库入门教程

    这篇文章主要介绍了超强、超详细Redis入门教程,本文详细介绍了Redis数据库各个方面的知识,需要的朋友可以参考下 ...

    junjie2522019-10-21
  • Redis浅谈Redis缓存有哪些淘汰策略

    浅谈Redis缓存有哪些淘汰策略

    redis用做缓存是一种非常常见的手段,然而由于内存大小的限制,会导致redis在内存空间满了以后需要处理继续存入的数据,所以就需要淘汰策略,本文就详...

    XiaoLin_Java4192021-09-17
  • RedisRedis的8大数据类型,写得非常好!

    Redis的8大数据类型,写得非常好!

    NoSQL 开发中或多或少都会用到,也是面试必问知识点。最近这几天的面试每一场都问到了。但是感觉回答的并不好,还有很多需要梳理的知识点。...

    民工哥技术之路5182020-12-15
  • Redis关于SpringBoot 使用 Redis 分布式锁解决并发问题

    关于SpringBoot 使用 Redis 分布式锁解决并发问题

    针对上面问题,一般的解决方案是使用分布式锁来解决,本文通过场景分析给大家介绍关于SpringBoot 使用 Redis 分布式锁解决并发问题,感兴趣的朋友一起看...

    qhh02058072021-11-24
  • Redisredis客户端实现高可用读写分离的方式详解

    redis客户端实现高可用读写分离的方式详解

    基于sentienl 获取和动态感知 master、slaves节点信息的变化,我们的读写分离客户端就能具备高可用+动态扩容感知能力了,接下来通过本文给大家分享redis客户...

    mushishi8572021-08-15
  • Redis详解Redis开启远程登录连接

    详解Redis开启远程登录连接

    本篇文章主要介绍了Redis开启远程登录连接,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧 ...

    502studio6342019-11-06
  • Redis浅谈Redis主从复制以及主从复制原理

    浅谈Redis主从复制以及主从复制原理

    在现有企业中80%公司大部分使用的是redis单机服务,在实际的场景当中单一节点的redis容易面临风险。本文将介绍Redis主从复制以及主从复制原理。...

    八重樱6562021-08-08
  • Redis详解Redis单线程的正确理解

    详解Redis单线程的正确理解

    这篇文章主要介绍了详解Redis单线程的正确理解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面...

    小白菜_111052021-08-02