从零开始,探究Redis分布式锁底层原理!

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: 从零开始,探究Redis分布式锁底层原理!


🍊 从零开始,探究Redis分布式锁底层原理!

Redis是一个开源的NoSQL数据库,提供了分布式锁的实现,分布式锁是一种在分布式环境下保持数据一致性的方法。在多线程或多进程的环境下,多个线程或进程对共享资源进行读写操作,为保证数据的正确性和一致性,需要使用分布式锁来控制并发访问。在分布式环境下,Redis分布式锁是非常实用的一种方案,可以保证应用程序的高可用性、高可靠性和高并发性。

在Redis中,使用setnx命令来实现分布式锁,多线程或多进程可以通过setnx命令来尝试获取锁,只有获取到锁的进程才有执行权利。在实际应用中,对于Redis分布式锁的应用,除了普通的使用场景外,还有许多异常情况需要考虑和处理。

🎉 1. Redis服务挂掉了,抛出异常了,锁不会被释放掉,新的请求无法进来,出现死锁问题

这种情况最容易出现的情况是Redis服务突然挂掉,导致锁无法被释放,后续新的请求也无法获取锁,从而导致死锁问题。为了避免这种情况的出现,需要在加锁的代码中,使用try finally语句块来确保锁最终能够被释放。即使Redis服务挂掉了,也可以保证锁能够最终被释放。

String lockKey = "lockKey";
String threadId = Thread.currentThread().getId();
boolean lockSuccess = jedis.setnx(lockKey, threadId) == 1;
try {
    if (lockSuccess) {
        // 获取到锁,执行任务
        doTask();
    }
} finally {
    // 最终释放锁
    if (lockSuccess) {
        jedis.del(lockKey);
    }
}

在加锁的代码中使用try finally语句块,即使Redis服务挂掉了,也可以保证锁最终能够被释放。

🎉 2. 服务器果宕机了,导致锁不能被释放的现象

在分布式环境下,常常会遇到服务器宕机的情况,如果当前持有锁的服务器宕机了,那么其他服务器就无法获取锁,就会出现锁不能被释放的现象。为了避免这种情况的出现,我们可以在加锁的时候设置锁的超时时间,当锁超时时,就会自动释放锁。

String lockKey = "lockKey";
String threadId = Thread.currentThread().getId();
boolean lockSuccess = jedis.setnx(lockKey, threadId) == 1;
try {
    if (lockSuccess) {
        // 获取到锁,执行任务
        doTask();
    }
} finally {
    // 释放锁
    if (lockSuccess) {
        jedis.del(lockKey);
    }
    // 设置锁的超时时间
    if (jedis.ttl(lockKey) == -1) {
        jedis.expire(lockKey, 30);
    }
}

在加锁的代码中,使用jedis.ttl(lockKey)来获取锁的过期时间,如果锁已经过期了(返回-1),那么就使用jedis.expire(lockKey, 30)来设置锁的超时时间为30秒。这样可以自动释放锁,避免出现锁不能被释放的现象。

🎉 3. 锁的过期时间比业务执行时间短,会存在多个线程拥有同一把锁的现象

如果锁的过期时间比业务执行时间短,会存在多个线程拥有同一把锁的现象,例如有一个线程执行需要15秒,过期时间只有10秒,当执行到10秒时第二个线程进来拿到这把锁,会出现多个线程拿到同一把锁执行。为了避免这种情况的出现,可以使用续期超时时间的方法来解决。

String lockKey = "lockKey";
String threadId = Thread.currentThread().getId();
boolean lockSuccess = jedis.setnx(lockKey, threadId) == 1;
try {
    if (lockSuccess) {
        // 获取到锁,执行任务
        doTask();
    }
} finally {
    // 释放锁
    if (lockSuccess) {
        jedis.del(lockKey);
    }
    // 续期超时时间
    if (jedis.ttl(lockKey) > 10) {
        jedis.expire(lockKey, 10);
    }
}

在加锁的代码中,使用jedis.ttl(lockKey)来获取锁的剩余时间,如果锁的剩余时间大于10秒,就使用jedis.expire(lockKey, 10)来设置锁的超时时间为10秒。这样可以续期超时时间,避免出现多个线程拥有同一把锁的现象。

🎉 4. 锁的过期时间比业务执行时间短,锁永久失效

如果锁的过期时间比业务执行时间短,且程序执行的时间超过了设置的过期时间,就会导致其他线程删除了自己的锁,出现锁永久失效的情况。为了避免这种情况的出现,需要给每个线程都设置一个唯一标识,避免出现程序执行的时间超过设置的过期时间,导致其他线程删除了自己的锁,只允许自己删除自己线程的锁。

String lockKey = "lockKey";
String threadId = Thread.currentThread().getId();
String uniqueId = UUID.randomUUID().toString();
boolean lockSuccess = jedis.setnx(lockKey, uniqueId) == 1;
try {
    if (lockSuccess) {
        // 获取到锁,执行任务
        doTask();
    }
} finally {
    // 释放锁
    if (lockSuccess && uniqueId.equals(jedis.get(lockKey))) {
        jedis.del(lockKey);
    }
}

