服务器之家:专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

服务器之家 - 数据库 - Redis - 聊聊使用RedisTemplat实现简单的分布式锁的问题

聊聊使用RedisTemplat实现简单的分布式锁的问题

2021-11-25 17:54郝瑞杰 Redis

这篇文章主要介绍了使用RedisTemplat实现简单的分布式锁问题,文中给大家介绍在SpringBootTest中编写测试模块的详细代码,需要的朋友可以参考下

不使用redisson框架实现Redis分布式锁

准备工作:

导入依赖

?
1
2
3
4
<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

编写RedisConfig类

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String , Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
        RedisTemplate<String, Object> 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:使用占位符加锁:

占位符加锁问题:出现异常时无法释放锁,导致后继进入的线程成为死锁

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
@SpringBootTest
class ApplicationTests {
    @Autowired
    private RedisTemplate redisTemplate;
    @Test
    public void lodsTest01(){
        ValueOperations valueOperations = redisTemplate.opsForValue();
            //创建一个占位符,如果key不存在才可以设置成功
            Boolean isLock = valueOperations.setIfAbsent("k1", "v1");
            //如果占位成功,进行正常操作
            if (isLock){
                //设置一个name存到redis
                valueOperations.set("name","xxxx");
                //从redis取出name
                String name = (String) valueOperations.get("name");
                System.out.println("name = " + name);
                //手动制造异常
                Integer.parseInt("xxxx");
                //操作结束删除锁
                redisTemplate.delete("k1");
            }else{
                System.out.println("有线程在用,请稍后在试");
            }
    }
}

测试
第一个线程出现异常无法释放锁:

聊聊使用RedisTemplat实现简单的分布式锁的问题

之后所有线程都无法访问:

聊聊使用RedisTemplat实现简单的分布式锁的问题

解决方案为锁加一个有效时间。

1.2:使用占位符设置有效时间解决死锁问题:

占位符设置有效时间问题即使某线程出现异常,但占位符过了有效时间,锁就会释放。但是在大量线程同时访问时,如果线程1被外界因素影响(网络波动,服务器出问题等等),线程1的业务还没完成,但锁的有效时间到了的话,下一个线程就会进来,就会出现线程不安全的情况,出现线程互相删锁的情况。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
@Test
public void testLock02()  {
    ValueOperations valueOperations = redisTemplate.opsForValue();
    //如果key不存在才可以设置成功,设置一个有效时间防止线程异常出现死锁
    Boolean isLock = valueOperations.setIfAbsent("k1", "v1",5, TimeUnit.SECONDS);
    //如果占位成功,进行正常操作
    if (isLock){
        //设置一个name存到redis
        valueOperations.set("name","xxxx");
        //从redis取出name
        String 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脚本

聊聊使用RedisTemplat实现简单的分布式锁的问题

?
1
2
3
4
5
if redis.call("get",KEYS[1])==ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end

1.3.2:修改ReidsConfig类

?
1
2
3
4
5
6
7
8
9
@Bean
public DefaultRedisScript<Boolean> defaultRedisScript(){
    DefaultRedisScript<Boolean> redisScript = new DefaultRedisScript<>();
    //lock.lua脚本位置和application.yml同级目录
    redisScript.setLocation(new ClassPathResource("lock.lua"));
    //设置类型为boolean
    redisScript.setResultType(Boolean.class);
    return redisScript;
}

1.3.3:编写测试模块

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
@Test
    public void testLock03(){
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String value = UUID.randomUUID().toString();
        //如果key不存在才可以设置成功,设置一个value为随机数的值,防止出现线程太多 导致线程不安全
        Boolean isLock = valueOperations.setIfAbsent("k1", value, 5, TimeUnit.SECONDS);
        //如果占位成功,进行正常操作
        if (isLock){
            //设置一个name存到redis
            valueOperations.set("name","xxxx");
            //从redis取出name
            String name = (String) valueOperations.get("name");
            System.out.println("name = " + name);
            //为redis发送lua脚本删除锁对应的value
            Boolean aBoolean = (Boolean) redisTemplate.execute(redisScript, Collections.singletonList("k1"), value);
            System.out.println(aBoolean);
        }else{
            System.out.println("有线程在用,请稍后在试");
        }
    }

测试结果:
顺利把name值存到redis中并把锁删除并返回true

聊聊使用RedisTemplat实现简单的分布式锁的问题

锁会被正常删除只留下name:

聊聊使用RedisTemplat实现简单的分布式锁的问题

到此这篇关于使用RedisTemplat实现简单的分布式锁的文章就介绍到这了,更多相关RedisTemplat分布式锁内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/weixin_45826772/article/details/121393512

延伸 · 阅读

精彩推荐
  • Redisredis实现排行榜功能

    redis实现排行榜功能

    排行榜在很多地方都能使用到,redis的zset可以很方便地用来实现排行榜功能,本文就来简单的介绍一下如何使用,具有一定的参考价值,感兴趣的小伙伴们...

    乘月归5022021-08-05
  • RedisRedis全量复制与部分复制示例详解

    Redis全量复制与部分复制示例详解

    这篇文章主要给大家介绍了关于Redis全量复制与部分复制的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Redis爬虫具有一定的参考学习...

    豆子先生5052019-11-27
  • RedisRedis如何实现数据库读写分离详解

    Redis如何实现数据库读写分离详解

    Redis的主从架构,能帮助我们实现读多,写少的情况,下面这篇文章主要给大家介绍了关于Redis如何实现数据库读写分离的相关资料,文中通过示例代码介绍...

    罗兵漂流记6092019-11-11
  • Redisredis中如何使用lua脚本让你的灵活性提高5个逼格详解

    redis中如何使用lua脚本让你的灵活性提高5个逼格详解

    这篇文章主要给大家介绍了关于redis中如何使用lua脚本让你的灵活性提高5个逼格的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具...

    一线码农5812019-11-18
  • Redis详解Redis复制原理

    详解Redis复制原理

    与大多数db一样,Redis也提供了复制机制,以满足故障恢复和负载均衡等需求。复制也是Redis高可用的基础,哨兵和集群都是建立在复制基础上实现高可用的...

    李留广10222021-08-09
  • RedisRedis的配置、启动、操作和关闭方法

    Redis的配置、启动、操作和关闭方法

    今天小编就为大家分享一篇Redis的配置、启动、操作和关闭方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧 ...

    大道化简5312019-11-14
  • RedisRedis 事务知识点相关总结

    Redis 事务知识点相关总结

    这篇文章主要介绍了Redis 事务相关总结,帮助大家更好的理解和学习使用Redis,感兴趣的朋友可以了解下...

    AsiaYe8232021-07-28
  • Redisredis 交集、并集、差集的具体使用

    redis 交集、并集、差集的具体使用

    这篇文章主要介绍了redis 交集、并集、差集的具体使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友...

    xiaojin21cen10152021-07-27