TCC 分布式事务解决方案

 1 @Service
 2 @Slf4j
 3 public class AccountInfoServiceImpl implements AccountInfoService {
 4 
 5     @Autowired
 6     AccountInfoDao accountInfoDao;
 7 
 8     @Autowired
 9     Bank2Client bank2Client;
10 
11     // 账户扣款，就是tcc的try方法
12 
13     /**
14      *     try幂等校验
15      *     try悬挂处理
16      *     检查余额是够扣减金额
17      *     扣减金额
18      * @param accountNo
19      * @param amount
20      */
21     @Override
22     @Transactional
23     //只要标记@Hmily就是try方法，在注解中指定confirm、cancel两个方法的名字
24     @Hmily(confirmMethod="commit",cancelMethod="rollback")
25     public void updateAccountBalance(String accountNo, Double amount) {
26         //获取全局事务id
27         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
28         log.info("bank1 try begin 开始执行...xid:{}",transId);
29         //幂等判断 判断local_try_log表中是否有try日志记录，如果有则不再执行
30         if(accountInfoDao.isExistTry(transId)>0){
31             log.info("bank1 try 已经执行，无需重复执行,xid:{}",transId);
32             return ;
33         }
34 
35         //try悬挂处理，如果cancel、confirm有一个已经执行了，try不再执行
36         if(accountInfoDao.isExistConfirm(transId)>0 || accountInfoDao.isExistCancel(transId)>0){
37             log.info("bank1 try悬挂处理  cancel或confirm已经执行，不允许执行try,xid:{}",transId);
38             return ;
39         }
40 
41         //扣减金额
42         if(accountInfoDao.subtractAccountBalance(accountNo, amount)<=0){
43             //扣减失败
44             throw new RuntimeException("bank1 try 扣减金额失败,xid:{}"+transId);
45         }
46         //插入try执行记录,用于幂等判断
47         accountInfoDao.addTry(transId);
48 
49         //远程调用李四，转账
50         if(!bank2Client.transfer(amount)){
51             throw new RuntimeException("bank1 远程调用李四微服务失败,xid:{}"+transId);
52         }
53         if(amount == 2){
54             throw new RuntimeException("人为制造异常,xid:{}"+transId);
55         }
56         log.info("bank1 try end 结束执行...xid:{}",transId);
57     }
58 
59     //confirm方法
60     @Transactional
61     public void commit(String accountNo, Double amount){
62         //获取全局事务id
63         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
64         log.info("bank1 confirm begin 开始执行...xid:{},accountNo:{},amount:{}",transId,accountNo,amount);
65     }
66 
67     /** cancel方法
68      *     cancel幂等校验
69      *     cancel空回滚处理
70      *     增加可用余额
71      * @param accountNo
72      * @param amount
73      */
74     @Transactional
75     public void rollback(String accountNo, Double amount){
76         //获取全局事务id
77         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
78         log.info("bank1 cancel begin 开始执行...xid:{}",transId);
79         //    cancel幂等校验
80         if(accountInfoDao.isExistCancel(transId)>0){
81             log.info("bank1 cancel 已经执行，无需重复执行,xid:{}",transId);
82             return ;
83         }
84         //cancel空回滚处理，如果try没有执行，cancel不允许执行
85         if(accountInfoDao.isExistTry(transId)<=0){
86             log.info("bank1 空回滚处理，try没有执行，不允许cancel执行,xid:{}",transId);
87             return ;
88         }
89         //    增加可用余额
90         accountInfoDao.addAccountBalance(accountNo,amount);
91         //插入一条cancel的执行记录
92         accountInfoDao.addCancel(transId);
93         log.info("bank1 cancel end 结束执行...xid:{}",transId);
94     }
95 }

 1 @Service
 2 @Slf4j
 3 public class AccountInfoServiceImpl implements AccountInfoService {
 4 
 5     @Autowired
 6     AccountInfoDao accountInfoDao;
 7 
 8     @Override
 9     @Hmily(confirmMethod="confirmMethod", cancelMethod="cancelMethod")
10     public void updateAccountBalance(String accountNo, Double amount) {
11         //获取全局事务id
12         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
13         log.info("bank2 try begin 开始执行...xid:{}",transId);
14     }
15 
16     /**
17      * confirm方法
18      *     confirm幂等校验
19      *     正式增加金额
20      * @param accountNo
21      * @param amount
22      */
23     @Transactional
24     public void confirmMethod(String accountNo, Double amount){
25         //获取全局事务id
26         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
27         log.info("bank2 confirm begin 开始执行...xid:{}",transId);
28         if(accountInfoDao.isExistConfirm(transId)>0){
29             log.info("bank2 confirm 已经执行，无需重复执行...xid:{}",transId);
30             return ;
31         }
32         //增加金额
33         accountInfoDao.addAccountBalance(accountNo,amount);
34         //增加一条confirm日志，用于幂等
35         accountInfoDao.addConfirm(transId);
36         log.info("bank2 confirm end 结束执行...xid:{}",transId);
37     }
38 
39     /**
40      * @param accountNo
41      * @param amount
42      */
43     public void cancelMethod(String accountNo, Double amount){
44         //获取全局事务id
45         String transId = HmilyTransactionContextLocal.getInstance().get().getTransId();
46         log.info("bank2 cancel begin 开始执行...xid:{}",transId);
47 
48     }
49 }