一、前言
在分布式系统中，多个节点可能会同时访问共享资源，导致数据不一致的问题。分布式锁是解决这些问题的一种有效机制。Redisson是一个基于Redis的Java客户端，不仅提供了丰富的分布式数据结构，还实现了分布式锁功能。本文将详细介绍Redisson分布式锁的用法，包括其配置、基本用法和高级用法。
二、Redisson分布式锁的配置
1. 引入依赖
首先，在Maven项目中引入Redisson依赖：
<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.1</version>
</dependency>
2. 配置Redisson客户端
创建Redisson配置文件 redisson-config.yaml：
singleServerConfig:address: "redis://127.0.0.1:6379"password: nullconnectionPoolSize: 64connectionMinimumIdleSize: 10
然后，在代码中加载配置文件并创建Redisson客户端：
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;public class RedissonManager {private static RedissonClient redisson;static {Config config = Config.fromYAML(new File("path/to/redisson-config.yaml"));redisson = Redisson.create(config);}public static RedissonClient getRedisson() {return redisson;}
}
三、Redisson分布式锁的基本用法
1. 获取分布式锁
使用Redisson的 getLock方法获取分布式锁：
import org.redisson.api.RLock;public class LockService {public void execute() {RedissonClient redisson = RedissonManager.getRedisson();RLock lock = redisson.getLock("myLock");lock.lock(); // 加锁try {// 业务逻辑} finally {lock.unlock(); // 解锁}}
}
2. 尝试加锁
可以使用 tryLock方法尝试加锁，并设置等待时间和锁的超时时间：
public class LockService {public void execute() {RedissonClient redisson = RedissonManager.getRedisson();RLock lock = redisson.getLock("myLock");boolean isLocked;try {isLocked = lock.tryLock(100, 10, TimeUnit.SECONDS);if (isLocked) {// 业务逻辑}} catch (InterruptedException e) {e.printStackTrace();} finally {if (isLocked) {lock.unlock(); // 解锁}}}
}
四、Redisson分布式锁的高级用法
1. 公平锁
公平锁按照请求顺序加锁，避免资源争夺不公平的问题：
public class LockService {public void execute() {RedissonClient redisson = RedissonManager.getRedisson();RLock fairLock = redisson.getFairLock("myFairLock");fairLock.lock();try {// 业务逻辑} finally {fairLock.unlock();}}
}
2. 读写锁
Redisson提供了读写锁 RWLock，支持读锁和写锁：
import org.redisson.api.RReadWriteLock;public class LockService {public void executeRead() {RedissonClient redisson = RedissonManager.getRedisson();RReadWriteLock rwLock = redisson.getReadWriteLock("myRWLock");RLock readLock = rwLock.readLock();readLock.lock();try {// 读操作} finally {readLock.unlock();}}public void executeWrite() {RedissonClient redisson = RedissonManager.getRedisson();RReadWriteLock rwLock = redisson.getReadWriteLock("myRWLock");RLock writeLock = rwLock.writeLock();writeLock.lock();try {// 写操作} finally {writeLock.unlock();}}
}
3. 联锁
联锁 RedissonMultiLock允许多个锁同时生效，所有锁都需要成功加锁后，业务逻辑才会执行：
import org.redisson.api.RLock;
import org.redisson.api.RedissonMultiLock;public class LockService {public void execute() {RedissonClient redisson = RedissonManager.getRedisson();RLock lock1 = redisson.getLock("lock1");RLock lock2 = redisson.getLock("lock2");RLock lock3 = redisson.getLock("lock3");RedissonMultiLock multiLock = new RedissonMultiLock(lock1, lock2, lock3);multiLock.lock();try {// 业务逻辑} finally {multiLock.unlock();}}
}
五、实际应用示例
示例：库存扣减
在电子商务系统中，商品的库存管理是一个典型的应用场景。为了防止超卖，需要使用分布式锁来控制库存的扣减。
@Service
public class InventoryService {@Autowiredprivate RedissonClient redissonClient;public void reduceStock(String productId, int quantity) {RLock lock = redissonClient.getLock("inventoryLock:" + productId);lock.lock();try {// 检查库存int stock = getStock(productId);if (stock >= quantity) {// 扣减库存updateStock(productId, stock - quantity);} else {throw new RuntimeException("库存不足");}} finally {lock.unlock();}}private int getStock(String productId) {// 查询库存逻辑}private void updateStock(String productId, int newStock) {// 更新库存逻辑}
}
六、常见问题及解决方案
1. 加锁失败
问题：Redisson客户端在加锁时出现异常。
解决方案：检查Redis服务器是否正常运行，网络连接是否正常，以及Redisson配置是否正确。
2. 锁超时
问题：业务逻辑执行时间超过锁的超时时间，导致锁自动释放。
解决方案：合理设置锁的超时时间，或者使用Redisson的看门狗机制，自动延长锁的有效期。
lock.lock(30, TimeUnit.SECONDS); // 设置锁超时时间为30秒
3. 死锁问题
问题：多个锁之间相互等待，导致死锁。
解决方案：使用Redisson的公平锁或者合理规划加锁顺序，避免死锁。