SpringBoot怎么整合分布式锁redisson

这篇文章主要介绍“SpringBoot怎么整合分布式锁redisson”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“SpringBoot怎么整合分布式锁redisson”文章能帮助大家解决问题。

1、导入maven坐标

<!-- 用redisson作为所有分布式锁，分布式对象等功能框架-->    <dependency>        <groupId>org.redisson</groupId>        <artifactId>redisson</artifactId>        <version>3.12.5</version>    </dependency>

2、redisson配置类（如果redis没有密码就不需要private String password）

package com.xuechengpluscommon.config; import org.redisson.Redisson;import org.redisson.api.RedissonClient;import org.redisson.config.Config;import org.redisson.config.SingleServerConfig;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration; @Configurationpublic class MyRedissonConfig {     @Value(value = "${spring.redis.host}")    private String host;    @Value(value = "${spring.redis.port}")    private int port;    @Value(value = "${spring.redis.database}")    private int database;//    @Value(value = "${spring.redis.password}")//    private String password;         @Bean(destroyMethod = "shutdown")    RedissonClient redisson() {        Config config = new Config();        //Redis多节点        // config.useClusterServers()        //     .addNodeAddress("redis://127.0.0.1:6379", "redis://127.0.0.1:7001");        //Redis单节点        SingleServerConfig singleServerConfig = config.useSingleServer();        //可以用"rediss://"来启用SSL连接        String address = "redis://" + host + ":" + port;        singleServerConfig.setAddress(address);        //设置 数据库编号        singleServerConfig.setDatabase(database);//        singleServerConfig.setPassword(password);        //连接池大小:默认值：64        // singleServerConfig.setConnectionPoolSize()        return Redisson.create(config);    } }

yml中redis的配置

redis:    database: 0    host: ip地址    port: 6379

3、创建redisson的bean

@Autowiredprivate RedissonClient redisson;

4、测试，入队

@Testvoid contextLoads1() {    RQueue<String> queue = redisson.getQueue("RedissonQueue");    queue.add("hello");    System.out.println(queue);}

redis数据

5、测试，出队

@Testvoid contextLoads2() {    RQueue<String> queue = redisson.getQueue("RedissonQueue");    String remove = queue.remove();    System.out.println(remove);}

出队数据：

6、分布式锁

public R redisTest1() throws InterruptedException {        //首先从redis查询数据        Orders redisOrder;        redisOrder=(Orders) redisTemplate.opsForValue().get("redisTest");        //如果存在redis则返回        if(ObjectUtils.isNotEmpty(redisOrder)){            return R.ok(redisOrder);            //如果不存在则从数据库查询        }else {            //首先获取分布式锁            RLock lock = redissonClient.getLock("redisTestDogWatch");            //上锁            lock.lock();             //获取锁之后进行查询            try {                redisOrder = (Orders) redisTemplate.opsForValue().get("redisTest");                if (ObjectUtils.isNotEmpty(redisOrder)) {                    return R.ok(redisOrder);                }                //数据库查询                redisOrder= ordersService.getById(1577177773194113014L);                redisTemplate.opsForValue().set("redisTest", redisOrder );                System.out.println("[从数据库中查询]");             } catch (Exception e) {                e.printStackTrace();            } finally {                //删除锁                lock.unlock();            }            return R.ok(redisOrder);        }    }

在这里让线程睡眠35秒

//上锁lock.lock();Thread.sleep(35000);

此时三个服务器运行

测试结果

可以首先看到已经上锁的redisTestDogWatch，每个锁30秒，如果线程未完成则会自动续30秒，如果线程完成到finally中的unlock就删除锁

目前可以看到只有一个服务器获取到锁

存储redis的数据

此时进行并发测试

依旧保持35秒的睡眠时间

此时可以看到未拿到锁的线程报错

java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: d904f2b9-e75d-472d-a5a6-d0a8cc603a80 thread-id: 210

尝试解锁锁定，未被当前线程锁定 按节点 ID：C731FAC4-9BF7-4F4A-ACC1-A2CC9B78A02F 线程 ID：232

这是因为锁住了，所以无法获取锁，然后看门狗会不断刷新

关于“SpringBoot怎么整合分布式锁redisson”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注编程网行业资讯频道，小编每天都会为大家更新不同的知识点。