使用RedisTemplat实现简单的分布式锁
不使用redisson框架实现Redis分布式锁 准备工作:
导入依赖
org.springframework.boot spring-boot-starter-data-redis
编写RedisConfig类
@Configurationpublic class RedisConfig {
@Beanpublic RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
RedisTemplate redisTemplate = new RedisTemplate<>();
//String类型 key序列器redisTemplate.setKeySerializer(new StringRedisSerializer());
//String类型 value序列器redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
//Hash类型 key序列器redisTemplate.setHashKeySerializer(new StringRedisSerializer());
//Hash类型 value序列器redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
//将连接工厂注入redisTemplate.setConnectionFactory(redisConnectionFactory);
return redisTemplate;
} }
1.在SpringBootTest中编写测试模块 1.1:使用占位符加锁:
占位符加锁问题
:出现异常时无法释放锁,导致后继进入的线程成为死锁@SpringBootTestclass ApplicationTests {
@Autowiredprivate RedisTemplate redisTemplate;
@Testpublic void lodsTest01(){
ValueOperations valueOperations = redisTemplate.opsForValue();
//创建一个占位符,如果key不存在才可以设置成功Boolean isLock = valueOperations.setIfAbsent("k1", "v1");
//如果占位成功,进行正常操作if (isLock){
//设置一个name存到redisvalueOperations.set("name","xxxx");
//从redis取出nameString name = (String) valueOperations.get("name");
System.out.println("name = " + name);
//手动制造异常Integer.parseInt("xxxx");
//操作结束删除锁redisTemplate.delete("k1");
}else{
System.out.println("有线程在用,请稍后在试");
}}}
测试
第一个线程出现异常无法释放锁:
文章图片
之后所有线程都无法访问:
文章图片
解决方案
:为锁加一个有效时间。1.2:使用占位符设置有效时间解决死锁问题:
占位符设置有效时间问题
:即使某线程出现异常,但占位符过了有效时间,锁就会释放。但是在大量线程同时访问时,如果线程1被外界因素影响(网络波动,服务器出问题等等),线程1的业务还没完成,但锁的有效时间到了的话,下一个线程就会进来,就会出现线程不安全的情况,出现线程互相删锁的情况。@Testpublic void testLock02(){
ValueOperations valueOperations = redisTemplate.opsForValue();
//如果key不存在才可以设置成功,设置一个有效时间防止线程异常出现死锁Boolean isLock = valueOperations.setIfAbsent("k1", "v1",5, TimeUnit.SECONDS);
//如果占位成功,进行正常操作if (isLock){
//设置一个name存到redisvalueOperations.set("name","xxxx");
//从redis取出nameString str = (String) valueOperations.get("name");
System.out.println("name = " + str);
//制造异常Integer.parseInt("xxxx");
//操作结束删除锁redisTemplate.delete("k1");
}else{
System.out.println("有线程在用,请稍后在试");
}}
解决方案:
使用lua脚本,给每个锁的key对应的value设置一个随机数1.3:使用lua脚本解决线程不安全问题:
lua脚本可以写在Redis服务器上:
优点
: 在服务器上运行速度快缺点
: 修改代码时比较麻烦lua脚本可以通过java发送
优点:
修改代码方便缺点:
每次发送请求时都需要占用网络资源1.3.1:编写lua脚本
文章图片
if redis.call("get",KEYS[1])==ARGV[1] thenreturn redis.call("del",KEYS[1])elsereturn 0end
1.3.2:修改ReidsConfig类
@Beanpublic DefaultRedisScript defaultRedisScript(){
DefaultRedisScript redisScript = new DefaultRedisScript<>();
//lock.lua脚本位置和application.yml同级目录redisScript.setLocation(new ClassPathResource("lock.lua"));
//设置类型为booleanredisScript.setResultType(Boolean.class);
return redisScript;
}
1.3.3:编写测试模块
@Testpublic void testLock03(){
ValueOperations valueOperations = redisTemplate.opsForValue();
String value = https://www.it610.com/article/UUID.randomUUID().toString();
//如果key不存在才可以设置成功,设置一个value为随机数的值,防止出现线程太多 导致线程不安全Boolean isLock = valueOperations.setIfAbsent("k1", value, 5, TimeUnit.SECONDS);
//如果占位成功,进行正常操作if (isLock){
//设置一个name存到redisvalueOperations.set("name","xxxx");
//从redis取出nameString name = (String) valueOperations.get("name");
System.out.println("name = " + name);
//为redis发送lua脚本删除锁对应的valueBoolean aBoolean = (Boolean) redisTemplate.execute(redisScript, Collections.singletonList("k1"), value);
System.out.println(aBoolean);
}else{
System.out.println("有线程在用,请稍后在试");
}}
【使用RedisTemplat实现简单的分布式锁】
测试结果:
顺利把name值存到redis中并把锁删除并返回true
文章图片
锁会被正常删除只留下name:
文章图片
推荐阅读
- 由浅入深理解AOP
- 【译】20个更有效地使用谷歌搜索的技巧
- 关于QueryWrapper|关于QueryWrapper,实现MybatisPlus多表关联查询方式
- mybatisplus如何在xml的连表查询中使用queryWrapper
- MybatisPlus|MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决
- MybatisPlus使用queryWrapper如何实现复杂查询
- python学习之|python学习之 实现QQ自动发送消息
- 孩子不是实现父母欲望的工具——林哈夫
- opencv|opencv C++模板匹配的简单实现
- Node.js中readline模块实现终端输入