分布式锁三种实现方式:
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异常,全局统一处理即可



