当前位置：首页 > 数据库 > Redis > 详细页面

Redis分布式锁一定要避开的两个坑

时间：2023-11-01来源：系统城装机大师作者：佚名

1 第一个坑：错误释放锁时机

1.1. 发现问题

分析以下代码存在什么问题：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33 // 分布式锁服务
public interface RedisLockService {
// 获取锁
public boolean getLock(String key);
// 释放锁
public boolean releaseLock(String key);
}

// 业务服务
public class BizService {

@Resource
private RedisLockService redisLockService;

public void bizMethod(String bizId) {
try {
// 获取锁
if(redisLockService.getLock(bizId)) {
// 业务重复校验
if(!bizValidate(bizId)) {
throw new BizException(ErrorBizCode.REPEATED);
}
// 执行业务
return doBusiness();
}
// 获取锁失败
throw new BizException(ErrorBizCode.GET_LOCK_ERROR);
} finally {
// 释放锁
redisLockService.releaseLock(bizId);
}
}
}

上述代码看似没问题，实则隐藏大问题。问题在于释放锁时没有校验当前线程是否拿到锁：

线程1和线程2同一时刻访问业务方法
线程2获取锁成功，进行业务处理
线程1没有获取到锁，但是释放锁成功
此时有线程3尝试获取锁成功，但是线程2业务没有处理完，所以线程3不会导致业务重复异常
最终导致线程2和线程3重复执行业务

1.2 解决问题

解决方案是在确认获取锁成功后才允许释放锁：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29 public class BizService {

@Resource
private RedisLockService redisLockService;

public void bizMethod(String bizId) {
boolean getLockSuccess = false;
try {
// 尝试获取锁
getLockSuccess = redisLockService.getLock(bizId);
// 获取锁成功
if(getLockSuccess) {
// 业务重复校验
if(!bizValidate(bizId)) {
throw new BizException(ErrorBizCode.REPEATED);
}
// 执行业务
return doBusiness();
}
// 获取锁失败
throw new BizException(ErrorBizCode.GET_LOCK_ERROR);
} finally {
// 获取锁成功才允许释放锁
if(getLockSuccess) {
redisLockService.releaseLock(bizId);
}
}
}
}