Redis实现分布式锁

Redis实现分布式锁

分布式锁三种实现方式：
1. 基于数据库实现分布式锁；
2. 基于缓存（Redis等）实现分布式锁；
3. 基于Zookeeper实现分布式锁

本文记录redis实现分布式锁

基于缓存（Redis等）实现分布式锁

1. 使用命令介绍：
（1）SETNX
SETNX key val：当且仅当key不存在时，set一个key为val的字符串，返回1；若key存在，则什么都不做，返回0。
（2）expire
expire key timeout：为key设置一个超时时间，单位为second，超过这个时间锁会自动释放，避免死锁。
（3）delete
delete key：删除key

在使用Redis实现分布式锁的时候，主要就会使用到这三个命令。

2. 实现思想：
（1）获取锁的时候，使用setnx加锁，并使用expire命令为锁添加一个超时时间，超过该时间则自动释放锁，锁的value值为一个随机生成的UUID，通过此在释放锁的时候进行判断。
（2）获取锁的时候还设置一个获取的超时时间，若超过这个时间则放弃获取锁。
（3）释放锁的时候，通过UUID判断是不是该锁，若是该锁，则执行delete进行锁释放。

具体实现，借助 baomidou / lock4j分布式锁框架。Git地址：Gitee 搜索 - Gitee.com

pom依赖（核心几个依赖）

         
        
            org.springframework.boot
            spring-boot-starter-data-redis
        
        
        
            org.apache.commons
            commons-pool2
        
        
        
            com.baomidou
            lock4j-redis-template-spring-boot-starter
            2.2.0
        

配置文件

spring:
  datasource:
  redis:
    host: 127.0.0.1
    port: 6379
    password:
    database: 2
    # 连接超时时间
    timeout: 10s
    lettuce:
      shutdown-timeout: 100
      pool:
        # 连接池中的最小空闲连接
        min-idle: 2
        # 连接池中的最大空闲连接
        max-idle: 5
        # 连接池的最大数据库连接数
        max-active: 100
        # #连接池最大阻塞等待时间（使用负值表示没有限制）
        max-wait: -1ms

使用方法

//使用注解的方式
@Lock4j(expire = 10000L, acquireTimeout = 10000L)

    //Autowired注入bean的方式
    @Autowired
    private LockTemplate lockTemplate;
    //获取锁
    lockTemplate.lock("key", 10000L, 10000L, RedisTemplateLockExecutor.class);
    //finally中释放锁
    } finally {
     lockTemplate.releaseLock(lockInfo);
    }
    //当锁超时会抛出LockFailureException异常，全局统一处理即可