一种redis命令搞定基于redis的分布式锁

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

基于redis的分布式锁项目肯定经常用到,主要是为了避免重复处理,或者由于并发带来的脏数据或者错误的处理。

使用锁就必须注意一下几点:
1、互斥,同一时间不能有多个client能获取到锁
2、不能发生死锁,不能因为有锁的client因为崩溃或者解锁命令请求失败导致无法释放锁
3、自己只能解自己上的锁,不能删除别人的锁

下面介绍一下代码为什么这么写
1、为什么不用setnx和expire两个命令来实现加锁,因为如果再执行setnx后加过期时间崩溃了,就无法解锁。
2、为什么需要使用随机字符串来做lockvalue,主要是为了防止不同client的锁都是一样的,防止client误删
3、为什么还需要Lua脚本代码来实现删除锁,纵然我们在删除之前比对了锁,但是get和del之间不是原子性的,所以也防止删除别人的锁,用lua脚本代码实现原子操作

下面是一个不侵占业务的通过redis分布式锁来执行的方法代码,当然这里只是参考,一种解决问题的方案,至于业务实现怎么写,大家可以随便发挥。

/**
 * 分布式锁
 *
 * @param r             继承于Redis
 * @param lockKey       分布式锁的key
 * @param voidMethod    获得到锁后需要执行的方法
 * @param expireSeconds 锁定时间 单位/s(需要评估方法执行时间)
 * @param retrySeconds  重试间隔 单位/s
 * @throws ServiceException
 */
public <R extends Redis> void lock(R r, String lockKey, VoidMethodInterface voidMethod, int expireSeconds, int retrySeconds) throws ServiceException {
    long begin = 0L;
    long retryMills = retrySeconds * 1000;
    //获取随机字符串,避免lockValue相同
    String lockValue = UUID.randomUUID().toString();
    while (begin <= retryMills) {
        String response = r.set(lockKey, lockValue, "nx", "ex", expireSeconds);
        if (response != null) {
            logger.debug("lock method exec begin");
            try {
                voidMethod.exec();
            } catch (Exception e) {
                logger.error("method exec failed ,msg:%s", e.getMessage());
            } finally {
                String value = r.get(lockKey);
                //当缓存里还有该key对应的值时,才去删除锁,避免执行时间过长导致锁被释放
                if (!StringUtils.isEmpty(value) && lockValue.equals(value)) {
                    // 避免若在此时,这把锁突然不是这个客户端的,则会误解锁
                    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
                    r.eval(script, Collections.singletonList(lockKey), Collections.singletonList(lockValue));
                }
            }
            logger.debug("lock method exec success");
            return;
        } else {
            long waitMills = random.nextInt(WAIT_INTERVAL_MIN_MILLS, WAIT_INTERVAL_MAX_MILLS);
            try {
                Thread.sleep(waitMills);
            } catch (InterruptedException ex) {
                throw new UnexpectedStateException(ex);
            }
            begin = begin + waitMills;
            logger.debug("等待获取锁,当前等待时间:%sms", begin);
        }
    }
    logger.error("等待获取锁超时");
}
相关实践学习
基于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个大坑,又大又深, 如何才能 避开 ?
|
19天前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
53 16
|
2月前
|
NoSQL Redis 数据库
计数器 分布式锁 redis实现
【10月更文挑战第5天】
51 1
|
22天前
|
存储 NoSQL Java
Redis命令:列表模糊删除详解
通过本文的介绍,我们详细探讨了如何在Redis中实现列表的模糊删除。虽然Redis没有直接提供模糊删除命令,但可以通过组合使用 `LRANGE`和 `LREM`命令,并在客户端代码中进行模糊匹配,来实现这一功能。希望本文能帮助你在实际应用中更有效地操作Redis列表。
34 0
|
2月前
|
NoSQL 算法 关系型数据库
Redis分布式锁
【10月更文挑战第1天】分布式锁用于在多进程环境中保护共享资源,防止并发冲突。通常借助外部系统如Redis或Zookeeper实现。通过`SETNX`命令加锁,并设置过期时间防止死锁。为避免误删他人锁,加锁时附带唯一标识,解锁前验证。面对锁提前过期的问题,可使用守护线程自动续期。在Redis集群中,需考虑主从同步延迟导致的锁丢失问题,Redlock算法可提高锁的可靠性。
80 4
|
2月前
|
缓存 NoSQL 测试技术
Redis如何解决频繁的命令往返造成的性能瓶颈!
Redis如何解决频繁的命令往返造成的性能瓶颈!
|
2月前
|
NoSQL Redis 数据安全/隐私保护
Redis 命令
10月更文挑战第15天
28 0
|
2月前
|
缓存 NoSQL 算法
面试题:Redis如何实现分布式锁!
面试题:Redis如何实现分布式锁!
|
4月前
|
NoSQL Redis
基于Redis的高可用分布式锁——RedLock
这篇文章介绍了基于Redis的高可用分布式锁RedLock的概念、工作流程、获取和释放锁的方法,以及RedLock相比单机锁在高可用性上的优势,同时指出了其在某些特殊场景下的不足,并提到了ZooKeeper作为另一种实现分布式锁的方案。
116 2
基于Redis的高可用分布式锁——RedLock
|
4月前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
这篇文章是关于如何在SpringBoot应用中整合Redis并处理分布式场景下的缓存问题,包括缓存穿透、缓存雪崩和缓存击穿。文章详细讨论了在分布式情况下如何添加分布式锁来解决缓存击穿问题,提供了加锁和解锁的实现过程,并展示了使用JMeter进行压力测试来验证锁机制有效性的方法。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】