Redis实现分布式锁

本文涉及的产品
云数据库 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);
        }
    }
相关实践学习
基于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
相关文章
|
15天前
|
NoSQL Java 关系型数据库
【Redis系列笔记】分布式锁
分布式锁:满足分布式系统或集群模式下多进程可见并且互斥的锁。 分布式锁的核心思想就是让大家都使用同一把锁,只要大家使用的是同一把锁,那么我们就能锁住线程,不让线程进行,让程序串行执行,这就是分布式锁的核心思路
112 2
|
9天前
|
监控 NoSQL 算法
探秘Redis分布式锁:实战与注意事项
本文介绍了Redis分区容错中的分布式锁概念,包括利用Watch实现乐观锁和使用setnx防止库存超卖。乐观锁通过Watch命令监控键值变化,在事务中执行修改,若键值被改变则事务失败。Java代码示例展示了具体实现。setnx命令用于库存操作,确保无超卖,通过设置锁并检查库存来更新。文章还讨论了分布式锁存在的问题,如客户端阻塞、时钟漂移和单点故障,并提出了RedLock算法来提高可靠性。Redisson作为生产环境的分布式锁实现,提供了可重入锁、读写锁等高级功能。最后,文章对比了Redis、Zookeeper和etcd的分布式锁特性。
111 16
探秘Redis分布式锁:实战与注意事项
|
11天前
|
NoSQL Java 大数据
介绍redis分布式锁
分布式锁是解决多进程在分布式环境中争夺资源的问题,与本地锁相似但适用于不同进程。以Redis为例,通过`setIfAbsent`实现占锁,加锁同时设置过期时间避免死锁。然而,获取锁与设置过期时间非原子性可能导致并发问题,解决方案是使用`setIfAbsent`的超时参数。此外,释放锁前需验证归属,防止误删他人锁,可借助Lua脚本确保原子性。实际应用中还有锁续期、重试机制等复杂问题,现成解决方案如RedisLockRegistry和Redisson。
|
12天前
|
缓存 NoSQL Java
【亮剑】分布式锁是保证多服务实例同步的关键机制,常用于互斥访问共享资源、控制访问顺序和系统保护,如何使用注解来实现 Redis 分布式锁的功能?
【4月更文挑战第30天】分布式锁是保证多服务实例同步的关键机制,常用于互斥访问共享资源、控制访问顺序和系统保护。基于 Redis 的分布式锁利用 SETNX 或 SET 命令实现,并考虑自动过期、可重入及原子性以确保可靠性。在 Java Spring Boot 中,可通过 `@EnableCaching`、`@Cacheable` 和 `@CacheEvict` 注解轻松实现 Redis 分布式锁功能。
|
13天前
|
NoSQL Redis 微服务
分布式锁_redis实现
分布式锁_redis实现
|
16天前
|
NoSQL Java Redis
Redis入门到通关之分布式锁Rediision
Redis入门到通关之分布式锁Rediision
15 0
|
16天前
|
NoSQL 关系型数据库 MySQL
Redis入门到通关之Redis实现分布式锁
Redis入门到通关之Redis实现分布式锁
18 1
|
机器学习/深度学习 缓存 NoSQL
|
缓存 NoSQL Java
为什么分布式一定要有redis?
1、为什么使用redis 分析:博主觉得在项目中使用redis,主要是从两个角度去考虑:性能和并发。当然,redis还具备可以做分布式锁等其他功能,但是如果只是为了分布式锁这些其他功能,完全还有其他中间件(如zookpeer等)代替,并不是非要使用redis。
1334 0
|
1天前
|
存储 监控 NoSQL
Redis哨兵&分片集群
Redis哨兵&分片集群
6 0