分布式锁
blossom-spring-boot-starter-protection
(opens new window)技术组件,使用 Redis 实现分布式锁的功能,它有 2 种使用方式:
- 编程式锁:基于 Redisson (opens new window)框架提供的各种 (opens new window)分布式锁
- 声明式锁:基于 Lock4j (opens new window)框架的
@Lock4j
注解
# 1. 编程式锁
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
</dependency>
# 1.1 Redisson 配置
无需配置。因为在 Redis 缓存 (opens new window) 中,进行了 Spring Data Redis + Redisson 的配置。
# 1.2 实战案例
blossom-module-pay
模块的 notify
功能,使用到分布式锁,确保每个支付通知任务有且仅有一个在执行。下面,来看看这个案例是如何实现的。
① 在 RedisKeyConstants
类中,定义通知任务使用的分布式锁的 Redis Key。如下图所示:
② 创建 PayNotifyLockRedisDAO
类,使用 RedisClient 实现分布式锁的加锁与解锁。如下图所示:
③ 在 PayNotifyServiceImpl
执行指定的支付通知任务时,通过 PayNotifyLockRedisDAO 获得分布式锁。如下图所示:
技术选型:为什么不使用 Lock4j 提供的 LockTemplate 实现编程式锁?
两者各有优势,选择 Redisson 主要考虑它支持的 Redis 分布式锁的类型较多:可靠性较高的红锁、性能较好的读写锁等等。
Lock4j 的 LockTemplate 也是不错的选择,一方面不强依赖 Redisson 框架,一方面支持 ZooKeeper 等等。
# 2. 声明式锁
考虑到不是所有人都会使用 Lock4j 组件,所以默认项目未引入 lock4j-redisson-spring-boot-starter
。如果你想要实用,可按照下图进行引入:
# 2.1 Lock4j 配置
在 application-dev.yaml
(opens new window)配置文件中,通过 lock4j
配置项,添加 Lock4j 全局默认的分布式锁配置。如下图所示:
# 2.2 使用案例
在需要使用到分布式锁的方法上,添加 @Lock4j
注解,非常方便。示例代码如下:
@Service
public class DemoService {
// 默认使用 lock4j 配置项
@Lock4j
public void simple() {
//do something
}
// 完全配置,支持 Spring EL 表达式
@Lock4j(keys = {"#user.id", "#user.name"}, expire = 60000, acquireTimeout = 1000)
public User customMethod(User user) {
return user;
}
}