Reactive WebFlux分布式锁实现难题：线程切换致锁失效如何解决？

问题根源分析 #

你遇到的锁失效问题，核心错误有两个：

1. 错误绑定线程ID与锁持有者：WebFlux基于Reactor异步非阻塞模型，线程是动态复用的，Thread.currentThread().getId()无法标识锁的真实持有者——Redisson的Reactive锁是与订阅上下文绑定，而非线程。
2. 异步解锁未同步生命周期：doFinally中调用unlock().subscribe()是异步执行，不会等待解锁完成，且异常无法被捕获；同时业务逻辑的线程切换会导致原线程被复用，其他任务复用该线程时并不会触发锁校验（因为锁的持有逻辑错误）。

正确实现方案 #

使用Reactor原生的usingWhen操作符管理锁的生命周期，它会自动绑定锁的获取、业务执行、锁释放的全流程，确保锁的正确持有与释放，完全适配异步非阻塞场景。

修改后的切面代码 #

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import reactor.core.publisher.Mono;

public Object createLock(ProceedingJoinPoint joinPoint, ReactiveRedissonLock reactiveRedissonLock) throws Throwable {
    Logger log = LoggerFactory.getLogger(LockAspect.class);
    RLockReactive reactiveLock = getReactiveLock(requestParamMap, keyRoot);
    
    // 使用usingWhen实现锁的声明式生命周期管理
    return Mono.usingWhen(
        // 1. 锁获取逻辑：成功则返回锁实例，失败抛出异常
        reactiveLock.tryLock(
                reactiveRedissonLock.waitTime(),
                reactiveRedissonLock.leaseTime(),
                TimeUnit.SECONDS
            )
            .flatMap(locked -> {
                if (!locked) {
                    return Mono.error(new AssessmentEngineException(
                        HttpStatus.INTERNAL_SERVER_ERROR, 
                        "Multiple calls not allowed to this part of the code"
                    ));
                }
                return Mono.just(reactiveLock);
            }),
        // 2. 执行业务逻辑：锁持有期间执行目标方法
        lock -> {
            try {
                return (Mono<?>) joinPoint.proceed();
            } catch (Throwable e) {
                return Mono.error(e); // 将切面捕获的异常包装为Reactive错误信号
            }
        },
        // 3. 锁释放逻辑：无论业务成功/失败，确保锁被释放
        lock -> lock.unlock()
            .onErrorResume(e -> {
                log.error("Failed to release Redisson lock", e);
                return Mono.empty(); // 捕获解锁异常，避免中断业务流程
            })
    );
}

方案核心优势 #

1. 生命周期绑定：usingWhen会确保只有锁获取成功后才执行业务逻辑，且业务逻辑完成（无论正常/异常）后，必须等待锁释放完成才会结束整个Reactive链，彻底避免锁泄漏。
2. 脱离线程依赖：不再使用线程ID关联锁，Redisson的Reactive锁内部通过订阅上下文管理持有者，完全适配WebFlux的线程切换特性。
3. 异常安全：解锁异常被单独捕获处理，不会影响业务逻辑的错误传递；业务逻辑的异常也会触发锁释放，避免死锁。

关键注意事项 #

• 锁Key唯一性：确保getReactiveLock生成的锁Key能唯一标识临界区，避免不同业务逻辑共用同一锁导致的误阻塞。
• LeaseTime与看门狗：如果业务执行时间不确定，可将leaseTime设为-1启用Redisson的看门狗机制，自动续期锁的持有时间（Reactive模式下Redisson默认支持该特性）。
• 业务返回类型校验：切面中需确保目标方法返回的是Mono/Flux类型，避免阻塞方法破坏异步非阻塞模型。

内容的提问来源于stack exchange，提问作者Nikhil Rai