济南网站制作推广点赞排行 wordpress 主题

Redisson 实现分布式锁

业务方法：

如图，简单的执行一个增加余额的方法，为保证数据一致性，那么可以通过Redisson分布式锁来实现。

加锁逻辑

LockUtil 工具类

锁余额方法：

工具类代码

/*** @author lujinhong* @since  2025/3/25*/
public class LockUtil {/*** 锁商家余额** @param business 商家id* @param supplier 函数式接口；代表一个无参但有返回值的函数，就是代表加锁后要执行的业务逻辑* @param lockFail 加锁失败后执行的自定义业务逻辑，这里就是一个简单的抛异常*/public static <T> T businessBalance(Integer business, Supplier<T> supplier, InvokeInter lockFail) {return tryLock(RedisKey.LOCK_BUSINESS_BALANCE.getKey(business), supplier, lockFail);}
}

枚举代码

/*** @author lujinhong* @since  2025/3/25*/
@Getter
@AllArgsConstructor
public enum RedisKey {// 商家余额LOCK_BUSINESS_BALANCE("lock_business_balance_");private final String key;public String getKey(Number number) {return key + number;}
}

RedisUtil 工具类

tryLock 方法及重载【分布式锁具体实现】

/*** @author lujinhong* @since  2025/3/25*/
@Slf4j
@Component
public class RedisUtil {public static RedisUtil _this;@Resourceprivate RedissonClient redissonClient;@PostConstructpublic void init() {_this = this;}/*** 设置分布式锁** @param key      就是上面用商家id生成的一个key* @param supplier 函数式接口，加锁后要执行的业务逻辑* @param lockFail 加锁失败后执行的业务逻辑：这里是抛异常*/public static <T> T tryLock(String key, Supplier<T> supplier, InvokeInter lockFail) {return tryLock(key, supplier, lockFail, 10, TimeUnit.SECONDS);}/*** 设置分布式锁--具体实现* <p>* 注意事项1：.getLock(key)：用商家Id作为key生成一个rLock对象，底层代码是通过new来创建实例的，也就是说不同线程操作同一个商家获取到的是不同的RLock实例，* -----------重点来了：虽然 RLock 实例在 Java 层是不同的，但是它们 指向同一个 Redis 锁，这个锁的标识是由 key（比如 LOCK_BUSINESS_BALANCE:1001）决定的。* --------------------所以才需要在加锁之前，判断当前这个锁实例是否被其他线程占用了等判断--> if (lock.isLocked() && !lock.isHeldByCurrentThread())* <p>* 锁实例：RLock 是一个 Java 对象，代表分布式锁，它操作 Redis 中的实际锁资源。* 锁资源：是 Redis 中的一个 key，用于标识是否已被某个线程持有，实际上是分布式锁的底层实现。* <p>* 获取锁，其实就是当前线程获得了对某个共享资源的独占访问权限* <p>* lock.isHeldByCurrentThread() 的底层实现依赖于 Redis 中 锁的 value 存储了持有锁的线程的 ID。该方法通过查询 Redis 锁的 value，并与当前线程的 ID 比较，来判断当前线程是否持有该锁** @param key      用来生成 RLock 锁实例的key* @param supplier 函数式接口，在加锁成功后执行的业务逻辑* @param lockFail 加锁失败后执行的业务逻辑* @param amount   当前线程在获取锁时最多等待的时间【注意是获取锁的时间，不是获取到该锁后锁的存活时间】，就是给你多少时间去获取锁* @param unit     时间单位*/public static <T> T tryLock(String key, Supplier<T> supplier, InvokeInter lockFail, long amount, TimeUnit unit) {// 创建一个 redisson 分布式锁的锁实例：// 这个实例并不是直接获取Redis里的锁，而是一个Java对象，它是 Redisson 对 Redis 分布式锁的封装，用于后续操作：// 如 加锁tryLock()、释放锁unlock()、查询锁状态 isLocked()RLock lock = _this.redissonClient.getLock(key);try {// lock.isLocked()：判断的是 Redis 中该 key（锁资源）是否已经被其他线程或进程获取。// !lock.isHeldByCurrentThread()：判断当前线程是否持有该锁，就是通过 Redis 中的 key 来检查是否是当前线程获得了该锁if (lock.isLocked() && !lock.isHeldByCurrentThread()) {if (lockFail == null) {// 直接抛异常throw BizException.newInstance(ErrorCode.BUSY);}// 如果有自定义的加锁失败逻辑，则执行lockFail.invoke();}// 真正的加锁：在指定时间(amount)内获取锁，获取不到则返回false；// 问题：lock.tryLock获取到锁之后，redis内部是做了什么操作：其实就是操作了一句 setNx 命令而已。else if (lock.tryLock(amount, unit)) {try {// 执行具体的业务逻辑return supplier.get();} finally {// 释放锁lock.unlock();}} else {// 上面没获取到锁，则报错if (lockFail == null) {// 默认就抛这个异常throw BizException.newInstance(ErrorCode.BUSY);}// 如果有自定义的异常处理，则执行lockFail.invoke();}return null;} catch (InterruptedException e) {throw BizException.newInstance(ErrorCode.BUSY);}}}

Supplier 函数式接口调用分析