最佳实践-轻量级事务编程(绕开事务失效的坑)1、代码中开启事务常见问题2、推荐方案3、总结

104 阅读 0 评论 69 点赞

我是靠谱客的博主阳光香水，这篇文章主要介绍最佳实践-轻量级事务编程(绕开事务失效的坑)1、代码中开启事务常见问题2、推荐方案3、总结，现在分享给大家，希望可以做个参考。

1、代码中开启事务常见问题

现象：方法加了@Transactional，同类中方法调用，事务未生效。

原因：采用Spring aop注解事务方式，同类中方法调用不会进入AOP拦截。

2、推荐方案

1、定义动作执行接口

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
@FunctionalInterface
public interface IActionService {

   /**
    * 动作执行接口 
    * 事务  多线程 等可以封装
    * 
    */
   void doAction();
}

2、定义事务拦截服务类

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
/**
 * 事务处理
 * @author peter
 *
 */
@Transactional
@Service
public class TransactionService {
   
   /**
    * 执行事务代码
    */

   public void service(IActionService transaction) {
      transaction.doAction();
   }
   
}

3、项目中lambda表达方式方式应用

复制代码

transactionService.service(() -> {
               // 这当中是事务处理
               // 计算积分 考虑加速
               Integer points = pointGiveService.reducePoints(current);
                              
               // 考虑并发 做增量更新
               McMemberInfo updateMi = new McMemberInfo();
               updateMi.setId(mi.getId());
               updateMi.setMemberLevelCode(finalMemberLevel.getMemberLevelCode());// 等级编码
               updateMi.setLevelAlias(finalMemberLevel.getMemberLevelName());// 等级别名
               updateMi.setLevelAliasName(finalMemberLevel.getMemberLevelNickName());// 等级中文别名
               updateMi.setCurrentGrowthValue(levelInfo.getGrowthValue() - mi.getCurrentGrowthValue());// 成长值更新  增量
               updateMi.setCurrentRatingValue(levelInfo.getLevelValue() - mi.getCurrentRatingValue());// 定级值更新 增量
               updateMi.setCurrentApplePoints(0 - points);// 更新苹果积分 扣减积分 增量
               updateMi.setUpdated(DateUtil.currentDate());// 更新日期
               updateMi.setLevelDueDate(getLevelDueDate(conf));// 设置等级到期日
            
               // 增量更新
               memberInfoService.updateWithIncre(updateMi);
               
               
               // 中间锁状态 调整为最终锁状态 即已处理状态
               lockMiddleToFinalStatus(current.getNumber());
            });

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
transactionService.service(() -> {
               // 这当中是事务处理
               // 计算积分 考虑加速
               Integer points = pointGiveService.reducePoints(current);
                              
               // 考虑并发 做增量更新
               McMemberInfo updateMi = new McMemberInfo();
               updateMi.setId(mi.getId());
               updateMi.setMemberLevelCode(finalMemberLevel.getMemberLevelCode());// 等级编码
               updateMi.setLevelAlias(finalMemberLevel.getMemberLevelName());// 等级别名
               updateMi.setLevelAliasName(finalMemberLevel.getMemberLevelNickName());// 等级中文别名
               updateMi.setCurrentGrowthValue(levelInfo.getGrowthValue() - mi.getCurrentGrowthValue());// 成长值更新  增量
               updateMi.setCurrentRatingValue(levelInfo.getLevelValue() - mi.getCurrentRatingValue());// 定级值更新 增量
               updateMi.setCurrentApplePoints(0 - points);// 更新苹果积分 扣减积分 增量
               updateMi.setUpdated(DateUtil.currentDate());// 更新日期
               updateMi.setLevelDueDate(getLevelDueDate(conf));// 设置等级到期日
            
               // 增量更新
               memberInfoService.updateWithIncre(updateMi);
               
               
               // 中间锁状态 调整为最终锁状态 即已处理状态
               lockMiddleToFinalStatus(current.getNumber());
            });