正文
redis分布式锁超时处理办法,redis分布式锁超时造成的并发
小程序:扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序
【扫一扫了解最新限行尾号】
复制小程序
Redisson–红锁(Redlock)–使用/原理
就是,一个节点崩溃后,先不立即重启它,而是等待一段时间再重启,这段时间应该大于锁的有效时间(lock validity time)。 这样的话,这个节点在重启前所参与的锁都会过期,它在重启后就不会对现有的锁造成影响。
然而,单Redis实例的故障可能导致系统问题。Redisson通过RedLock算法,利用多个节点的锁获取来增强系统的健壮性。在RedissonRedLock中,通过并行加锁并检测多数节点响应成功,即使在master宕机时,也能确保锁的正确释放。
使用redis客户端redisson,redisson很好的解决了redis在分布式环境下的一些棘手问题,它的宗旨就是让使用者减少对Redis的关注,将更多精力用在处理业务逻辑上。redisson对分布式锁做了很好封装,只需调用API即可。
如果是直接操作redisTemplate,需要注意finally中释放锁,避免程序问题导致锁无法释放。使用redisson.unlock的时候注意加个逻辑判断(redLock.isLocked() &&redLock.isHeldByCurrentThread())防止某些极端并发情况下出现错误EleagleMonitorStateException:attempt to lock,not locked by current thread。
因此,Redisson是可以解决过期时间到了但是业务还没执行完的问题。Redlock核心思想是这样的:部署多个redis master节点,确保它们不会同时宕机。而且这些主节点之间是完全独立的,它们之间没有数据同步。同时,我们需要确保使用相同的方法来获取和释放锁。具体获取锁和释放锁的步骤大家下去自行研究。
如何用redis实现分布式锁
首先,通过实例化RedissonClient并调用RLock接口,我们能借助lock()方法来实现加锁和释放。在底层,lock()方法巧妙地调用tryAcquire(),并异步执行tryAcquireAsync。真正实现原子性加锁的过程,则是由tryLockInnerAsync通过lua脚本来完成的。
利用SETNX非常简单地实现分布式锁。例如:某客户端要获得一个名字foo的锁,客户端使用下面的命令进行获取:SETNX lock.foo current Unix time + lock timeout + 1 如返回1,则该客户端获得锁,把lock.foo的键值设置为时间值表示该键已被锁定,该客户端最后可以通过DEL lock.foo来释放该锁。
如果想要实现可重入的分布式锁的话,需要在设置value的时候加上线程信息和加锁次数的信息。但是这是简单的思路,如果加上过期时间等问题之后,可重入锁就可能比较复杂了。
使用Redis实现分布式锁最简单的方案是使用命令SETNX。SETNX(SET if Not eXist)的使用方式为:SETNX key value,只在键key不存在的情况下,将键key的值设置为value,若键key存在,则SETNX不做任何动作。SETNX在设置成功时返回,设置失败时返回0。
可以使用 while 循环重复执行 setnx 命令,并设置一个超时时间退出循环。可以尽量把锁自动过期的时间设的冗余一些。但也不能彻底解决。可以在删除锁的时候先get值,判断值是否是当前线程存的随机值,只有相同才执行删锁的操作;当然也要使用 lua 脚本执行来保证原子性。
原理很简单,set 一个 锁-key,如果成功则说明加锁成功,反之则失败。
大厂面试题详解:如何用Redis实现分布式锁?
直接使用 set(key,value,NX,EX,timeout) 指令,同时设置锁和超时时间。 以上两种方法,使用哪种方式都可以。 释放锁的脚本两种方式都一样,直接调用 Redis 的 del 指令即可。 到目前为止,我们的锁既起到了互斥效果,又不会因为某些持有锁的系统出现问题,导致死锁了。
可以在删除锁的时候先get值,判断值是否是当前线程存的随机值,只有相同才执行删锁的操作;当然也要使用 lua 脚本执行来保证原子性。
如果想要实现可重入的分布式锁的话,需要在设置value的时候加上线程信息和加锁次数的信息。但是这是简单的思路,如果加上过期时间等问题之后,可重入锁就可能比较复杂了。
用SETNX实现分布式锁 利用SETNX非常简单地实现分布式锁。
关于redis分布式锁超时处理办法和redis分布式锁超时造成的并发的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。