redisson分布式锁源码分析,springboot redisson分布式锁

2022-07-31 09:23:58 分类：java 阅读()

　　redisson分布式锁源码分析,springboot redisson分布式锁

　　一、前言二。为什么使用Redisson1。我们打开官网2。我们可以看到官方让我们用别人3。打开官方推荐4。找到文件3。Springboot集成Redisson1。导入依赖关系2。以官网为例，看看如何配置3。编写配置类4。测试并锁定官网5中的例子。根据官网的简单控制器界面6写的。测试4。lock.lock()源代码分析1。打开RedissonLock实现类2。找到实现方法3。按住Ctrl键进入锁定方法4。进去试着获取锁法5。检查tryLockInnerAsync()方法6。输入计划任务还剩4。scheduleExpirationRenewal()方法5。lock.lock(10，时间单位。秒)源代码分析6。lock.unlock()源代码分析7。

　　00-1010我们正在用Redis实现分布式锁。首先，我们通常使用set resource-name any string NX ex max-lock-time来锁定，并使用Lua脚本来确保原子性以释放锁定。这种手工实现比较麻烦，Redis官网也明确说Java版本是Redisson实现的。边肖也看着官网慢慢摸索清晰，并做了这个记录的特写。从官网到整合Springboot再到源代码解读，以单个节点为例，边肖的理解在评论里，希望能帮到大家！

　　

目录

 

　　

一、前言

redis中文官网

 

　　

二、为什么使用Redisson

 

　　

1. 我们打开官网

 

　　

2. 我们可以看到官方让我们去使用其他

Redisson地址

 

　　5.雷迪森结构

　　

3. 打开官方推荐

 

　　

4. 找到文档

依赖groupIdorg.springframework.boot/groupId artifactId spring-boot-starter-data-redis/artifactId/dependency依赖groupIdredis.clients/groupId artifactId jedis/artifactId/dependency！- redis分布式锁定依赖项groupIdorg.redisson/groupId项目redis ion/项目ID版本3 . 12 . 0/版本/依赖项

 

　　

三、Springboot整合Redisson

 

　　

1. 导入依赖

