Redisson源码(一)RedissonLock加锁与解锁过程原理分析

本文涉及的产品
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
注册配置 MSE Nacos/ZooKeeper,118元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: RedissonLock加锁与解锁过程原理分析

在当今分布式微服务架构流行的情况下,显然在传统单体项目中使用的JDK自带的锁已经不能解决资源竞争的问题了,
进而出现的解决方案有1)利用数据库 2)redis 3)zookeeper,经过验证的是利用redis做分布式锁无论在可用性、可靠性上比较有优势。
而使用Redisson来做分布式锁很多人在熟悉不过了,它提供的Lock就是基于redis来做的。

Tip以下是本人经过多年的工作经验集成的JavaWeb脚手架,封装了各种通用的starter可开箱即用,同时列举了互联网各种高性能场景的使用示例。

// Git代码
https://gitee.com/yeeevip/yeee-memo
https://github.com/yeeevip/yeee-memo
AI 代码解读

1 Redisson锁的基本使用

JDK提供的Lock、CountDownLatch、Semaphore等解决资源竞争/协调的并发辅助工具API在Redisson框架同样也提供了,区别就是它是支持分布式的,
并且使用的方式也和JDK中大同小异。

1.1 执行流程

20240223-01.png

1.2 Lock的使用示例

我们来看一下最基本的使用示例代码:

public class LockExample {
   
   

    public void testLock() {
   
   
        RLock lock = redissonClient.getLock("testLockKey");
        // 1.最常用的使用方法
        lock.lock();
        try {
   
   
            // 2.执行业务
            doSomeThing();
        } finally {
   
   
            // 3.解锁
            lock.unlock();
        }
    }
}
AI 代码解读

Tip我工作中Redisson各种锁的具一些体使用示例Demo,有兴趣的可以参考一下

// Git代码
https://gitee.com/yeeevip/yeee-memo/tree/master/solution-problem/distribute-lock/distribute-lock-redisson/src/main/java/vip/yeee/memo/demo/distribute/lock/redisson/example
AI 代码解读

2 加锁过程分析

2.1 代码执行分析

  • 1.通过redissonClient调用getLock()方法获取到锁对象

getLock获取到的是非公平锁,非公平锁不严格要求先到先得,后面申请加锁的线程有可能会比之前等待的提前拿到锁。

  • 2.然后通过锁对象调用lock()方法进行加锁

  • 3.使用当前线程ID执行tryAcquire()尝试获取锁,若获取到锁直接返回

这里tryAcquire()方法会调用redis服务器执行Lua脚本命令获取锁;

还有一点就是加锁成功后会有watchdog机制给锁续期防止业务执行时锁释放了。

  • 4.若没有获取到锁时,会给该线程向channel订阅锁通知,同时继续自旋尝试获取锁

向channel订阅后,锁释放后可以收到通知立即去尝试获取锁;

自旋获取并不是说直接无限调用tryAcquire,而是根据上次tryAcquire返回的ttl阻塞等待后才再次tryAcquire

2.1.1 Java核心代码

public class RedissonLock {
   
   

    private void lock(long leaseTime, TimeUnit unit, boolean interruptibly) {
   
   
        // 获取当前线程ID
        long threadId = Thread.currentThread().getId();

        // 尝试加锁,返回值为需要等待的时间,若为空则表示当前线程加锁成功
        Long ttl = tryAcquire(-1, leaseTime, unit, threadId);
        if (ttl == null) {
   
   
            return;
        }

        // 尝试加锁若没有成功

        // 1.该线程向channel订阅锁通知
        RFuture<RedissonLockEntry> future = subscribe(threadId);
        ...

        try {
   
   
            while (true) {
   
   
                ttl = tryAcquire(-1, leaseTime, unit, threadId);

                // ttl为null,说明获取成功,返回
                if (ttl == null) {
   
   
                    break;
                }
                // 若锁有效期ttl大于0,则阻塞ttl后继续获取,防止空自旋
                if (ttl >= 0) {
   
   
                    try {
   
   
                        future.getNow().getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);
                    } catch (InterruptedException e) {
   
   
                        if (interruptibly) {
   
   
                            throw e;
                        }
                        future.getNow().getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);
                    }
                } else {
   
   
                    ...
                }
            }
        } finally {
   
   
            unsubscribe(future, threadId);
        }
    }
}
AI 代码解读

2.1.2 Lua脚本代码

-- KEYS[1] = 锁对象唯一键
-- ARGV[1] = 锁过期时间
-- ARGV[2] = 加锁线程ID

-- 还没有线程加锁
if (redis.call('exists', KEYS[1]) == 0) then
-- 当前线程占有锁
redis.call('hincrby', KEYS[1], ARGV[2], 1);
-- 并设置过期时间
redis.call('pexpire', KEYS[1], ARGV[1]);
return nil;
end;

-- 若该线程已经持有锁
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then
-- 重入次数+1
redis.call('hincrby', KEYS[1], ARGV[2], 1);
-- 设置过期时间
redis.call('pexpire', KEYS[1], ARGV[1]);
return nil;
end;

-- 锁被其他线程占有,则返回剩余有效期
return redis.call('pttl', KEYS[1]);
AI 代码解读

3 解锁过程分析

3.1 代码执行分析

解锁逻辑相对比较简单

  • 1.使用unlock()方法进行解锁

  • 2.根据当前线程再调用unlockInnerAsync()方法执行lua命令解锁

3.1.1 Java核心代码

