Redis 实现分布式锁

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 分布式锁,主要考察使用者对原子性的理解,原子性可以保证程序从异常中恢复后,redis中的数据是正确的,程序依然正常运行。分布式锁是实现线程同步手段之一。

分布式锁介绍

分布式锁,主要考察使用者对原子性的理解,原子性可以保证程序从异常中恢复后,redis中的数据是正确的,程序依然正常运行。分布式锁是实现线程同步手段之一

分布式锁原理

分布式锁其实就是在进程里占一个“坑”,当别的进程来占坑时,发现那里已经有一根“大萝卜”了,就只好放弃或者稍后再试。占“坑”就是把所有的逻辑变成单进程来执行。

Redis 实现分布式锁

实现分布式锁,三个版本进行演变,最终达到完美的分布式锁功能。

基础版本

require_once("../RedisClient.php");
$client = RedisClient::getInstance();
/**
 * 基础版,完成锁的请求与释放,但是有严重的问题.
 * 如果请求锁完成后,宕机了,就成死锁了.再也不能请求到锁了
 * @return null
 */
function base () {
    global $client;
    //请求锁
    $lock = $client->set('lock','true');
    if(!$lock){
        return null;
    }
    // do something critical ...
    //释放锁
    $client->del('lock');
}


存在的问题

如果在释放锁前,服务器宕机了,那么我们永远都无法重新申请锁,就成死锁了。我们可以利用redis 的 set 命令给锁设置一个过期时间,服务器宕机了,锁过一段时间也会重新释放。

过期时间随机数版

很多同学会有疑问为什么需要添加随机数,不妨静下心仔细想想,如果我们给的时间过期了,锁不存在了,刚好另一个进程站用了这个“坑”,那我们是不是删错了呢?

require_once("../RedisClient.php");
$client = RedisClient::getInstance();
/**
 * 设置锁和添加过期时间放在一个命令中,要成功一起成功
 * 添加随机数,防止过期时间后,删除了其他进程的锁
 * @return null
 */
function perfect () {
    global $client;
    $unique = uniqid();
    //请求锁并添加过期时间
    $lock = $client->set('lock',$unique,'ex',60,'nx');
    if(!$lock){
        return null;
    }
    // do something critical ...
    //释放锁
    if ($client->get('lock')==$unique){
        $client->del('lock');
    };
}


存在的问题

由于 Redis 没有提供带条件删除的命令,需我们手动去匹配随机数,在进行了锁匹配中,有可能锁刚匹配完,本进程锁的过期时间到了,系统自动删除。而另一个进程已经申请了锁,我们命令删除另一个进程的锁,造成脏数据。这事我们需要用到 Lua 脚本进行原子性执行。

Lua 脚本版

use Predis\Command\ScriptCommand;
require_once("../RedisClient.php");
$client = RedisClient::getInstance();
class releaseLockScript extends ScriptCommand {
    public function getScript()
    {
        return <<<LUA
if redis.call("get",ARGV[1]) == ARGV[2] then
    return redis.call("del",ARGV[1])
else
    return 0
end
LUA;
    }
}
// 定义锁命令
$client->getProfile()->defineCommand('releaseLock','releaseLockScript');
function lua () {
    global $client;
    $unique = uniqid();
    //请求锁并添加过期时间
    $lock = $client->set('lock',$unique,'ex',60,'nx');
    if(!$lock){
        return null;
    }
    // do something critical ...
    //释放锁
    $client->releaseLock('lock',$unique)
}


存在的问题

当然这个也不是一个完美的方案,只是相对安全一点,如果真的超时了。其他逻辑还没有执行完,其他线程也会趁虚而入。

分布式锁的缺点

  • 分布式锁一旦加了之后,对同一个商品的下单请求,会导致所有客户端都必须对同一个商品的库存锁key进行加锁。这样会导致对同一个商品的下单请求,就必须串行化,一个接一个的处理。
  • 不适合执行较长逻辑的代码的请求。

