redis分布锁在实际中使用实例 redis实现分布锁

什么是redis分布式锁1、之前自己在用redis来实现分布式锁的时候都是基于单个Redis实例 , 也就是说Redis本身是有单点故障的,Redis的官方文档介绍了一种自认为合理的算法,Redlock来实现分布式Redis下的分布式锁 。
2、在使用Redis实现分布式锁的时候,主要就会使用到这三个命令 。
3、简而言之 , 分布式锁就是用来控制同一时刻,只有一个线程可以访问被保护的资源 。可以使用 SETNX key value 命令实现互斥的特性 。解释下:如果 key 不存在,则设置 value 给这个 key,否则啥都不做 。
Springboot使用redis的setnx和getset实现并发锁、分布式锁使用redis实现并发锁 , 主要是靠两个redis的命令:setnx和getset 。那我们的设计思路就是:上面的代码使用了一个RedisService的类,里面主要是简单封装了一下redis的操作,你可以替换为自己的service 。
这里同时启动5个线程并发往redis中存储 lock 这个key(key可以自定义 , 但需要一致),同时设置10秒的过期时间 。
C3发送SETNX lock.foo 想要获得锁,由于C0还持有锁 , 所以Redis返回给C3一个0 C3发送GET lock.foo 以检查锁是否超时了,如果没超时,则等待或重试 。
高并发场景Redis分布式锁实现方式1、使用分布式锁要满足的几个条件:系统是一个分布式系统(关键是分布式,单机的可以使用ReentrantLock或者synchronized代码块来实现)共享资源(各个系统访问同一个资源,资源的载体可能是传统关系型数据库或者NoSQL) 。
2、使用redis实现并发锁,主要是靠两个redis的命令:setnx和getset 。那我们的设计思路就是:上面的代码使用了一个RedisService的类,里面主要是简单封装了一下redis的操作,你可以替换为自己的service 。
3、在同一时刻,只能有一个线程去读写一个【共享资源】,也就是高并发的场景下 , 通常为了保证数据的正确 , 需要控制同一时刻只允许一个线程访问 。此时就需要使用分布式锁了 。
4、获取锁最终都会调用这个方法,通过 lua 脚本与 redis 进行交互 , 来实现分布式锁 。首先分析,传给 lua 脚本的参数:lua 脚本的流程:为了实现无限制持有锁,那么就需要定时刷新锁的过期时间 。
5、简单加锁命令:命令是:setnx 内部的实现机制就是判断这个key位置是不是有数据,没有数据就设置成value返回,有数据就返回一个特殊数值 。
Redis的Setnx命令实现分布式锁1、可以在再次获取锁时,如果锁被占用就get值,判断值是否是当前线程存的随机值,如果是则再次执行 set 命令重新上锁;当然为了保证原子性这些操作都要用 lua 脚本来执行 。
2、释放锁时,删除相应的记录 。基于Redis的分布式锁使用Redis的SETNX命令(Set if Not eXists)来实现分布式锁 。SETNX命令在键不存在时设置值 , 并返回1;如果键已存在 , 不执行任何操作,并返回0 。
3、SETNX不同:SETNX(SETifNoteXists),该命令在key不存在时设置key的值,如果key存在,不做任何操作 。Redishash数据结构可以存储多个键值对,所以我们可以使用Redishash实现分布式锁 。
【redis分布锁在实际中使用实例 redis实现分布锁】4、使用redis实现并发锁,主要是靠两个redis的命令:setnx和getset 。那我们的设计思路就是:上面的代码使用了一个RedisService的类,里面主要是简单封装了一下redis的操作,你可以替换为自己的service 。
5、命令是: setnx expire 添加分布式锁的同时,添加一个锁锁过期的时间 。这样,当加锁线程退出之后,至少等一段时间之后,锁是有机会释放掉的 。这里有一个小问题是 , 这两个命令是分开执行的,不是原子操作 。

    推荐阅读