public class RedissonLock {
   
   
    public void unlock() {
   
   
        ...
        unlockAsync(Thread.currentThread().getId());
        ...
    }
    public RFuture<Void> unlockAsync(long threadId) {
   
   
        ...
        // 这个方法去执行Lua命令
        unlockInnerAsync(threadId);
        ...
    }
}
AI 代码解读

3.1.2 Lua脚本代码

-- KEYS[1] = 锁对象唯一键
-- KEYS[2] = 该锁发布订阅channel
-- ARGV[1] = UNLOCK_MESSAGE
-- ARGV[2] = 锁过期时间
-- ARGV[3] = 加锁线程ID

-- 该线程未持有锁直接返回
if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then
return nil;
end;

-- 该线程重入次数-1
local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1);

-- 如果重入次数还大于0
if (counter > 0) then
-- 重置该线程锁过期时间
redis.call('pexpire', KEYS[1], ARGV[2]);
return 0;
-- 重入次数等于0了
else
-- 释放锁
redis.call('del', KEYS[1]);
-- 向channel发布锁释放消息
redis.call('publish', KEYS[2], ARGV[1]);
return 1;
end;
return nil;
AI 代码解读

最后

Redission锁的原理我大致已经介绍完了,有问题的可以私聊我或者评论区留意~ 之后我会介绍Redission的延迟队列原理,感兴趣的话持续关注哦。

Tip以下是本人经过多年的工作经验集成的JavaWeb脚手架,封装了各种通用的starter可开箱即用,同时列举了互联网各种高性能场景的使用示例。

// Git代码
https://gitee.com/yeeevip/yeee-memo
https://github.com/yeeevip/yeee-memo
AI 代码解读
相关实践学习
基于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
目录
打赏
0
23
22
65
8
分享
相关文章
|
2月前
|
【📕分布式锁通关指南 07】源码剖析redisson利用看门狗机制异步维持客户端锁
Redisson 的看门狗机制是解决分布式锁续期问题的核心功能。当通过 `lock()` 方法加锁且未指定租约时间时,默认启用 30 秒的看门狗超时时间。其原理是在获取锁后创建一个定时任务,每隔 1/3 超时时间(默认 10 秒)通过 Lua 脚本检查锁状态并延长过期时间。续期操作异步执行,确保业务线程不被阻塞,同时仅当前持有锁的线程可成功续期。锁释放时自动清理看门狗任务,避免资源浪费。学习源码后需注意:避免使用带超时参数的加锁方法、控制业务执行时间、及时释放锁以优化性能。相比手动循环续期,Redisson 的定时任务方式更高效且安全。
109 24
【📕分布式锁通关指南 07】源码剖析redisson利用看门狗机制异步维持客户端锁
|
2月前
【📕分布式锁通关指南 08】源码剖析redisson可重入锁之释放及阻塞与非阻塞获取
本文深入剖析了Redisson中可重入锁的释放锁Lua脚本实现及其获取锁的两种方式(阻塞与非阻塞)。释放锁流程包括前置检查、重入计数处理、锁删除及消息发布等步骤。非阻塞获取锁(tryLock)通过有限时间等待返回布尔值,适合需快速反馈的场景;阻塞获取锁(lock)则无限等待直至成功,适用于必须获取锁的场景。两者在等待策略、返回值和中断处理上存在显著差异。本文为理解分布式锁实现提供了详实参考。
93 11
【📕分布式锁通关指南 08】源码剖析redisson可重入锁之释放及阻塞与非阻塞获取
|
2月前
|
【📕分布式锁通关指南 06】源码剖析redisson可重入锁之加锁
本文详细解析了Redisson可重入锁的加锁流程。首先从`RLock.lock()`方法入手,通过获取当前线程ID并调用`tryAcquire`尝试加锁。若加锁失败,则订阅锁释放通知并循环重试。核心逻辑由Lua脚本实现:检查锁是否存在,若不存在则创建并设置重入次数为1;若存在且为当前线程持有,则重入次数+1。否则返回锁的剩余过期时间。此过程展示了Redisson高效、可靠的分布式锁机制。
75 0
【📕分布式锁通关指南 06】源码剖析redisson可重入锁之加锁
什么是 CAS(自旋锁)? 它的优缺点? 如何使用CAS实现一把锁?
该博客文章解释了什么是CAS(自旋锁),包括CAS的基本概念、实现原理、优缺点,以及如何使用CAS实现锁的逻辑,并提供了使用CAS实现锁的Java完整代码示例和测试结果。
什么是 CAS(自旋锁)? 它的优缺点? 如何使用CAS实现一把锁?
线程安全--深入探究线程等待机制和死锁问题
线程安全--深入探究线程等待机制和死锁问题
339 1
【JavaEE】多线程进阶问题-锁策略and死锁,CAS操作,Synchronized原理
JavaEE & 多线程进阶问题 & 锁策略and 死锁,CAS操作,Synchronized原理
117 0
Redisson 分布式锁源码 08:MultiLock 加锁与锁释放
基于 Redis 的 Redisson 分布式联锁 RedissonMultiLock 对象可以将多个 RLock 对象关联为一个联锁,每个 RLock 对象实例可以来自于不同的 Redisson 实例。 当然,这是官网的介绍,具体是什么?一起看看联锁 MultiLock 使用以及源码吧!
570 0
Redisson 分布式锁源码 04:可重入锁释放
前面已经了解到了,可重入锁加锁,看门狗以及锁的互斥阻塞。 当锁加锁成功之后,锁是如何释放的?
281 0
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等