导入org . redis son . redis son；导入org . redis on . API . redis on client；导入org . redisson . config . config；导入org . spring framework . context . annotation . bean；导入org . spring framework . context . annotation . configuration；/* * * @ author wangzhenjun * @ date 2022/2/9 9336057 */@ configuration public类myredissonconfig {/* * * redisson的所有使用都是通过redisson client * @ return */@ bean(destroy method= shut down )public r

 

　　edissonClient redisson(){ // 1. 创建配置 Config config = new Config(); // 一定要加redis:// config.useSingleServer().setAddress("redis://192.168.17.130:6379"); // 2. 根据config创建出redissonClient实例 RedissonClient redissonClient = Redisson.create(config); return redissonClient; }}

 

　　

4. 官网测试加锁例子

 

　　

 

　　

5. 根据官网简单Controller接口编写

@ResponseBody@GetMapping("/hello")public String hello(){ // 1.获取一把锁，只要锁名字一样，就是同一把锁 RLock lock = redisson.getLock("my-lock"); // 2. 加锁 lock.lock();// 阻塞试等待 默认加的都是30s // 带参数情况 // lock.lock(10, TimeUnit.SECONDS);// 10s自动解锁，自动解锁时间一定要大于业务的执行时间。 try { System.out.println("加锁成功" + Thread.currentThread().getId()); Thread.sleep(30000); } catch (InterruptedException e) { e.printStackTrace(); } finally { // 3. 解锁 System.out.println("解锁成功：" + Thread.currentThread().getId()); lock.unlock(); } return "hello";}

 

　　

6. 测试

 

　　

 

　　

四、lock.lock()源码分析

 

　　

1. 打开RedissonLock实现类

 

　　

 

　　

2. 找到实现方法

@Overridepublic void lock() { try { // 我们发现不穿过期时间源码默认过期时间为-1 lock(-1, null, false); } catch (InterruptedException e) { throw new IllegalStateException(); }}

 

　　

3. 按住Ctrl进去lock方法

private void lock(long leaseTime, TimeUnit unit, boolean interruptibly) throws InterruptedException {// 获取线程的id，占有锁的时候field的值为UUID:线程号id long threadId = Thread.currentThread().getId(); // 尝试获得锁 Long ttl = tryAcquire(leaseTime, unit, threadId); // lock acquired 获得锁，返回 if (ttl == null) { return; }// 这里说明获取锁失败，就通过线程id订阅这个锁 RFuture<RedissonLockEntry> future = subscribe(threadId); if (interruptibly) { commandExecutor.syncSubscriptionInterrupted(future); } else { commandExecutor.syncSubscription(future); } try { // 这里进行自旋，不断尝试获取锁 while (true) { // 继续尝试获取锁 ttl = tryAcquire(leaseTime, unit, threadId); // lock acquired 获取成功 if (ttl == null) { // 直接返回，挑出自旋 break; } // waiting for message 继续等待获得锁 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 { if (interruptibly) { future.getNow().getLatch().acquire(); } else { future.getNow().getLatch().acquireUninterruptibly(); } } } } finally { // 取消订阅 unsubscribe(future, threadId); }// get(lockAsync(leaseTime, unit));}

 

　　

4. 进去尝试获取锁方法

 

　　

private Long tryAcquire(long leaseTime, TimeUnit unit, long threadId) {// 直接进入异步方法 return get(tryAcquireAsync(leaseTime, unit, threadId));}private <T> RFuture<Long> tryAcquireAsync(long leaseTime, TimeUnit unit, long threadId) { // 这里进行判断如果没有设置参数leaseTime = -1 if (leaseTime != -1) { return tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG); } // 此方法进行获得锁，过期时间为看门狗的默认时间 // private long lockWatchdogTimeout = 30 * 1000;看门狗默认过期时间为30s // 加锁和过期时间要保证原子性，这个方法后面肯定调用执行了Lua脚本，我们下面在看 RFuture<Long> ttlRemainingFuture = tryLockInnerAsync(commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_LONG); // 开启一个定时任务进行不断刷新过期时间 ttlRemainingFuture.onComplete((ttlRemaining, e) -> { if (e != null) { return; } // lock acquired 获得锁 if (ttlRemaining == null) { // 刷新过期时间方法，我们下一步详细说一下 scheduleExpirationRenewal(threadId); }); return ttlRemainingFuture;

 

　　

5. 查看tryLockInnerAsync()方法

<T> RFuture<T> tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) { internalLockLeaseTime = unit.toMillis(leaseTime); return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, command, // 首先判断锁是否存在 "if (redis.call(exists, KEYS[1]) == 0) then " + // 存在则获取锁 "redis.call(hset, KEYS[1], ARGV[2], 1); " + // 然后设置过期时间 "redis.call(pexpire, KEYS[1], ARGV[1]); " + "return nil; " + "end; " + // hexists查看哈希表的指定字段是否存在，存在锁并且是当前线程持有锁 "if (redis.call(hexists, KEYS[1], ARGV[2]) == 1) then " + // hincrby自增一 "redis.call(hincrby, KEYS[1], ARGV[2], 1); " + // 锁的值大于1，说明是可重入锁，重置过期时间 "redis.call(pexpire, KEYS[1], ARGV[1]); " + "return nil; " + "end; " + // 锁已存在，且不是本线程，则返回过期时间ttl "return redis.call(pttl, KEYS[1]);", Collections.<Object>singletonList(getName()), internalLockLeaseTime, getLockName(threadId));}

 

　　

6. 进入4留下的定时任务scheduleExpirationRenewal()方法

一步步往下找源码：scheduleExpirationRenewal --->renewExpiration

 

　　根据下面源码，定时任务刷新时间为：internalLockLeaseTime / 3，是看门狗的1/3，即为10s刷新一次

　　

private void renewExpiration() { ExpirationEntry ee = EXPIRATION_RENEWAL_MAP.get(getEntryName()); if (ee == null) { return; } Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() { @Override public void run(Timeout timeout) throws Exception { ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName()); if (ent == null) { return; } Long threadId = ent.getFirstThreadId(); if (threadId == null) { return; } RFuture<Boolean> future = renewExpirationAsync(threadId); future.onComplete((res, e) -> { if (e != null) { log.error("Cant update lock " + getName() + " expiration", e); return; } if (res) { // reschedule itself renewExpiration(); } }); } }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS); ee.setTimeout(task);}

 

　　

五、lock.lock(10, TimeUnit.SECONDS)源码分析

1. 打开实现类

 

　　

@Overridepublic void lock(long leaseTime, TimeUnit unit) { try { // 这里的过期时间为我们输入的10 lock(leaseTime, unit, false); } catch (InterruptedException e) { throw new IllegalStateException(); }}

2. 方法lock()实现展示，同三.3源码

 

　　3. 直接来到尝试获得锁tryAcquireAsync()方法

　　

private <T> RFuture<Long> tryAcquireAsync(long leaseTime, TimeUnit unit, long threadId) { // 这里进行判断如果没有设置参数leaseTime = -1,此时我们为10 if (leaseTime != -1) { // 来到此方法 return tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG); } // 此处省略后面内容，前面以详细说明。。。。}

4. 打开tryLockInnerAsync()方法

 

　　我们不难发现和没有传过期时间的方法一样，只不过leaseTime的值变了。

　　

<T> RFuture<T> tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) { internalLockLeaseTime = unit.toMillis(leaseTime); return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, command, // 首先判断锁是否存在 "if (redis.call(exists, KEYS[1]) == 0) then " + // 存在则获取锁 "redis.call(hset, KEYS[1], ARGV[2], 1); " + // 然后设置过期时间 "redis.call(pexpire, KEYS[1], ARGV[1]); " + "return nil; " + "end; " + // hexists查看哈希表的指定字段是否存在，存在锁并且是当前线程持有锁 "if (redis.call(hexists, KEYS[1], ARGV[2]) == 1) then " + // hincrby自增一 "redis.call(hincrby, KEYS[1], ARGV[2], 1); " + // 锁的值大于1，说明是可重入锁，重置过期时间 "redis.call(pexpire, KEYS[1], ARGV[1]); " + "return nil; " + "end; " + // 锁已存在，且不是本线程，则返回过期时间ttl "return redis.call(pttl, KEYS[1]);", Collections.<Object>singletonList(getName()), internalLockLeaseTime, getLockName(threadId));}

 

　　

六、lock.unlock()源码分析

1. 打开方法实现

 

　　

@Overridepublic void unlock() { try { // 点击进入释放锁方法 get(unlockAsync(Thread.currentThread().getId())); } catch (RedisException e) { if (e.getCause() instanceof IllegalMonitorStateException) { throw (IllegalMonitorStateException) e.getCause(); } else { throw e; } } // Future<Void> future = unlockAsync();// future.awaitUninterruptibly();// if (future.isSuccess()) {// return;// }// if (future.cause() instanceof IllegalMonitorStateException) {// throw (IllegalMonitorStateException)future.cause();// }// throw commandExecutor.convertException(future);}

2. 打开unlockAsync()方法

 

　　

@Overridepublic RFuture<Void> unlockAsync(long threadId) { RPromise<Void> result = new RedissonPromise<Void>(); // 解锁方法，后面展开说 RFuture<Boolean> future = unlockInnerAsync(threadId);// 完成 future.onComplete((opStatus, e) -> { if (e != null) { // 取消到期续订 cancelExpirationRenewal(threadId); // 将这个未来标记为失败并通知所有人 result.tryFailure(e); return; }// 状态为空，说明解锁的线程和当前锁不是同一个线程 if (opStatus == null) { IllegalMonitorStateException cause = new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: " + id + " thread-id: " + threadId); result.tryFailure(cause); return; } cancelExpirationRenewal(threadId); result.trySuccess(null); }); return result;}

3. 打开unlockInnerAsync()方法

 

　　

protected RFuture<Boolean> unlockInnerAsync(long threadId) { return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, // 判断释放锁的线程和已存在锁的线程是不是同一个线程，不是返回空 "if (redis.call(hexists, KEYS[1], ARGV[3]) == 0) then " + "return nil;" + "end; " + // 释放锁后，加锁次数减一 "local counter = redis.call(hincrby, KEYS[1], ARGV[3], -1); " + // 判断剩余数量是否大于0 "if (counter > 0) then " + // 大于0 ，则刷新过期时间 "redis.call(pexpire, KEYS[1], ARGV[2]); " + "return 0; " + "else " + // 释放锁，删除key并发布锁释放的消息 "redis.call(del, KEYS[1]); " + "redis.call(publish, KEYS[2], ARGV[1]); " + "return 1; "+ "end; " + "return nil;", Arrays.<Object>asList(getName(), getChannelName()), LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId));}

 

　　

七、总结

这样大家就跟着小编走完了一遍底层源码，是不是感觉自己又行了，哈哈哈。小编走下来一遍觉得收货还是蛮大的，以前不敢点进去源码，进去就懵逼了，所以人要大胆的向前迈出第一步。

 

　　到此这篇关于Springboot基于Redisson实现Redis分布式可重入锁【案例到源码分析】的文章就介绍到这了,更多相关SpringbootRedis分布式可重入锁内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

标签：

相关文章阅读

  • ,,详解SpringBoot整合MyBatis详细教程
  • ,,详解SpringBoot中Session超时原理说明
  • ,,浅谈springboot中tk.mapper代码生成器的用法说明
  • ,,SpringBoot项目微信云托管入门部署实践
  • ,,SpringBoot集成JPA持久层框架,简化数据库操作
  • ,,SpringBoot整合Ureport2报表及常见使用方法
  • ,,SpringBoot整合Swagger3生成接口文档过程解析
  • ,,SpringBoot实现动态定时任务
  • ,,Springboot基础之RedisUtils工具类
  • ,,Springboot单元测试无法读取配置文件的解决方案
  • ,,SpringBoot事件发布和监听详解
  • ,,SpringBoot之HandlerInterceptor拦截器的使用详解
  • ,,SpringBoot+阿里云OSS实现在线视频播放的示例
  • ,,SpringBoot+WebSocket实现即时通讯的方法详解
  • ,,SpringBoot+Tess4j实现牛逼的OCR识别工具的示例代码
    • 留言与评论（共有 条评论）
       
    验证码：