分布式锁和spring事务管理

最近开发一个小程序遇到一个需求须要实现分布式事务管理

业务需求

用户在使用小程序的过程当中能够查看景点，对景点地区或者城市标记是否想去，那么须要统计一个地点被标记的人数，以及记录某个用户对某个地点是否标记为想去，用两个表存储数据，一个地点表记录改地点被标记的次数，一个用户意向表记录某个用户对某个地点是否标记为想去。因为可能有多个用户同时标记一个地点，每一个用户在前端点击想去按钮以后，后台接收到请求，从数据库查询某个城市的标记人数，再加1，而后更新到数据库。从数据库查询标记人数，再加1，而后更新到数据库这个过程数据库数据必须加锁，一次只能一个进程处理。不然数据会出现不一样步问题

我使用的RedLock作分布式锁管理，用spring注解事务管理。
在实现过程当中遇到以下两个映像深入的问题：
一、分布式锁与spring注解事务共用产生的问题
二、锁在事务提交前超时问题

使用分布式锁RedLock及spring事务实现

最初实现代码以下：

public markScenicSpot(){
  //设置锁为destId
   RLock lock = redisson.getLock("Afanti_markScenicSpot_updateCountwantAndCountbeenLock_" + ID);
   //尝试获取锁
   long lockTimeOut = 30; //持有锁超时时间
   **boolean success = lock.tryLock(5, lockTimeOut, TimeUnit.SECONDS);**
   if (success) {
      try {
          //业务逻辑实现
      }catch (Exception e){
          throw e;
      } finally{
          //释放锁
          **lock.unlock();**
      }
   } else {
       log.error("获取锁失败！更新失败！");
       throw new BizException(ErrorCodeEnum.PROCESS_DATA_ERROR);
   }
 }

问题：高并发是锁没有生效

一、spring注解事务@Transactional和分布式锁不能一块儿使用
这是由于@Transactional是经过方法是否抛出异常来判断事务是否回滚仍是提交，此时方法已经结束。可是咱们必须在方法结束以前释放锁，
所以在释放锁以后，此时还没提交，因为锁已经释放，其余进程能够得到锁，并从数据库查询地点标记数，可是此时前一个进程没有提交数据。该进程查到的数据不是最新的数据。
这个问题我排查的时候花了好久，由于锁释放和提交事务之间只要几毫秒的时间，以前一直觉得这么短的时间不多是这里的问题，有怀疑过可是本身又放弃了
尽管这个过程只要很短的时间（我实际测试过程当中这个过程只要几毫秒），可是高并发的状况仍是会出问题。

解决1：

因为不能使用注解事务，我改成手动事务管理，增长以下代码。

public markScenicSpot(){
   //设置锁为destId
   RLock lock = redisson.getLock("Afanti_markScenicSpot_updateCountwantAndCountbeenLock_" + ID);
   //尝试获取锁
   long lockTimeOut = 30; //持有锁超时时间
   boolean success = lock.tryLock(5, lockTimeOut, TimeUnit.SECONDS);
   if(success){
      **DefaultTransactionDefinition def = new DefaultTransactionDefinition();
      def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); // 事物隔离级别
      TransactionStatus status = transactionManager.getTransaction(def); // 得到事务状态**
      try {
          //业务逻辑实现
          //......
          **//提交事务
          transactionManager.commit(status);**
      }catch (Exception e){
          **//回滚事务
          transactionManager.rollback(status);**
      } finally{
          //释放锁
          lock.unlock();
      }
   } else {
       log.error("获取锁失败！更新失败！");
       throw new BizException(ErrorCodeEnum.PROCESS_DATA_ERROR);
   }
 }

问题：锁超时事物异常

一、锁超时问题
在进行手动事务管理以后，解决的同步问题。可是出现另一个问题，锁超时可是事务仍未提交。因为此时当前进程锁超时可是没有提交，此时其余进程能够得到锁并从数据库查询目的地标记数，可是不是更新以后的数据，取得的数据有误。

解决2：

针对锁超时的状况，只须要当前进程提交以前增长一个判断，判断是否超时，若是超时抛出异常退出便可。
增长以下代码：

public markScenicSpot(){
   //设置锁为destId
   RLock lock = redisson.getLock("Afanti_markScenicSpot_updateCountwantAndCountbeenLock_" + ID);
   //尝试获取锁
   long lockTimeOut = 30; //持有锁超时时间
   boolean success = lock.tryLock(5, lockTimeOut, TimeUnit.SECONDS);
   **//获取锁时间
   long getLockTime=System.currentTimeMillis();**
   if(success){
      //事务管理
      DefaultTransactionDefinition def = new DefaultTransactionDefinition();
      def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); // 事物隔离级别
      TransactionStatus status = transactionManager.getTransaction(def); // 得到事务状态
      try {
          //业务逻辑实现
          //......
          //提交事务,判断锁是否超时
          **if(System.currentTimeMillis()-getLockTime<lockTimeOut*1000){
            transactionManager.commit(status);
            log.info("提交事务");
          } else {
            log.error("异常：程序执行时间过长，锁超时!");
            throw new BizException(ErrorCodeEnum.PROCESS_DATA_ERROR);
          }**
      }catch (Exception e){
          //回滚事务
          transactionManager.rollback(status);
      } finally{
          //释放锁
          lock.unlock();
      }
   } else {
       log.error("获取锁失败！更新失败！");
       throw new BizException(ErrorCodeEnum.PROCESS_DATA_ERROR);
   }
 }

总结

高并发状况下，分布式事务很容易出问题，要对各类状况分析是否可能出问题，并要对全部可能出问题的状况作充分的测试才能保证程序健壮。