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

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 Template实现分布式锁的实例代码

    Redis Template实现分布式锁的实例代码

    这篇文章主要介绍了Redis Template实现分布式锁,需要的朋友可以参考下 ...

    晴天小哥哥2592019-11-18
  • Redisredis缓存存储Session原理机制

    redis缓存存储Session原理机制

    这篇文章主要为大家介绍了redis缓存存储Session原理机制详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪...

    程序媛张小妍9252021-11-25
  • Redis如何使用Redis锁处理并发问题详解

    如何使用Redis锁处理并发问题详解

    这篇文章主要给大家介绍了关于如何使用Redis锁处理并发问题的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Redis具有一定的参考学习...

    haofly4522019-11-26
  • RedisRedis集群的5种使用方式,各自优缺点分析

    Redis集群的5种使用方式,各自优缺点分析

    Redis 多副本,采用主从(replication)部署结构,相较于单副本而言最大的特点就是主从实例间数据实时同步,并且提供数据持久化和备份策略。...

    优知学院4082021-08-10
  • Redis《面试八股文》之 Redis十六卷

    《面试八股文》之 Redis十六卷

    redis 作为我们最常用的内存数据库,很多地方你都能够发现它的身影,比如说登录信息的存储,分布式锁的使用,其经常被我们当做缓存去使用。...

    moon聊技术8182021-07-26
  • Redis详解三分钟快速搭建分布式高可用的Redis集群

    详解三分钟快速搭建分布式高可用的Redis集群

    这篇文章主要介绍了详解三分钟快速搭建分布式高可用的Redis集群,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,...

    万猫学社4502021-07-25
  • RedisRedis 6.X Cluster 集群搭建

    Redis 6.X Cluster 集群搭建

    码哥带大家完成在 CentOS 7 中安装 Redis 6.x 教程。在学习 Redis Cluster 集群之前,我们需要先搭建一套集群环境。机器有限,实现目标是一台机器上搭建 6 个节...

    码哥字节15752021-04-07
  • Redis关于Redis数据库入门详细介绍

    关于Redis数据库入门详细介绍

    大家好,本篇文章主要讲的是关于Redis数据库入门详细介绍,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下,方便下次浏览...

    沃尔码6982022-01-24