Redis实现分布式锁

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: 本章主要讲解了如何通过Redis实现分布式锁

一、应用场景

分布式锁是一种控制分布式系统中并发访问共享资源的方法。在分布式系统中,由于多个进程或线程同时访问共享资源,可能会导致数据的不一致性或者并发问题。分布式锁的作用就是确保在同一时间内只有一个进程或线程可以访问共享资源。

二、代码实现与讲解

通过Redis分布式锁的方案来实现秒杀,这里主要使用了Redis的两个命令SETNX(key,value)和GETSET(key,value),setnx的含义是只有key不存在的情况下,将键key的值设置为value,如果key已经存在,则setnx命令不做任何操作。Getset的含义是先获取key的值,然后再重新设置key的值。

假设此时有线程A和线程B同时访问临界区代码,假设线程A首先执行了SETNX命令,并返回结果1,继续向下执行。而此时线程B再次执行SETNX命令时,返回的结果为0,则线程B不能继续向下执行。只有当线程A执行DELETE命令将设置的锁状态删除时,线程B才会成功执行SETNX命令设置加锁状态后继续向下执行。

但是会产生死锁问题,假设线程A在业务处理过程中发生异常导致线程A没有执行锁的释放,那么接下来的所有线程都会被阻塞,所以这里通过加时间戳的形式来解决死锁问题。Key设置为商品Id,value值为当前时间+过期时间。首先获取currentValue,通过与当前时间进行比较判断是否过期,如果过期了,通过getSet获取oldValue并重新设置value值,如果获取的oldValue与currentValue相同,那么成功获取锁,如果不同,说明锁已经被其它线程获取了,那么返回失败。

/*** 加锁* setnx + getset* @param key* @param value 当前时间+超时时间 150* @return*/publicstaticbooleanlock(Stringkey, Stringvalue) {
if (stringRedisTemplate.opsForValue().setIfAbsent(key, value)) {
returntrue;
        }
StringcurrentValue=stringRedisTemplate.opsForValue().get(key);
/*如果锁过期在业务处理过程中可能由于某种未知异常,导致死锁产生,下面是让死锁解锁的代码*/if (StringUtils.hasLength(currentValue) &&Long.parseLong(currentValue) <System.currentTimeMillis()) {
// 获取上一个锁的时间StringoldValue=stringRedisTemplate.opsForValue().getAndSet(key, value);
if (StringUtils.hasLength(oldValue) &&oldValue.equals(currentValue)) {
returntrue;
            }
        }
returnfalse;
    }
/*** 解锁** @param key* @param value*/publicstaticvoidunlock(Stringkey, Stringvalue) {
try {
StringcurrentValue=stringRedisTemplate.opsForValue().get(key);
if (StringUtils.hasLength(currentValue) &&currentValue.equals(value)) {
stringRedisTemplate.opsForValue().getOperations().delete(key);
            }
        } catch (Exceptione) {
log.error("【redis分布式锁】解锁异常, {}", e);
        }
    }
相关文章
|
2月前
|
存储 负载均衡 NoSQL
【赵渝强老师】Redis Cluster分布式集群
Redis Cluster是Redis的分布式存储解决方案,通过哈希槽(slot)实现数据分片,支持水平扩展,具备高可用性和负载均衡能力,适用于大规模数据场景。
198 2
|
2月前
|
存储 缓存 NoSQL
【📕分布式锁通关指南 12】源码剖析redisson如何利用Redis数据结构实现Semaphore和CountDownLatch
本文解析 Redisson 如何通过 Redis 实现分布式信号量(RSemaphore)与倒数闩(RCountDownLatch),利用 Lua 脚本与原子操作保障分布式环境下的同步控制,帮助开发者更好地理解其原理与应用。
105 0
|
3月前
|
存储 缓存 NoSQL
Redis核心数据结构与分布式锁实现详解
Redis 是高性能键值数据库,支持多种数据结构,如字符串、列表、集合、哈希、有序集合等,广泛用于缓存、消息队列和实时数据处理。本文详解其核心数据结构及分布式锁实现,帮助开发者提升系统性能与并发控制能力。
|
23天前
|
NoSQL Java 调度
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
分布式锁是分布式系统中用于同步多节点访问共享资源的机制,防止并发操作带来的冲突。本文介绍了基于Spring Boot和Redis实现分布式锁的技术方案,涵盖锁的获取与释放、Redis配置、服务调度及多实例运行等内容,通过Docker Compose搭建环境,验证了锁的有效性与互斥特性。
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
|
17天前
|
缓存 NoSQL 关系型数据库
Redis缓存和分布式锁
Redis 是一种高性能的键值存储系统,广泛用于缓存、消息队列和内存数据库。其典型应用包括缓解关系型数据库压力,通过缓存热点数据提高查询效率,支持高并发访问。此外,Redis 还可用于实现分布式锁,解决分布式系统中的资源竞争问题。文章还探讨了缓存的更新策略、缓存穿透与雪崩的解决方案,以及 Redlock 算法等关键技术。
|
3月前
|
NoSQL Redis
Lua脚本协助Redis分布式锁实现命令的原子性
利用Lua脚本确保Redis操作的原子性是分布式锁安全性的关键所在,可以大幅减少由于网络分区、客户端故障等导致的锁无法正确释放的情况,从而在分布式系统中保证数据操作的安全性和一致性。在将这些概念应用于生产环境前,建议深入理解Redis事务与Lua脚本的工作原理以及分布式锁的可能问题和解决方案。
132 8
|
4月前
|
缓存 NoSQL 算法
高并发秒杀系统实战(Redis+Lua分布式锁防超卖与库存扣减优化)
秒杀系统面临瞬时高并发、资源竞争和数据一致性挑战。传统方案如数据库锁或应用层锁存在性能瓶颈或分布式问题,而基于Redis的分布式锁与Lua脚本原子操作成为高效解决方案。通过Redis的`SETNX`实现分布式锁,结合Lua脚本完成库存扣减,确保操作原子性并大幅提升性能(QPS从120提升至8,200)。此外,分段库存策略、多级限流及服务降级机制进一步优化系统稳定性。最佳实践包括分层防控、黄金扣减法则与容灾设计,强调根据业务特性灵活组合技术手段以应对高并发场景。
1054 7
|
缓存 NoSQL Java
为什么分布式一定要有redis?
1、为什么使用redis 分析:博主觉得在项目中使用redis,主要是从两个角度去考虑:性能和并发。当然,redis还具备可以做分布式锁等其他功能,但是如果只是为了分布式锁这些其他功能,完全还有其他中间件(如zookpeer等)代替,并不是非要使用redis。
1448 0
|
机器学习/深度学习 缓存 NoSQL
|
5月前
|
缓存 NoSQL 关系型数据库
美团面试:MySQL有1000w数据,redis只存20w的数据,如何做 缓存 设计?
美团面试:MySQL有1000w数据,redis只存20w的数据,如何做 缓存 设计?
美团面试:MySQL有1000w数据,redis只存20w的数据,如何做 缓存 设计?

热门文章

最新文章