在加锁的代码中,使用UUID.randomUUID().toString()来生成每个线程的唯一标识,这样就保证了每个线程都有一个唯一的标识。在释放锁的时候,使用jedis.get(lockKey)来获取当前锁的值,如果当前线程的唯一标识和锁的值相同,就释放锁。这样就可以避免出现锁永久失效的情况。

总之,在使用Redis分布式锁的时候,需要注意一些异常情况,并且给每个线程都设置一个唯一标识,保证锁的正确使用。使用try finally语句块来确保锁最终能够被释放,在加锁的时候设置锁的超时时间,避免出现锁不能被释放的现象。在锁的过期时间比业务执行时间短的情况下,可以使用续期超时时间的方法来解决。最后,使用Redis分布式锁可以保证数据的正确性和一致性,提高了应用程序的可用性、可靠性和并发性。


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
3月前
|
NoSQL Java Redis
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
Redis分布式锁在高并发场景下是重要的技术手段,但其实现过程中常遇到五大深坑:**原子性问题**、**连接耗尽问题**、**锁过期问题**、**锁失效问题**以及**锁分段问题**。这些问题不仅影响系统的稳定性和性能,还可能导致数据不一致。尼恩在实际项目中总结了这些坑,并提供了详细的解决方案,包括使用Lua脚本保证原子性、设置合理的锁过期时间和使用看门狗机制、以及通过锁分段提升性能。这些经验和技巧对面试和实际开发都有很大帮助,值得深入学习和实践。
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
|
2月前
|
存储 Dubbo Java
分布式 RPC 底层原理详解,看这篇就够了!
本文详解分布式RPC的底层原理与系统设计,大厂面试高频,建议收藏。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
分布式 RPC 底层原理详解,看这篇就够了!
|
30天前
|
存储 NoSQL Java
使用lock4j-redis-template-spring-boot-starter实现redis分布式锁
通过使用 `lock4j-redis-template-spring-boot-starter`,我们可以轻松实现 Redis 分布式锁,从而解决分布式系统中多个实例并发访问共享资源的问题。合理配置和使用分布式锁,可以有效提高系统的稳定性和数据的一致性。希望本文对你在实际项目中使用 Redis 分布式锁有所帮助。
101 5
|
30天前
|
机器学习/深度学习 存储 运维
分布式机器学习系统:设计原理、优化策略与实践经验
本文详细探讨了分布式机器学习系统的发展现状与挑战,重点分析了数据并行、模型并行等核心训练范式,以及参数服务器、优化器等关键组件的设计与实现。文章还深入讨论了混合精度训练、梯度累积、ZeRO优化器等高级特性,旨在提供一套全面的技术解决方案,以应对超大规模模型训练中的计算、存储及通信挑战。
65 4
|
2月前
|
NoSQL Java 数据处理
基于Redis海量数据场景分布式ID架构实践
【11月更文挑战第30天】在现代分布式系统中,生成全局唯一的ID是一个常见且重要的需求。在微服务架构中,各个服务可能需要生成唯一标识符,如用户ID、订单ID等。传统的自增ID已经无法满足在集群环境下保持唯一性的要求,而分布式ID解决方案能够确保即使在多个实例间也能生成全局唯一的标识符。本文将深入探讨如何利用Redis实现分布式ID生成,并通过Java语言展示多个示例,同时分析每个实践方案的优缺点。
70 8
|
2月前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
61 16
|
2月前
|
缓存 NoSQL PHP
Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出
本文深入探讨了Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出。文章还介绍了Redis在页面缓存、数据缓存和会话缓存等应用场景中的使用,并强调了缓存数据一致性、过期时间设置、容量控制和安全问题的重要性。
45 5
|
14天前
|
存储 缓存 NoSQL
解决Redis缓存数据类型丢失问题
解决Redis缓存数据类型丢失问题
157 85
|
3月前
|
消息中间件 缓存 NoSQL
Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。
【10月更文挑战第4天】Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。随着数据增长,有时需要将 Redis 数据导出以进行分析、备份或迁移。本文详细介绍几种导出方法:1)使用 Redis 命令与重定向;2)利用 Redis 的 RDB 和 AOF 持久化功能;3)借助第三方工具如 `redis-dump`。每种方法均附有示例代码,帮助你轻松完成数据导出任务。无论数据量大小,总有一款适合你。
85 6
|
11天前
|
缓存 监控 NoSQL
Redis经典问题:缓存穿透
本文详细探讨了分布式系统和缓存应用中的经典问题——缓存穿透。缓存穿透是指用户请求的数据在缓存和数据库中都不存在,导致大量请求直接落到数据库上,可能引发数据库崩溃或性能下降。文章介绍了几种有效的解决方案,包括接口层增加校验、缓存空值、使用布隆过滤器、优化数据库查询以及加强监控报警机制。通过这些方法,可以有效缓解缓存穿透对系统的影响,提升系统的稳定性和性能。