Redis集群利用Redisson实现分布式锁

傷城~ 2024-04-18 13:44 78阅读 0赞

Redisson实现集群环境下的分布式锁十分简单：

#### 引入依赖 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70]

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.8.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.lk</groupId>
        <artifactId>demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>demo</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            //Redis起步依赖
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
                <version>2.1.7.RELEASE</version>
            </dependency>
            //Redisson起步依赖
            <dependency>
                <groupId>org.redisson</groupId>
                <artifactId>redisson-spring-boot-starter</artifactId>
                <version>3.11.2</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.48</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

#### Redisson配置类 ####

package com.lk.demo.redissionconfig;
    
    import org.redisson.Redisson;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /*
    * Redisson的配置类，提供RedissonClient实例
    * */
    @Configuration
    public class RedissionConfiguration {
    
        @Bean
        public RedissonClient getRedissionClient(){
            Config config=new Config();
            //集群模式,集群节点的地址须使用“redis://”前缀，否则将会报错。
            //此例集群为3节点，各节点1主1从
            config.useClusterServers().addNodeAddress("redis://192.168.37.134:7001","redis://192.168.37.134:7002",
                    "redis://192.168.37.134:7003","redis://192.168.37.134:7004","redis://192.168.37.134:7005","redis://192.168.37.134:7006");
            return Redisson.create(config);
        }
    }

#### 分布式锁 ####

package com.lk.demo.redissionconfig;
    
    import org.redisson.api.RLock;
    import org.redisson.api.RedissonClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.stereotype.Repository;
    
    
    import java.util.concurrent.TimeUnit;
    
    /*
    * 利用RedissonClient部署及解除分布式锁
    * 直接调用lock、unlock方法，此方法只允许1个线程取得锁，其余线程将自旋等待
    * */
    
    @Repository
    public class HandlerLock{
        @Autowired
        private RedisTemplate<String,String> rt;
        //@Qualifier("redisson") //在org.redisson.spring.starter包中，可以从配置文件读取redis配置，并返回redissonclient对象
        @Qualifier("getRedissionClient")//指定从本地自写的class中取得实例
        @Autowired
        private RedissonClient redissonClient;
        //实验方法，测试分布式锁
        public void doLock(String lockname){
            //从RedissonClient取得Rlock实例
            RLock rlock=redissonClient.getLock(lockname);
            //尝试取锁，有效期为3s，到期后自动释放。如果取得锁继续执行。取锁失败则自旋。
            //亦可使用rlock.tryLock（）方法，此方法也为尝试取锁，并返回boolean结果
            rlock.lock(3,TimeUnit.SECONDS);
            //以下为测试业务代码，
            System.out.println(Thread.currentThread().getName()+"取得锁");
            int store=Integer.valueOf(rt.opsForValue().get("store"));
            if(store>0)
            {
                System.out.printf("售出1,当前库存为%d\n",--store);
                rt.opsForValue().set("store",String.valueOf(store));
            }else
                System.out.println("已售完，下次再来吧");
            //业务完成，释放锁
            rlock.unlock();
            System.out.println("解锁");
        }
    }

#### 测试Controller ####

@Controller
    public class Controllerdemo {
        @Autowired
        private HandlerLock handlerLock;
        @RequestMapping("/hello")
        @ResponseBody
        public void demo(){
            handlerLock.doLock("luking");
        }
    
    }

#### 并发测试 ####

启动SpringBoot，使用Jmeter进行并发压力测试，Redis中store字段现有值100。

###### 500线程并发，循环2次 ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70 2]

###### 控制台结果输出 ######

![在这里插入图片描述][20190907155532477.png]

###### redis缓存 ######

![在这里插入图片描述][20190907155646148.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/82a03c41a2ba4dd691a1111b26311d59.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/0fe7458a251b4e31a89b36091b5a0cef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/de158aa2db2d45ecac11b74b524c0d22.png
[20190907155532477.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/f6f60b4a15ea4c10a9c43270c4671da9.png
[20190907155646148.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a137cefd13dc4081b4b3c2d87b518d33.png