RedisRedisson实现分布式锁(3)—项目落地实现

有关Redisson实现分布式锁前面写了两篇博客作为该项目落地的铺垫。

1、Redisson实现分布式锁(1)---原理

2、Redisson实现分布式锁(2)—RedissonLock

这篇讲下通过Redisson实现分布式锁的项目实现&＃xff0c;我会把项目放到GitHub,该项目可以直接运用于实际开发中&＃xff0c;作为分布式锁使用。

一、项目概述

1、技术架构

项目总体技术选型

SpringBoot2.1.5 &＃43; Maven3.5.4 &＃43; Redisson3.5.4 &＃43; lombok(插件)

2、加锁方式

该项目支持 自定义注解加锁 和 常规加锁 两种模式

自定义注解加锁

&＃64;DistributedLock(value&＃61;"goods", leaseTime&＃61;5)
public String lockDecreaseStock(){//业务逻辑
}

常规加锁

//1、加锁
redissonLock.lock("redisson", 10);
//2、业务逻辑
//3、解锁
redissonLock.unlock("redisson");

3、Redis部署方式

该项目支持四种Redis部署方式

1、单机模式部署
2、集群模式部署
3、主从模式部署
4、哨兵模式部署

该项目已经实现支持上面四种模式&＃xff0c;你要采用哪种只需要修改配置文件application.properties&＃xff0c;项目代码不需要做任何修改。

4、项目整体结构

redis-distributed-lock-core # 核心实现
|
---src|---com.jincou.redisson|# 通过注解方式 实现分布式锁---annotation|# 配置类实例化RedissonLock---config|# 放置常量信息---constant|# 读取application.properties信息后&＃xff0c;封装到实体---entity |# 支持单机、集群、主从、哨兵 代码实现---strategyredis-distributed-lock-web-test # 针对上面实现类的测试类
|
---src|---java|---com.jincou.controller|# 测试 基于注解方式实现分布式锁---AnnotatinLockController.java|# 测试 基于常规方式实现分布式锁---LockController.java---resources | # 配置端口号 连接redis信息(如果确定部署类型&＃xff0c;那么将连接信息放到core项目中)---application.properties

二、测试

模拟1秒内100个线程请求接口&＃xff0c;来测试结果是否正确。同时测试3中不同的锁:lock锁、trylock锁、注解锁。

1、lock锁

/*** 模拟这个是商品库存*/public static volatile Integer TOTAL &＃61; 10;&＃64;GetMapping("lock-decrease-stock")public String lockDecreaseStock() throws InterruptedException {redissonLock.lock("lock", 10);if (TOTAL > 0) {TOTAL--;}Thread.sleep(50);log.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;减完库存后,当前库存&＃61;&＃61;&＃61;" &＃43; TOTAL);//如果该线程还持有该锁&＃xff0c;那么释放该锁。如果该线程不持有该锁&＃xff0c;说明该线程的锁已到过期时间&＃xff0c;自动释放锁if (redissonLock.isHeldByCurrentThread("lock")) {redissonLock.unlock("lock");}return "&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;";}

压测结果

没问题&＃xff0c;不会超卖&＃xff01;

2、tryLock锁

/*** 模拟这个是商品库存*/
public static volatile Integer TOTAL &＃61; 10;&＃64;GetMapping("trylock-decrease-stock")public String trylockDecreaseStock() throws InterruptedException {if (redissonLock.tryLock("trylock", 10, 5)) {if (TOTAL > 0) {TOTAL--;}Thread.sleep(50);redissonLock.unlock("trylock");log.info("&＃61;&＃61;&＃61;&＃61;tryLock&＃61;&＃61;&＃61;减完库存后,当前库存&＃61;&＃61;&＃61;" &＃43; TOTAL);} else {log.info("[ExecutorRedisson]获取锁失败");}return "&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;";
}

测试结果

没有问题 &＃xff0c;不会超卖&＃xff01;

3、注解锁

/*** 模拟这个是商品库存*/
public static volatile Integer TOTAL &＃61; 10;&＃64;GetMapping("annotatin-lock-decrease-stock")
&＃64;DistributedLock(value&＃61;"goods", leaseTime&＃61;5)
public String lockDecreaseStock() throws InterruptedException {if (TOTAL > 0) {TOTAL--;}log.info("&＃61;&＃61;&＃61;注解模式&＃61;&＃61;&＃61; 减完库存后,当前库存&＃61;&＃61;&＃61;" &＃43; TOTAL);return "&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;";
}


测试结果

没有问题 &＃xff0c;不会超卖&＃xff01;

通过实验可以看出&＃xff0c;通过这三种模式都可以实现分布式锁&＃xff0c;然后呢&＃xff1f;哪个最优。

三、三种锁的锁选择

观点 最完美的就是lock锁&＃xff0c;因为

1、tryLock锁是可能会跳过减库存的操作&＃xff0c;因为当过了等待时间还没有获取锁&＃xff0c;就会返回false,这显然很致命&＃xff01;2、注解锁只能用于方法上&＃xff0c;颗粒度太大&＃xff0c;满足不了方法内加锁。

1、lock PK tryLock 性能的比较

模拟5秒内1000个线程分别去压测这两个接口&＃xff0c;看报告结果&＃xff01;

1&＃xff09;lock锁

压测结果 1000个线程平均响应时间为31324。吞吐量 14.7/sec

2&＃xff09;tryLock锁

压测结果 1000个线程平均响应时间为28628。吞吐量 16.1/sec

这里只是单次测试&＃xff0c;有很大的随机性。从当前环境单次测试来看&＃xff0c;tryLock稍微高点。

2、常见异常 attempt to unlock lock, not ······

在使用RedissonLock锁时&＃xff0c;很容易报这类异常&＃xff0c;比如如下操作

//设置锁1秒过去
redissonLock.lock("redisson", 1);
/*** 业务逻辑需要咨询2秒*/
redissonLock.release("redisson");

上面在并发情况下就会这样

造成异常原因&＃xff1a;

线程1 进来获得锁后&＃xff0c;但它的业务逻辑需要执行2秒&＃xff0c;在 线程1 执行1秒后&＃xff0c;这个锁就自动过期了&＃xff0c;那么这个时候
线程2 进来了获得了锁。在线程1去解锁就会抛上面这个异常&＃xff08;因为解锁和当前锁已经不是同一线程了&＃xff09;

所以我们需要注意&＃xff0c;设置锁的过期时间不能设置太小&＃xff0c;一定要合理&＃xff0c;宁愿设置大点。

正对上面的异常&＃xff0c;可以通过isHeldByCurrentThread()方法&＃xff0c;

//如果为false就说明该线程的锁已经自动释放&＃xff0c;无需解锁
if (redissonLock.isHeldByCurrentThread("lock")) {redissonLock.unlock("lock");
}

好了&＃xff0c;这篇博客就到这了&＃xff01;

至于完整的项目地址见GitHub。

如果对您能有帮助,就给个星星吧&＃xff0c;哈哈&＃xff01;

GitHub地址 https://github.com/yudiandemingzi/spring-boot-distributed-redisson

参考

1、自己写分布式锁--基于redission

2、Redisson实现Redis分布式锁的N种姿势

3、利用Redisson实现分布式锁及其底层原理解析