六Redis分布式锁实战

一 redis设置值存在的问题

上边代码在单机部署时是没问题的&＃xff0c;但是如果是下边这种分布式&＃xff08;集群&＃xff09;架构的话&＃xff0c;就会产生问题了

本地启动两个同样的应用&＃xff0c;分别是8080和8090端口&＃xff0c;通过Nginx配置访问这两个应用

使用Jmeter模拟多个请求去请求nginx

如果两个控制台有相同的数据出现&＃xff0c;那就是说明在分布式环境下出现问题了&＃xff08;下边这俩数是一样的&＃xff09;&＃xff1a;

结果&＃xff1a;synchronized等各种锁&＃xff0c;只在JVM级别生效&＃xff0c;在分布式集群架构下会失效&＃xff1b;解决这个问题需要使用分布式锁&＃xff0c;实现简单Redis的分布式锁代码如下

jedis有一条命令setnx(key,value),这条命令会向Redis服务端存一个key/value&＃xff0c;返回的结果指的是是否存成功&＃xff08;如果服务端已经存在这个key了&＃xff0c;那么就会返回false&＃xff09;&＃xff1b;由于Redis是单线程&＃xff0c;所以只会有一个线程来执行这行setnx(key,value)代码&＃xff1b;

上边的代码存在的问题&＃xff1a;如果删除key之前代码出现异常&＃xff0c;那么这个key就不会被正常删除了&＃xff0c;所以应该加try/finally代码块&＃xff0c;让删除key的代码一定执行

继续优化&＃xff0c;如果执行finally前宕机了&＃xff0c;这个key就不会被删除了&＃xff0c;还是存在问题。这时可以加一个超时时间&＃xff0c;超过这个超时时间后&＃xff0c;redis会自动把这个key清除掉&＃xff0c;此时即使程序中间出异常了&＃xff0c;过了这个时间后&＃xff0c;那个key也会被删除&＃xff0c;其他线程还是可以在redis里设置key的&＃xff08;没有超时时间的话&＃xff0c;这个key一直存在&＃xff0c;其他线程一直就没法进来执行代码&＃xff09;

在高并发场景下&＃xff0c;上边的代码还是有问题&＃xff0c;线程1加的锁可能被线程2释放掉了&＃xff08;超时时间设置10秒&＃xff0c;结果线程1执行需要15秒&＃xff0c;这就存在问题了&＃xff09;&＃xff1b;解决&＃xff1a;给每一个线程生成一个唯一的UUID&＃xff0c;把这个UUID放在redis的value里

删除锁之前判断当前这个锁是不是自己加的&＃xff0c;是的话再删除&＃xff1b;

上边的代码其实还有问题&＃xff0c;如果最下边的finally里边&＃xff0c;删除key之前报错了就又出问题了&＃xff1b;
上边的超时时间的设置也是个问题&＃xff0c;设置多长都可能会出现问题&＃xff0c;比如设置30秒&＃xff0c;还是会有的代码逻辑执行超过30秒的&＃xff1b;

可以采用定时任务来解决这个问题——锁续命&＃xff1a;
主线程1进来把key锁上&＃xff0c;假设锁了30秒&＃xff0c;此时在后台同时开启一个子线程2做定时任务timer&＃xff0c;每隔10秒执行定时器&＃xff0c;去检查主线程1设置的这个锁是否还存在&＃xff0c;如果存在意味着释放锁的代码还没执行&＃xff08;主线程业务代码还没执行完&＃xff09;&＃xff0c;此时把这个锁的超时时间重新置为30秒&＃xff0c;如果不存在则结束这个子线程2&＃xff1b;

二 分布式下redis解决方案redisson

基于以上问题&＃xff0c;有一个开源框架已经解决了上边的定时器——redisson
redisson官网
redisson在封装redis命令上没有Jedis强&＃xff0c;但是在分布式环境下要比Jedis优秀很多

使用redisson
引入依赖

springBoot启动类配置redisson
在springBoot启动类上加入redisson配置&＃xff0c;将redisson对象注入到Bean容器里&＃xff1a;

不同的redis环境使用的api不一样&＃xff1a;

使用redisson实现之前的锁逻辑

注入redisson

实现业务逻辑&＃xff1a;

redisson实现原理

redisson底层调用的大量lua脚本语言&＃xff0c;调用了很多redis的原子操作功能&＃xff08;setnx&＃xff09;&＃xff1b;

高并发分布式锁如何实现——分段锁
假如编号是001的商品有1000个&＃xff0c;则可以分为10个段

001-1&＃61;100个
001-2&＃61;100个
001-3&＃61;100个
-------------
001-10&＃61;100个


把001-1、001-2.。。。。。。。。。。001-10这10个段作为key分别放在redis集群里的不同机器里&＃xff0c;然后针对不同的段进行加锁;