使用RedisTemplate实现Redis分布式锁出现的一些列问题(避坑)
点击关注公众号,实用技术文章及时了解
来源:blog.csdn.net/lmx125254/
article/details/89604638
自己的项目因为会一直抓取某些信息,但是本地会和线上经常一起跑,造成冲突。这其实就是我们常说的分布式集群的问题了,本地和线上的服务器构成了集群以及QPS为2的小并发(其实也不叫并发,不知道拿什么词形容?)。
首先,分布式集群的问题大家都知道,会造成数据库的插入重复问题,会造成一系列的并发性问题。
解决的方式呢也大概如下几点,百度以及谷歌上都能搜到的解决方式:
数据库添加唯一索引
设计接口幂等性
依靠中间件使用分布式锁,而分布式锁又分为Redis和Zookeeper
由于Zookeeper我没怎么接触过,并且我项目中本来就引用了Redis,所以就想着用Redis来做分布式锁,也高端洋气上档次点。
首先基于Redis的操作,我们必须要保证其原子性,也就是要么全部成功,要么全部失败,先从Redis的客户端入手。
就Redis客户端而言,我们通过的操作是先使用setnx指令,如果成功则返回1,失败则返回0
可是就分布锁锁而言,一个常用的问题就是如果一个服务setnx成功了,但是在解锁的时候如果发生了宕机或者一些特殊因素,导致无法解锁,那么其他服务将陷入死锁的状态。所以,我们在用 setnx 的同时想着去用 expire 指令对锁进行一个过期操作
从指令可以看出 setnx 和 expire 指令是分开的,如果在这中间的空隙过程中如果有特殊因素导致指令无法继续,也会导致死锁的产生。
为了解决这个疑难,Redis 开源社区涌现了一堆分布式锁的 library,专门用来解决这个问题。实现方法极为复杂,小白用户一般要费很大的精力才可以搞懂。如果你需要使用分布式锁,意味着你不能仅仅使用 Jedis 或者 redis-py 就行了,还得引入分布式锁的 library。
为了治理这个乱象,Redis 2.8 版本中作者加入了 set 指令的扩展参数,使得 setnx 和 expire 指令可以一起执行,彻底解决了分布式锁的乱象。从此以后所有的第三方分布式锁 library 可以休息了。
以上都是基于Redis的操作,但是我们在JAVA中如何去运用分布式锁呢。学习资料:Java进阶视频资源
首先在Redis方面我用的是RedisTemplate对Redis进行操作的 ,而RedisTemplate在目前情况下如果不借助于是无法保证其原子性的,所以我们需要借助于Redis的Lua脚本。
先上Lua脚本的代码
// 加锁
if redis.call('setNx',KEYS[1],ARGV[1]) then if redis.call('get',KEYS[1])==ARGV[1] then return redis.call('expire',KEYS[1],ARGV[2]) else return 0 end
end// 解锁
if redis.call('get', KEYS[1]) == ARGV[1]
then return redis.call('del', KEYS[1])
else return 0
end
Java调用脚本有两种方式
1.新建一个脚本文件,在代码中调用其绝对路径地址
redisScript.setScriptSource(new ResourceScriptSource(new ClassPathResource(地址)));
2.在Java代码中以字符串的方式传入
redisScript.setScriptText(脚本);
我是用的第二种方式实现的,下面是JAVA代码
/*** 获取锁* @param lockKey* @param value* @param expireTime:单位-秒* @return*/public boolean getLock(String lockKey, String value, int expireTime){boolean ret = false;try{String script = "if redis.call('setNx',KEYS[1],ARGV[1]) then if redis.call('get',KEYS[1])==ARGV[1] then return redis.call('expire',KEYS[1],ARGV[2]) else return 0 end end";RedisScript<Long> redisScript = new DefaultRedisScript<>(script, Long.class);Object result = redisTemplate.execute(redisScript,new StringRedisSerializer(),new StringRedisSerializer(), Collections.singletonList(lockKey),value,expireTime + "");System.out.println(result + "-----------");//Object result = redisTemplate.execute(redisScript, Collections.singletonList(lockKey),value,expireTime + "");if(SUCCESS.equals(result)){return true;}}catch(Exception e){e.printStackTrace();}return ret;}/*** 释放锁* @param lockKey* @param value* @return*/public boolean releaseLock(String lockKey, String value){String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";RedisScript<Long> redisScript = new DefaultRedisScript<>(script, Long.class);Object result = redisTemplate.execute(redisScript,new StringRedisSerializer(),new StringRedisSerializer(), Collections.singletonList(lockKey),value);if(SUCCESS.equals(result)) {return true;}return false;}
以上代码已经在我的项目中确切可以使用了。但是在使用的过程中遇到了许多问题。
1.java.lang.IllegalStateException
在返回值方面,会经常报IllegalStateException。
RedisScript<String> redisScript = new DefaultRedisScript<>(script, String.class);
用String类型时候,经常会报类型转换异常。我在代码中使用的Long类型接收该类型,在命令行中我们也看到命令行结果返回的是数字0或者1,保险起见我们也可以用Object对象来接收结果集。
2.ERR value is not an integer or out of range
这个问题纠结了我一个下午至少,Redis报的异常都是很深的,从跟踪源码的时候看到,我们在调用redisTemplate.execute的方法时候,如果不传序列化的参数的时候,代码默认调用的是 Jdkserializationredisserializer 来进行序列化和反序列化操作,这是jdk自带的序列化操作,使用该序列化的对象必须要实现Serializable接口。所以该序列化接口是用于对实体类的序列化。
所以在进行 execute 操作的时候,我们传入 Stringredisserializer,该序列化接口是专用于对字符串类型的序列化操作。具体的区别可以去这两个类的源码中看下他们的加密方式。
因为时间以及个人能力的问题,对部分源码有点未理解,所以没有做到全方位的解读这些异常的原因,以后有机会会将源码细读并分析其异常原因。
以上是我对Redis分布式锁的一些个人的理解以及遇到的问题,如有错误请帮忙指正,多多包涵。
推荐:
主流Java进阶技术(学习资料分享)
PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧!
使用RedisTemplate实现Redis分布式锁出现的一些列问题(避坑)相关推荐
- RedisTemplate下Redis分布式锁引发的系列问题
https://blog.csdn.net/lmx125254/article/details/89604638
- Redis原生SET、SETNX、SETEX方法以及RedisTemplate的方法 + 分布式锁的实现
Redis原生GET/SET方法 SET()命令:有两个参数 set(key, value),将字符串值 value 关联到 key ,如果 key 已经持有其他值, SET 就覆写旧值,无视类型 S ...
- Redis分布式锁使用不当,酿成一个重大事故,超卖了100瓶飞天茅台!!!
点击关注公众号,Java干货及时送达 来源:juejin.cn/post/6854573212831842311 基于Redis使用分布式锁在当今已经不是什么新鲜事了. 本篇文章主要是基于我们实际项目 ...
- Redis 分布式锁使用不当,酿成一个重大事故,超卖了100瓶飞天茅台!!!
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! 基于Redis使用分布式锁在当今已经不是什么新鲜事了. 本 ...
- 秒杀商品超卖事故:Redis分布式锁请慎用!
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:浪漫先生 来源:juejin.im/post/6854573 ...
- 记一次由Redis分布式锁造成的重大事故,避免以后踩坑!
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:浪漫先生 juejin.im/post/5f159cd8f2 ...
- 简单介绍redis分布式锁解决表单重复提交的问题
在系统中,有些接口如果重复提交,可能会造成脏数据或者其他的严重的问题,所以我们一般会对与数据库有交互的接口进行重复处理.本文就详细的介绍一下redis分布式锁解决表单重复提交,感兴趣的可以了解一下 假 ...
- 因为一次 Redis 分布式锁事故,整个项目组被扣绩效了。。。
来源:http://suo.im/5CTeWB 前言 基于Redis使用分布式锁在当今已经不是什么新鲜事了.本篇文章主要是基于我们实际项目中因为redis分布式锁造成的事故分析及解决方案. 背景 我们 ...
- 飞天茅台超卖事故:Redis分布式锁请慎用!
" 基于 Redis 使用分布式锁在当今已经不是什么新鲜事了.本篇文章主要是基于我们实际项目中因为 Redis 分布式锁造成的事故分析及解决方案. 图片来自 Pexels 背景 我们项目中的 ...
最新文章
- php执行mysql insert,当执行mysql insert 时插入两条是咋回事
- 一文梳理2019年腾讯广告算法大赛冠军方案
- 廖雪峰python教程书-Python 爬虫:把廖雪峰的教程转换成 PDF 电子书
- Hadoop专业解决方案-第1章 大数据和Hadoop生态圈
- 列出Sell in application所有可以传输的application object
- linux磁盘使用情况脚本,技术|用 Linux Shell 脚本来监控磁盘使用情况并发送邮件...
- glxinfo: not found
- leetcode 144. Binary Tree Preorder Traversal ----- java
- android+统计功能,React Native 轻松集成统计功能(Android 篇)
- 如何进行Tuxera NTFS的挂载卷设置?
- MFC-利用内存映射文件来读写文件
- 2016年北京邮电大学计算机考研机试试题及答案
- 人工智能研究现状及发展前景如何
- LateX各种命令符号
- android打开蓝牙设置界面,Android 点击跳转到蓝牙设置界面
- 软考是什么?为什么要考?
- DG8FV-B9TKY-FRT9J-6CRCC-XPQ4G
- 【Python】windows下Eclipse中安装集成webpy框架
- 椭圆 标准方程 离心率 圆的标准方程
- Openharmony应用NAPI详解--基础篇
热门文章
- 英特尔中国:截至2018年底女性员工占比33%
- 业界最强!阿里“平头哥”首款芯片发布:应用于5G、自动驾驶等领域
- 什么手机用起来最烫手?2019上半年手机温度榜公布...
- 传华为将有2万名CNBG员工转岗CBG 回应:该消息不属实
- 用 GDB 调试Linux下的C程序
- c++自由读写配置ifstream(一)
- java任务追踪预警怎么写_分布式系统中如何优雅地追踪日志(原理篇)
- 【Flink on k8s】JConsole 远程监控 TaskManager
- 【Elasticsearch】关于 Analyzers 的一切,第一部分
- 【Elasticsearch】Elasticsearch gateway 流程分析