SpringBoot基于Redisson实现分布式锁并分析其原理

SpringBoot基于Redisson实现分布式锁并分析其原理

目录

• • 一、简介
  • 二、maven依赖
  • 三、配置类
  • • 3.1、属性配置
    • 3.2、redis配置
    • 3.3、redisson配置
  • 四、分布式锁使用
  • • 4.1、service层
    • 4.2、controller层
  • 五、配置文件application.yml
  • • 5.1、单节点配置
    • 5.2、集群节点配置
  • 六、测试
  • • 6.1、多实例准备和Nginx配置
    • 6.2、jemeter并发测试
    • • 6.2.1、不加锁并发结果
      • 6.2.2、使用redisson加锁结果
  • 七、redisson原理（注释都在代码里）
  • • 7.1、获取锁对象
    • • 7.1.1、加锁getLock()
    • 7.2、加锁lock()
    • • 7.2.1、加锁lock()（重要）
      • 7.2.2、tryAcquire()
      • 7.2.3、tryAcquireAsync()
      • 7.2.4、tryLockInnerAsync()（核心）
      • 7.2.5、流程图
    • 7.3、释放锁unlock
    • • 7.3.1、unlock()
      • 7.3.2、unlockAsync()
      • 7.3.3、unlockInnerAsync()（核心）
      • 7.3.4、流程图
    • 7.4、锁的续期
    • • 7.4.1、scheduleExpirationRenewal()
      • 7.4.2、renewExpiration()（重要）
      • 7.4.3、renewExpirationAsync()（核心）
    • 7.5、lua脚本

一、简介

  在分布式系统中，为了保证同一时间只能由一个客户端对共享资源 *** 作，我们通常采用加锁来实现，常见有三种方式：

• 基于数据库实现的分布式锁
• 基于zookeeper实现的分布式锁
• 基于redis实现的分布式锁

  而在使用redis实现时Redisson是官方推荐的一种方案也是我们今天的主角。

二、maven依赖

pom.xml

    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.5.2
        
    

    com.alian
    redisson
    0.0.1-SNAPSHOT
    redisson
    Spring Boot分布式锁之redisson

    
        1.8
    

    

        
            org.springframework.boot
            spring-boot-starter-web
            ${parent.version}
        

        
        
            org.springframework.boot
            spring-boot-starter-data-redis
            ${parent.version}
        

        
        
            com.fasterxml.jackson.core
            jackson-databind
            2.9.10
        

        
        
            com.fasterxml.jackson.datatype
            jackson-datatype-jsr310
            2.9.10
        

        
        
            com.alibaba
            fastjson
            1.2.68
        

        
        
            org.redisson
            redisson
            3.16.3
        

        
            org.projectlombok
            lombok
            1.16.14
        

    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    

  今天的主角就是redisson，如果关于redis不知道整合的可以参考我之前的文章：SpringBoot整合redis（redis支持单节点和集群），这里我就不过多的介绍了。

        
        
            org.redisson
            redisson
            3.16.3
        

三、配置类 3.1、属性配置

AppProperties.java

package com.alian.redisson.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Data
@Component
@ConfigurationProperties(prefix = "app.redisson")
public class AppProperties {

    
    private String address;

    
    private int database;

}

3.2、redis配置

  这里使用redis配置只是为了模拟分布式环境下数据库减库存。

RedisConfig.java

package com.alian.redisson.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalTimeSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;

@Configuration
public class RedisConfig {

    
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        // 实例化redisTemplate
        RedisTemplate redisTemplate = new RedisTemplate<>();
        //设置连接工厂
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        // key采用String的序列化
        redisTemplate.setKeySerializer(keySerializer());
        // value采用jackson序列化
        redisTemplate.setValueSerializer(valueSerializer());
        // Hash key采用String的序列化
        redisTemplate.setHashKeySerializer(keySerializer());
        // Hash value采用jackson序列化
        redisTemplate.setHashValueSerializer(valueSerializer());
        //执行函数，初始化RedisTemplate
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }

    
    private RedisSerializer keySerializer() {
        return new StringRedisSerializer();
    }

    
    private RedisSerializer