Spring Boot 3.0x的Redis 分布式锁的概念和原理

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>lock4j-redis-template-spring-boot-starter</artifactId>
    <version>2.2.7</version>
</dependency>

@Service
public class DemoServiceImpl {
    /**
    默认获取锁超时3秒，30秒锁过期
    这个方法使用了 @Lock4j 注解，并且没有显式地配置任何参数。
	默认行为：获取锁时的超时时间为 3 秒，锁的过期时间为 30 秒。
	适用场景：在简单的场景下，simple() 方法会被锁住，直到锁被释放或超时。在锁的持有期间，其他线程无法进入该方法。
	**/
    @Lock4j
    public void simple() {
        //需要执行的方法
    }
    /**
    完全配置，支持spel，这个方法使用了 @Lock4j 注解，并且自定义了多个参数。
	配置详解：
	keys = {"#user.id", "#user.name"}：使用 SpEL 表达式动态生成锁的键。这里锁的键由 user 对象的 id 和 name 属性组成，确保了锁的唯一性。
	expire = 60000：指定锁的过期时间为 60 秒（即1分钟）。
	acquireTimeout = 1000：指定获取锁的超时时间为 1 秒。
	适用场景：当方法涉及到特定用户操作时，使用 customMethod() 来确保同一用户（根据 id 和 name 唯一确定）不会被多个线程同时操作。只有在获取到锁的情况下，才会执行方法逻辑，锁在1秒内未获取到，则会抛出异常或执行相应处理。
	**/
    @Lock4j(keys = {"#user.id", "#user.name"}, expire = 60000, acquireTimeout = 1000)
    public User customMethod(User user) {
        return user;
    }
}

lock4j:
  acquire-timeout: 3000 # 默认获取锁超时时间为3秒
  expire: 30000 # 默认锁的过期时间为30秒
  primary-executor: com.baomidou.lock.executor.RedisTemplateLockExecutor # 使用RedisTemplate作为默认的锁执行器
  lock-key-prefix: lock4j # 锁key的前缀，默认为lock4j

    @Lock4j(executor = RedissonLockExecutor.class)
    public Boolean test() {
        return "true";
    }

@Component
public class DynamicLockKeyBuilder extends DefaultLockKeyBuilder {
    @Override
	public String buildKey(MethodInvocation invocation, String[] definitionKeys) {
		String key = super.buildKey(invocation, definitionKeys);
        //需要执行的方法
		return key;
	}
}

@Component
public class MyLockFailureStrategy implements LockFailureStrategy {
    @Override
    public void onLockFailure(String key, long acquireTimeout, int acquireCount) {
    	//需要执行的方法或者业务代码
    }
}

@Service
@AllArgsConstructor
public class SysPaymentInfoServiceImpl extends ServiceImpl<SysPaymentInfoMapper, SysPaymentInfo> implements SysPaymentInfoService {
    private final LockTemplate lockTemplate;
    public void programmaticLock(String userId) {
        // 执行查询业务操作 不上锁
        // 业务区域
        // 获取锁
        final LockInfo lockInfo = lockTemplate.lock(userId, 30000L, 5000L, RedissonLockExecutor.class);
        if (null == lockInfo) {
            throw new RuntimeException("业务处理中,请稍后再试！");
        }
        // 获取锁成功，处理相关业务
        try {
            Console.log("执行简单方法 , 当前线程:" + Thread.currentThread().getName() + " , counter：" + (counter++));
        } finally {
            //释放锁
            lockTemplate.releaseLock(lockInfo);
        }
        //结束
    }

// 用户在5秒内只能访问1次
    @Lock4j(keys = {"#user.id"}, acquireTimeout = 0, expire = 5000, autoRelease = false)
    public Boolean test(User user) {
        return "true";
    }