Redission锁的设计原理和应用
2021/8/14 2:05:57
本文主要是介绍Redission锁的设计原理和应用,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
Redission锁的设计原理和应用
一:基本使用方法
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.8.2</version> </dependency>
@Test public void tt() { Config config = new Config(); config.useSingleServer().setAddress("127.0.0.1:6399").setDatabase(0); // 构造RedissonClient RedissonClient redissonClient = Redisson.create(config); // 设置锁定资源名称 RLock disLock = redissonClient.getLock("helloRedissionLock"); boolean isLock; try { //尝试获取分布式锁 isLock = disLock.tryLock(500, 15000, TimeUnit.MILLISECONDS); if (isLock) { //TODO if get lock success, do something; Thread.sleep(15000); } } catch (Exception e) { } finally { // 无论如何, 最后都要解锁 disLock.unlock(); } }
二:通过源码解读设计原理
2.1获取锁(关键代码如下)
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; " + "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " + "redis.call('hincrby', KEYS[1], ARGV[2], 1); " + "redis.call('pexpire', KEYS[1], ARGV[1]); " + "return nil; " + "end; " + "return redis.call('pttl', KEYS[1]);", Collections.<Object>singletonList(getName()), internalLockLeaseTime, getLockName(threadId));
解读:这是一段lua的脚本
第一个if:判断key = helloRedissionLock是否存在?若不存(==0)在则通过hset命令设置 key = helloRedissionLock的hash对象(key=当前线程ID:1 value=1),并且设置过期时间
第二个if:判断key = helloRedissionLock和hash对象(key=当前线程ID:1 value=1)?若存在(==1)则:1.设置hash对象的value+1,2.重新设置过期时间
return:key = helloRedissionLock的过期时间
备注:Hincrby 命令用于为哈希表中的字段值加上指定增量值,该点是reentrant lock的关键
2.2 解锁
return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, "if (redis.call('exists', KEYS[1]) == 0) then " + "redis.call('publish', KEYS[2], ARGV[1]); " + "return 1; " + "end;" + "if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then " + "return nil;" + "end; " + "local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); " + "if (counter > 0) then " + "redis.call('pexpire', KEYS[1], ARGV[2]); " + "return 0; " + "else " + "redis.call('del', KEYS[1]); " + "redis.call('publish', KEYS[2], ARGV[1]); " + "return 1; "+ "end; " + "return nil;", Arrays.<Object>asList(getName(), getChannelName()), LockPubSub.unlockMessage, internalLockLeaseTime, getLockName(threadId));
解读:
第一个if:判断key=入参是否存在?若不存在(==0),广播机制,然后返回1。
第二个if:判断key和value是否存在?若不存在(==0 返回ni l。
脚本(存在):local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1);获取value
第三个if:判断counter是否大于0?true-->value-1:
else:删除key并广播
2.3 等待
while (true) { long currentTime = System.currentTimeMillis(); ttl = tryAcquire(leaseTime, unit, threadId); // lock acquired if (ttl == null) { return true; } ...... }
解读:
通过while(true)实现线程等待
三:应用实例(Springboot)
3.1 简介:在分布式或者多线程场景下,为了让一个数据或方法(数据来源数据库)在同一时刻只能让一个人处理(即串性),我们可以利用Redission锁让只有拿到锁的人才能编辑该数据。
实现原理:利用切面编程+注解(RedissionLock)编程的方式实现对方法上加入了RedissionLock注解的方法进行全局加锁
3.2 定义注解
@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface RedissionLock { /** * 锁住方法中的第几个参数(-1全部参数) * * @return */ int lockIndexParam() default -1; /** * 锁的时间 * * @return */ int leaseTime() default 10; /** * 等待时间 */ int waitTime() default 5; }
3.3 注册切面
@Aspect @Component public class RedissionLockAspect { @Resource private RedissonClient redissonClient; /** * 环绕通知:灵活自由的在目标方法中切入代码 */ @Around("@annotation(redissionLock)") public Object around(ProceedingJoinPoint joinPoint, RedissionLock redissionLock) throws Throwable { // 获取目标方法的名称 String methodName = joinPoint.getSignature().getName(); // 获取方法传入参数 Object[] params = joinPoint.getArgs(); System.out.println("==@Around== lingyejun blog logger --》 method name " + methodName + " args " + params[0]); RLock lock = redissonClient.getLock(params[redissionLock.lockIndexParam()-1].toString()); boolean b = lock.tryLock(redissionLock.waitTime(), redissionLock.leaseTime(), TimeUnit.MINUTES); if (b) { lock.unlock(); return joinPoint.proceed(); } else { return null; } } }
3.4 使用方式
@RedissionLock(lockIndexParam = 1) public void tt(String id){ System.out.println("进入了方法::" + id); }
这篇关于Redission锁的设计原理和应用的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-12-07Redis高并发入门详解
- 2024-12-07Redis缓存入门:新手必读指南
- 2024-12-07Redis缓存入门:新手必读教程
- 2024-12-07Redis入门:新手必备的简单教程
- 2024-12-07Redis入门:新手必读的简单教程
- 2024-12-06Redis入门教程:从安装到基本操作
- 2024-12-06Redis缓存入门教程:轻松掌握缓存技巧
- 2024-12-04Redis入门:简单教程详解
- 2024-11-29Redis开发入门教程:从零开始学习Redis
- 2024-11-27Redis入门指南:快速掌握Redis基础操作