Springboot基于Redisson如何实现Redis分布式可重入锁源码解析

魁首哥

作者

Springboot基于Redisson如何实现Redis分布式可重入锁源码解析

这篇文章主要介绍了Springboot基于Redisson如何实现Redis分布式可重入锁源码解析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

一、前言

我们在实现使用Redis实现分布式锁，最开始一般使用SET resource-name anystring NX EX max-lock-time进行加锁，使用Lua脚本保证原子性进行实现释放锁。这样手动实现比较麻烦，对此Redis官网也明确说Java版使用Redisson来实现。小编也是看了官网慢慢的摸索清楚，特写此记录一下。从官网到整合Springboot到源码解读，以单节点为例。

二、为什么使用Redisson

1. 我们打开官网

redis中文官网

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

3. 打开官方推荐

4. 找到文档

Redisson地址

5. Redisson结构

三、Springboot整合Redisson

1. 导入依赖

org.springframework.bootspring-boot-starter-data-redisredis.clientsjedisorg.redissonredisson3.12.0

2. 以官网为例查看如何配置

3. 编写配置类

importorg.redisson.Redisson;importorg.redisson.api.RedissonClient;importorg.redisson.config.Config;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;/***@authorwangzhenjun*@date2022/2/99:57*/@ConfigurationpublicclassMyRedissonConfig{/***所有对redisson的使用都是通过RedissonClient来操作的*@return*/@Bean(destroyMethod="shutdown")publicRedissonClientredisson(){//1.创建配置Configconfig=newConfig();//一定要加redis://config.useSingleServer().setAddress("redis://192.168.17.130:6379");//2.根据config创建出redissonClient实例RedissonClientredissonClient=Redisson.create(config);returnredissonClient;}}

4. 官网测试加锁例子

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

@ResponseBody@GetMapping("/hello")publicStringhello(){//1.获取一把锁，只要锁名字一样，就是同一把锁RLocklock=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(InterruptedExceptione){e.printStackTrace();}finally{//3.解锁System.out.println("解锁成功："+Thread.currentThread().getId());lock.unlock();}return"hello";}

6. 测试

四、lock.lock()源码分析

1. 打开RedissonLock实现类

2. 找到实现方法

@Overridepublicvoidlock(){try{//我们发现不穿过期时间源码默认过期时间为-1lock(-1,null,false);}catch(InterruptedExceptione){thrownewIllegalStateException();}}

3. 按住Ctrl进去lock方法

privatevoidlock(longleaseTime,TimeUnitunit,booleaninterruptibly)throwsInterruptedException{//获取线程的id，占有锁的时候field的值为UUID:线程号idlongthreadId=Thread.currentThread().getId();//尝试获得锁Longttl=tryAcquire(leaseTime,unit,threadId);//lockacquired获得锁，返回if(ttl==null){return;}//这里说明获取锁失败，就通过线程id订阅这个锁RFuturefuture=subscribe(threadId);if(interruptibly){commandExecutor.syncSubscriptionInterrupted(future);}else{commandExecutor.syncSubscription(future);}try{//这里进行自旋，不断尝试获取锁while(true){//继续尝试获取锁ttl=tryAcquire(leaseTime,unit,threadId);//lockacquired获取成功if(ttl==null){//直接返回，挑出自旋break;}//waitingformessage继续等待获得锁if(ttl>=0){try{future.getNow().getLatch().tryAcquire(ttl,TimeUnit.MILLISECONDS);}catch(InterruptedExceptione){if(interruptibly){throwe;}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. 进去尝试获取锁方法

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