一、分布式锁的概述
1.1 分布式锁的背景
在单机系统中，Java 提供了 synchronized 和 Lock 等锁机制来确保并发情况下的线程安全。然而，在分布式系统中，多个服务实例运行在不同的物理或虚拟机上，无法直接使用这些本地的锁机制来控制对共享资源的访问。
为了在分布式环境中控制对共享资源的访问，就需要引入一种能够跨多台服务器实例的锁机制，这就是分布式锁。Redis 作为一种高性能的内存数据库，提供了基于 Redis 的分布式锁实现。Redisson 基于 Redis 对分布式锁进行了封装，提供了简洁易用的 API 来管理分布式锁。
1.2 分布式锁的特性
一个完整的分布式锁需要具备以下几个特性：
- 互斥性：同一时刻只能有一个客户端能获得锁，其他客户端必须等待锁被释放后才能继续操作。
- 容错性：如果持有锁的客户端因为网络或系统故障而没有主动释放锁，锁应当能够被安全地释放。
- 高可用性：锁的请求和释放过程应该是高效的，且在 Redis 节点出现故障时，系统依然能够正常工作。
二、Redisson 分布式锁的原理
Redisson 分布式锁基于 Redis 的 SETNX (set if not exists) 命令实现。基本的原理如下：
- 加锁：客户端请求加锁时，会向 Redis 发送一个
SETNX命令，如果返回值为 1，表示加锁成功。如果返回 0，则说明锁已经被其他客户端持有，当前客户端需要等待。 - 自动过期：为了防止客户端因故障而无法释放锁，锁的持有是有过期时间的。通过 Redis 的
EXPIRE命令，锁在加锁时同时设置过期时间，到期后锁将自动释放。 - 解锁：锁持有者执行完任务后，主动向 Redis 发送命令删除锁的 key，从而释放锁，其他等待的客户端才能继续加锁。
Redisson 通过封装 Redis 的这些基础命令，提供了 RLock 接口来方便地实现分布式锁。
三、Redisson 分布式锁的使用
3.1 引入 Redisson 依赖
在项目中使用 Redisson，首先需要在 pom.xml 文件中引入 Redisson 的依赖：
<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.3</version>
</dependency>
3.2 Redisson 配置
为了使用 Redisson 分布式锁，首先需要配置 Redisson 客户端。Redisson 支持单节点模式、主从模式、集群模式和哨兵模式等多种 Redis 部署模式。这里我们以单节点模式为例：
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;public class RedissonConfig {public RedissonClient redissonClient() {Config config = new Config();config.useSingleServer().setAddress("redis://127.0.0.1:6379");return Redisson.create(config);}
}
3.3 使用分布式锁
在配置好 Redisson 客户端后，可以通过 RedissonClient 来获取 RLock 对象，进行分布式加锁和解锁操作。下面是一个简单的使用示例：
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;public class DistributedLockExample {private final RedissonClient redissonClient;public DistributedLockExample(RedissonClient redissonClient) {this.redissonClient = redissonClient;}public void executeWithLock() {// 获取锁对象RLock lock = redissonClient.getLock("myLock");try {// 加锁lock.lock();System.out.println("获得锁，执行临界区代码");// 模拟业务逻辑Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();} finally {// 解锁lock.unlock();System.out.println("释放锁");}}
}
在上面的示例中，我们通过 redissonClient.getLock("myLock") 获取一个名为 myLock 的锁对象，并在执行完任务后通过 lock.unlock() 主动释放锁。
3.4 设置锁的超时时间
为了防止因异常情况导致锁无法释放，Redisson 提供了设置锁超时时间的功能。在获取锁时，可以通过 lock.lock(long leaseTime, TimeUnit unit) 方法指定锁的持有时间。例如，下面的代码将设置锁的持有时间为 10 秒：
public void executeWithTimeoutLock() {RLock lock = redissonClient.getLock("myLock");try {// 加锁并设置超时时间为10秒lock.lock(10, TimeUnit.SECONDS);System.out.println("获得锁，执行临界区代码");// 模拟业务逻辑Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();} finally {// 无需主动解锁，锁会在10秒后自动释放if (lock.isHeldByCurrentThread()) {lock.unlock();}System.out.println("释放锁");}
}
四、Redisson 分布式锁的应用场景
4.1 控制并发访问
在电商、抢购等高并发场景中，多个用户同时发起对同一商品的抢购请求，此时需要使用分布式锁来控制对库存资源的并发访问，防止超卖或重复购买。
public void purchase(String productId) {RLock lock = redissonClient.getLock("product:" + productId);try {// 尝试获取锁if (lock.tryLock(5, 10, TimeUnit.SECONDS)) {// 执行购买逻辑System.out.println("购买成功");} else {System.out.println("获取锁失败，购买失败");}} catch (InterruptedException e) {e.printStackTrace();} finally {if (lock.isHeldByCurrentThread()) {lock.unlock();}}
}
4.2 分布式任务调度
在分布式系统中，任务调度器往往有多个实例在同时运行。如果多个实例同时执行相同的任务，可能会导致数据重复处理或任务冲突。此时可以通过 Redisson 分布式锁确保同一时刻只有一个实例能够执行任务。
public void scheduleTask() {RLock lock = redissonClient.getLock("taskLock");try {if (lock.tryLock(1, TimeUnit.MINUTES)) {System.out.println("获得锁，执行调度任务");// 执行定时任务}} catch (InterruptedException e) {e.printStackTrace();} finally {if (lock.isHeldByCurrentThread()) {lock.unlock();}}
}
4.3 分布式事务
在分布式系统中，为了确保多个数据库或服务之间的数据一致性，可以使用 Redisson 分布式锁来控制对共享资源的访问，从而实现分布式事务的控制。
五、Redisson 分布式锁的优缺点
5.1 优点
- 实现简单：Redisson 提供了简洁的 API，开发者可以轻松地实现分布式锁功能。
- 丰富的分布式工具：除了分布式锁，Redisson 还提供了其他分布式工具，如分布式集合、队列、布隆过滤器等，适用于多种场景。
- 自动续期：Redisson 提供了自动续期功能，防止因任务执行时间过长导致锁意外释放。
5.2 缺点
- 依赖 Redis：Redisson 是基于 Redis 实现的分布式锁，依赖于 Redis 的可用性和性能。
- **锁的粒度
问题**：在使用分布式锁时，需要合理设计锁的粒度。锁粒度过大会导致性能瓶颈，锁粒度过小则可能导致竞争加剧。
六、总结
Redisson 作为 Redis 的高级客户端，提供了简单易用的分布式锁实现，能够很好地解决分布式系统中的并发控制问题。通过 Redisson，开发者可以快速实现分布式锁，并应用到电商、任务调度、分布式事务等场景中。
在使用 Redisson 分布式锁时，除了基本的加锁和解锁操作外，还需要合理设计锁的粒度，确保锁的可用性和系统性能的平衡。