记录一次Redisson使用synchronized和分布式锁不生效的原因

最近在开发的过程中，遇到了一个并发场景，用户进行方案复制的时候，当快速点击两次操作的时候，出现了复制方案重名的情况，实际上是复制方案的方案名称，是由后端根据数据库已有的方案名称和当前要复制的方案名称进行逻辑处理，保证方案名称不能重复，比如：要复制的方案名称为“我的方案”，那么复制得到的方案名称为“我的方案-副本”，在高并发场景下，就会出现重名情况。

-------江湖-------

1851人浏览 · 2024-05-22 13:19:21

-------江湖------- · 2024-05-22 13:19:21 发布

1. 并发原因

每次在复制方案的时候，会有如下步骤：

首先校验要复制的方案是否存在。
查询所有已经存在的方案的所有名称。
根据要复制方案的名称生成一个新的方案名称，比如“某某方案-副本”。
新生成的方案是否和已存在的方案名称重名，如果重名，则添加后缀，比如“某某方案-副本（2）”。
最终做新方案的落库操作。

不知道大家有没有看到里面在高并发情况下存在的问题，当步骤五还没有落库，就已经有线程2进来，执行了查询操作，最后线程2落库生成的名称就会和线程1生成的方案名称重复。

@Transactional(rollbackFor = Exception.class)
public  void xxxCopy(Long modelId) throws GseException {
    	//业务逻辑代码
}

2. 初步解决办法

2.1 本地锁方式

我在本地做了两种尝试，首先通过本地锁（比如synchronized，Lock）相关手段进行锁定，当然这种肯定不能上生产，因为当多节点部署的时候，这种本地锁没有任何意义。

@Transactional(rollbackFor = Exception.class)
public  void xxxCopy(Long modelId) throws GseException {
    synchronized (this) {
       //业务逻辑代码
    }
}

这种写法没有生效，在我进行本地压测，开启多个线程的情况下，还是出现了重名情况，具体原因我待会会给大家分析。

2.2 分布式锁

这种才是生产上高并发经常会用到的，因为生产时多prod，采用本地锁没有任何意义，分布式锁我采用的是Redisson方案，相比较自己去写分布式锁，更稳定，更成熟。

    @Autowired
    private RedissonClient redissonClient;
    private static final String REDIS_COST_MODEL_ID_LOCK = "redis_cost_model_id_lock";
    
@Transactional(rollbackFor = Exception.class)
public  void xxxCopy(Long modelId) throws GseException {
    RLock lock = redissonClient.getLock(REDIS_COST_MODEL_ID_LOCK + modelId);
        try {
            if (lock.tryLock(20, 2, TimeUnit.SECONDS)) {
                //业务逻辑代码
            } else {
                log.error("获取分布式锁失败");
            }
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        } finally {
            // 判断当前线程是否持有锁
            if (lock.isHeldByCurrentThread()) {
                //释放当前锁
                lock.unlock();
                log.info(Thread.currentThread().getName() + "释放锁" + LocalDateTime.now());
            }
        }
}

但是，这种写法没有生效，在我本地压测的时候，还是存在重名问题。

3. 存在的问题以及原因

问题就是以上两种写法都没有生效，但是为什么呢？
在解释这个问题之前，我们首先要弄清楚两个问题：

@Transactional的底层实现原理，开启事务和提交事务的时机是什么？
分布式锁，和本地锁机制释放锁的时机是什么时候？

3.1 @Transactional的底层实现原理，开启事务和提交事务的时机是什么？

它的底层实现原理主要依赖于 Spring 的面向切面编程（AOP）机制。
底层实现原理

AOP 代理：当一个类或方法被 @Transactional 注解标记时，Spring 容器在初始化 Bean 时会检测到这个注解。对于使用 Spring 的代理模式（如 JDK 动态代理或 CGLIB），Spring 会为该 Bean 创建一个代理对象。这个代理对象会在调用实际方法前后插入事务管理相关的代码，即在方法执行前开启事务，在方法执行完毕后根据执行情况提交或回滚事务。
解析注解：Spring 通过扫描 Bean 定义，识别出带有 @Transactional 注解的方法或类，并配置相应的事务属性，如传播行为、隔离级别、超时时间、是否只读等。
事务拦截器：Spring 使用 AOP 机制中的拦截器（Interceptor）或Advice（通常为 TransactionInterceptor 或 AspectJ 的切面），在方法调用前后织入事务处理逻辑。在方法调用前，根据事务属性设置事务的开始；在方法正常结束时提交事务，如果方法抛出未检查异常（继承自 RuntimeException 的异常）或已检查异常（被 @Transactional 的 rollbackFor 属性指定的异常）则回滚事务。

开启事务和提交事务的时机

开启事务：事务通常在进入被 @Transactional 注解的方法之前立即开始。这意味着在执行业务逻辑之前，Spring 会确保与当前环境匹配的事务上下文已经建立。这包括选择合适的事务管理器，根据事务属性配置事务的隔离级别、传播行为等，并在数据库中实际开启事务。
提交事务：如果被注解的方法正常执行结束，没有抛出任何异常，Spring 会在离开该方法之前提交事务。提交事务意味着将所有挂起的更改永久化到数据库中，使事务中的所有操作对外可见。
回滚事务：如果在被注解的方法执行过程中抛出了异常，并且该异常未被 @Transactional 的 noRollbackFor 属性豁免，Spring 将在捕获到异常后立即回滚事务，撤销所有在事务中已完成但未提交的操作，保持数据的一致性。

3.2 分布式锁，和本地锁机制释放锁的时机是什么时候？

答案是：本地锁，如果是synchronized，看你包裹起来的范围。Lock的话看你手动释放锁的时候。
分布式锁：看你手动释放锁的时候。

那么造成问题的原因就出来了，如下图：

在这里插入图片描述
也就是说最终提交事务和释放锁的顺序有问题，按照上面的代码写法，因为当只有方法执行完了，AOP切面才会提交事务，那么如果你将上锁的代码写到被@Transactional注解的方法里面，那么提交事务永远都会处于释放锁之后，那么在释放锁之后，提交事务之前的这段时间，就会有并发问题。

4. 正确的写法

4.1 本地锁

    public  void addLock(Long modelId)throws GseException {
        synchronized (this) {
            xxxCopy(modelId);
        }
    }
    
    @Transactional(rollbackFor = Exception.class)
	public  void xxxCopy(Long modelId) throws GseException {
	    synchronized (this) {
	       //业务逻辑代码
	    }
	}

4.2 分布式锁

public void addLock(Long modelId) throws GseException {
        RLock lock = redissonClient.getLock(REDIS_COST_MODEL_ID_LOCK + modelId);
        try {
            if (lock.tryLock(20, 2, TimeUnit.SECONDS)) {
                xxxCopy(modelId);
            } else {
                log.error("获取分布式锁失败");
            }
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        } finally {
            // 判断当前线程是否持有锁
            if (lock.isHeldByCurrentThread()) {
                //释放当前锁
                lock.unlock();
                log.info(Thread.currentThread().getName() + "释放锁" + LocalDateTime.now());
            }
        }

    }

@Transactional(rollbackFor = Exception.class)
public  void xxxCopy(Long modelId) throws GseException {
    synchronized (this) {
       //业务逻辑代码
    }
}