Redisson&AOP自定义分布式锁组件

以下是一个使用Redisson和AOP创建分布式锁的简单示例。这个示例假设你已经配置了Redisson客户端并且已经添加了AOP依赖。

首先，创建一个注解来标记需要加锁的方法：

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface DistributedLock {
    String value() default "";
    int timeout() default 30; // 锁的默认超时时间
}

然后，创建一个切面来处理加锁和释放锁的逻辑：

@Aspect
@Component
public class DistributedLockAspect {
 
    @Autowired
    private RedissonClient redissonClient;
 
    @Around("@annotation(distributedLock)")
    public Object around(ProceedingJoinPoint joinPoint, DistributedLock distributedLock) throws Throwable {
        String lockKey = distributedLock.value();
        if (StringUtils.isEmpty(lockKey)) {
            lockKey = joinPoint.getSignature().toGenericString();
        }
 
        RLock lock = redissonClient.getLock(lockKey);
        try {
            boolean isLocked = lock.tryLock(distributedLock.timeout(), distributedLock.timeout(), TimeUnit.SECONDS);
            if (isLocked) {
                return joinPoint.proceed();
            } else {
                // 处理没有获取到锁的情况
                throw new RuntimeException("Could not obtain lock for " + lockKey);
            }
        } finally {
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}

最后，在你需要加锁的方法上使用@DistributedLock注解：

@Service
public class SomeService {
 
    @DistributedLock(value = "someKey", timeout = 10)
    public void someMethod() {
        // 你的业务逻辑
    }
}

这个示例展示了如何使用AOP和Redisson创建一个简单的分布式锁。你可以根据自己的需求调整超时时间和锁的key生成策略。