拓展

分布式锁是一种思想,除了用 Redis 实现分布式锁外,也可以试着用:Mysql、Memcache、Zookeeper 等去实现


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
2月前
|
NoSQL Java Redis
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
Redis分布式锁在高并发场景下是重要的技术手段,但其实现过程中常遇到五大深坑:**原子性问题**、**连接耗尽问题**、**锁过期问题**、**锁失效问题**以及**锁分段问题**。这些问题不仅影响系统的稳定性和性能,还可能导致数据不一致。尼恩在实际项目中总结了这些坑,并提供了详细的解决方案,包括使用Lua脚本保证原子性、设置合理的锁过期时间和使用看门狗机制、以及通过锁分段提升性能。这些经验和技巧对面试和实际开发都有很大帮助,值得深入学习和实践。
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
|
14天前
|
存储 NoSQL Java
使用lock4j-redis-template-spring-boot-starter实现redis分布式锁
通过使用 `lock4j-redis-template-spring-boot-starter`,我们可以轻松实现 Redis 分布式锁,从而解决分布式系统中多个实例并发访问共享资源的问题。合理配置和使用分布式锁,可以有效提高系统的稳定性和数据的一致性。希望本文对你在实际项目中使用 Redis 分布式锁有所帮助。
41 5
|
17天前
|
NoSQL Java 数据处理
基于Redis海量数据场景分布式ID架构实践
【11月更文挑战第30天】在现代分布式系统中,生成全局唯一的ID是一个常见且重要的需求。在微服务架构中,各个服务可能需要生成唯一标识符,如用户ID、订单ID等。传统的自增ID已经无法满足在集群环境下保持唯一性的要求,而分布式ID解决方案能够确保即使在多个实例间也能生成全局唯一的标识符。本文将深入探讨如何利用Redis实现分布式ID生成,并通过Java语言展示多个示例,同时分析每个实践方案的优缺点。
34 8
|
1月前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
55 16
|
27天前
|
缓存 NoSQL PHP
Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出
本文深入探讨了Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出。文章还介绍了Redis在页面缓存、数据缓存和会话缓存等应用场景中的使用,并强调了缓存数据一致性、过期时间设置、容量控制和安全问题的重要性。
37 5
|
2月前
|
NoSQL Redis 数据库
计数器 分布式锁 redis实现
【10月更文挑战第5天】
51 1
|
2月前
|
NoSQL 算法 关系型数据库
Redis分布式锁
【10月更文挑战第1天】分布式锁用于在多进程环境中保护共享资源,防止并发冲突。通常借助外部系统如Redis或Zookeeper实现。通过`SETNX`命令加锁,并设置过期时间防止死锁。为避免误删他人锁,加锁时附带唯一标识,解锁前验证。面对锁提前过期的问题,可使用守护线程自动续期。在Redis集群中,需考虑主从同步延迟导致的锁丢失问题,Redlock算法可提高锁的可靠性。
83 4
|
2月前
|
缓存 NoSQL 算法
面试题:Redis如何实现分布式锁!
面试题:Redis如何实现分布式锁!
|
4月前
|
NoSQL Redis
基于Redis的高可用分布式锁——RedLock
这篇文章介绍了基于Redis的高可用分布式锁RedLock的概念、工作流程、获取和释放锁的方法,以及RedLock相比单机锁在高可用性上的优势,同时指出了其在某些特殊场景下的不足,并提到了ZooKeeper作为另一种实现分布式锁的方案。
129 2
基于Redis的高可用分布式锁——RedLock
|
4月前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
这篇文章是关于如何在SpringBoot应用中整合Redis并处理分布式场景下的缓存问题,包括缓存穿透、缓存雪崩和缓存击穿。文章详细讨论了在分布式情况下如何添加分布式锁来解决缓存击穿问题,提供了加锁和解锁的实现过程,并展示了使用JMeter进行压力测试来验证锁机制有效性的方法。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】