TCC是Try、Confirm、Cancel三个词语的缩写,TCC要求每一个分支事务实现三个操做 :预处理Try、确认Confirm、撤销Cancel。Try操做作业务检查及资源预留,Confirm作业务确认操做,Cancel实现一个与Try相反的操做既回滚操做。TM首先发起全部的分支事务的try操做,任何一个分支事务的try操做执行失败,TM将会发起全部分支事务的Cancel操做,若try操做所有成功,TM将会发起全部分支事务的Confirm操做,其中Confirm/Cancel操做若执行失败,TM会进行重试。
分支事务失败的状况 :
TCC分为三个阶段 :html
目前市面上的TCC框架众多好比下面这几种 :
Seata也支持TCC,但Seata的TCC模式对Spring Cloud并无提供支持。咱们的目标是理解TCC原理以及事务协调运做的过程,所以更倾向于轻量级易于理解的框架。
Hmily是一个高性能分布式事务TCC开源框架。基于Java语言来开发(JDK1.8),支持Dubbo,Spring Cloud等RPC框架进行分布式事务。它目前支持如下特性 :java
try: 检查余额是否够30元 扣减30元 confirm: 空 cancel: 增长30元
帐户Bmysql
try: 增长30元 confirm: 空 cancel: 减小30元
方案1说明:
1)帐户A,这里的余额就是所谓的业务资源,按照前面提到的原则,在第一阶段须要检查并预留业务资源,所以, 咱们在扣钱 TCC 资源的 Try 接口里先检查 A 帐户余额是否足够,若是足够则扣除 30 元。 Confirm 接口表示正式 提交,因为业务资源已经在 Try 接口里扣除掉了,那么在第二阶段的 Confirm 接口里能够什么都不用作。Cancel 接口的执行表示整个事务回滚,帐户A回滚则须要把 Try 接口里扣除掉的 30 元还给帐户。
2)帐号B,在第一阶段 Try 接口里实现给帐户B加钱,Cancel 接口的执行表示整个事务回滚,帐户B回滚则须要把 Try 接口里加的 30 元再减去。
方案1的问题分析:
1)若是帐户A的try没有执行在cancel则就多加了30元。
2)因为try,cancel、confirm都是由单独的线程去调用,且会出现重复调用,因此都须要实现幂等。
3)帐号B在try中增长30元,当try执行完成后可能会其它线程给消费了。
4)若是帐户B的try没有执行在cancel则就多减了30元。
问题解决:
1)帐户A的cancel方法须要判断try方法是否执行,正常执行try后方可执行cancel。
2)try、cancel、confirm方法实现幂等。
3)帐户B在try方法中不容许更新帐户金额,在confirm中更新帐户金额。
4)帐户B的cancel方法须要判断try方法是否执行,正常执行try后方可执行cancel。
优化方案:
帐户A :web
try: try幂等校验 try悬挂处理 检查余额是否够30元 扣减30元 confirm: 空 cancel: cancel幂等校验 cancel空回滚处理 增长可用余额30元
帐户B :redis
try: 空 confirm: confirm幂等校验 正式增长30元 cancel: 空
经过Hmily实现TCC分布式事务,模拟两个帐户的转帐交易过程。
两个帐户分别在不一样的银行(张三在bank一、李四在bank2),bank一、bank2是两个微服务。交易过程是,张三给李四转帐制定金额。
上述交易步骤,要么一块儿成功,要么一块儿失败,必须是一个总体性事务。spring
数据库:MySQL-5.7.25
JDK:64位 jdk1.8.0_201 微服务:spring-boot-2.1.三、spring-cloud-Greenwich.RELEASE Hmily:hmily-springcloud.2.0.4-RELEASE
微服务及数据库的关系 :
dtx/dtx-tcc-demo/dtx-tcc-demo-bank1 银行1,操做张三帐户, 链接数据库bank1 dtx/dtx-tcc-demo/dtx-tcc-demo-bank2 银行2,操做李四帐户,链接数据库bank2
服务注册中心:dtx/discover-serversql
建立hmily数据库,用于存储hmily框架记录的数据。
CREATE DATABASE hmily
CHARACTER SET ‘utf8’ COLLATE ‘utf8_general_ci’;
建立bank1库,并导入如下表结构和数据(包含张三帐户)
CREATE DATABASE bank1
CHARACTER SET ‘utf8’ COLLATE ‘utf8_general_ci’;
建立bank2库,并导入如下表结构和数据(包含李四帐户)
CREATE DATABASE bank2
CHARACTER SET ‘utf8’ COLLATE ‘utf8_general_ci’;
DROP TABLE IF EXISTS account_info
; CREATE TABLE account_info
(id
bigint(20) NOT NULL AUTO_INCREMENT,account_name
varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT ‘户 主姓名’,account_no
varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT ‘银行 卡号’,account_password
varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT ‘账户密码’,account_balance
double NULL DEFAULT NULL COMMENT ‘账户余额’,
PRIMARY KEY (id
) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT = Dynamic;
INSERT INTO account_info
VALUES (2, ‘张三的帐户’, ‘1’, ‘’, 10000);
每一个数据库都建立try、confirm、cancel三张日志表:mongodb
CREATE TABLE `local_try_log` ( `tx_no` varchar(64) NOT NULL COMMENT `create_time` datetime DEFAULT NULL, PRIMARY KEY (`tx_no`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 CREATE TABLE `local_confirm_log` ( `tx_no` varchar(64) NOT NULL COMMENT `create_time` datetime DEFAULT NULL ) ENGINE=InnoDB DEFAULT CHARSET=utf8 CREATE TABLE `local_cancel_log` ( `tx_no` varchar(64) NOT NULL COMMENT `create_time` datetime DEFAULT NULL, PRIMARY KEY (`tx_no`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8
(1)引入maven依赖数据库
<dependency> <groupId>org.dromara</groupId> <artifactId>hmily‐springcloud</artifactId> <version>2.0.4‐RELEASE</version> </dependency>
(2)配置hmily
application.yml :网络
org: dromara: hmily : serializer : kryo recoverDelayTime : 128 retryMax : 30 scheduledDelay : 128 scheduledThreadMax : 10 repositorySupport : db started: true hmilyDbConfig : driverClassName : com.mysql.jdbc.Driver url : jdbc:mysql://localhost:3306/bank?useUnicode=true username : root password : root
新增配置类接收application.yml中的Hmily配置信息,并建立HmilyTransactionBootstrap Bean:
@Bean public HmilyTransactionBootstrap hmilyTransactionBootstrap(HmilyInitService hmilyInitService){ HmilyTransactionBootstrap hmilyTransactionBootstrap = new HmilyTransactionBootstrap(hmilyInitService); hmilyTransactionBootstrap.setSerializer(env.getProperty("org.dromara.hmily.serializer")); hmilyTransactionBootstrap.setRecoverDelayTime(Integer.parseInt(env.getProperty("org.dromara.hmily.recoverDelayTime"))); hmilyTransactionBootstrap.setRetryMax(Integer.parseInt(env.getProperty("org.dromara.hmily.retryMax"))); hmilyTransactionBootstrap.setScheduledDelay(Integer.parseInt(env.getProperty("org.dromara.hmily.scheduledDelay"))); hmilyTransactionBootstrap.setScheduledThreadMax(Integer.parseInt(env.getProperty("org.dromara.hmily.scheduledThreadMax"))); hmilyTransactionBootstrap.setRepositorySupport(env.getProperty("org.dromara.hmily.repositorySupport")); hmilyTransactionBootstrap.setStarted(Boolean.parseBoolean(env.getProperty("org.dromara.hmily.started"))); HmilyDbConfig hmilyDbConfig = new HmilyDbConfig(); hmilyDbConfig.setDriverClassName(env.getProperty("org.dromara.hmily.hmilyDbConfig.driverClassName")); hmilyDbConfig.setUrl(env.getProperty("org.dromara.hmily.hmilyDbConfig.url")); hmilyDbConfig.setUsername(env.getProperty("org.dromara.hmily.hmilyDbConfig.username")); hmilyDbConfig.setPassword(env.getProperty("org.dromara.hmily.hmilyDbConfig.password")); hmilyTransactionBootstrap.setHmilyDbConfig(hmilyDbConfig); return hmilyTransactionBootstrap; }
启动类增长@EnableAspectJAutoProxy并增长org.dromara.hmily的扫描项:
@SpringBootApplication @EnableDiscoveryClient @EnableHystrix @EnableFeignClients(basePackages = {"cn.itcast.dtx.tccdemo.bank1.spring"}) @ComponentScan({"cn.itcast.dtx.tccdemo.bank1","org.dromara.hmily"}) public class Bank1HmilyServer { public static void main(String[] args) { SpringApplication.run(Bank1HmilyServer.class, args); } }
dtx-tcc-demo-bank1实现try和cancel方法,以下 :
try: try幂等校验 try悬挂处理 检查余额是够扣减金额 扣减金额 confirm: 空 cancel: cancel幂等校验 cancel空回滚处理 增长可用余额
@Mapper @Component public interface AccountInfoDao { @Update("update account_info set account_balance=account_balance - #{amount} where account_balance>=#{amount} and account_no=#{accountNo} ") int subtractAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount); @Update("update account_info set account_balance=account_balance + #{amount} where account_no=#{accountNo} ") int addAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount); /** * 增长某分支事务try执行记录 * @param localTradeNo 本地事务编号 * @return */ @Insert("insert into local_try_log values(#{txNo},now());") int addTry(String localTradeNo); @Insert("insert into local_confirm_log values(#{txNo},now());") int addConfirm(String localTradeNo); @Insert("insert into local_cancel_log values(#{txNo},now());") int addCancel(String localTradeNo); /** * 查询分支事务try是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_try_log where tx_no = #{txNo} ") int isExistTry(String localTradeNo); /** * 查询分支事务confirm是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_confirm_log where tx_no = #{txNo} ") int isExistConfirm(String localTradeNo); /** * 查询分支事务cancel是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_cancel_log where tx_no = #{txNo} ") int isExistCancel(String localTradeNo); }
2)try和cancel方法
@Slf4j @Service public class AccountInfoServiceImpl implements AccountInfoService { @Autowired private AccountInfoDao accountInfoDao; @Autowired private Bank2Client bank2Client; /** * 只要标记@Hmily就是try方法,在注解中指定confirm、cancel两个方法的名字 * * @param accountNo * @param amount */ @Hmily(confirmMethod = "commit", cancelMethod = "rollback") @Transactional(rollbackFor = Exception.class) @Override public void updateAccountBalance(String accountNo, Double amount) { // 事务id String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank1 Service begin try ..." + transId); int existTry = accountInfoDao.isExistTry(transId); // 幂等判断 判断local_try_log表中是否有try日志记录,若是有再也不执行 // try幂等校验 if (existTry > 0) { log.info("Bank1 Service 已经执行try,无需重复执行,事务id :{}", transId); return; } // try悬挂处理,若是cancel、confirm有一个已经执行了,try再也不执行 if (accountInfoDao.isExistCancel(transId) > 0 || accountInfoDao.isExistConfirm(transId) > 0) { log.info("Bank1 Service 已经执行confirm或cancel,悬挂处理,事务id :{}", transId); return; } // 从帐户扣减 if (accountInfoDao.subtractAccountBalance(accountNo, amount) <= 0) { // 扣减失败 throw new HmilyRuntimeException("bank1 exception, 扣减失败,事务id :{}" + transId); } // 增长本地事务try成功记录,用于幂等性控制标识 accountInfoDao.addTry(transId); // 远程调用bank2 if (bank2Client.transfer(amount)) { throw new HmilyRuntimeException("bank2Client exception,事务id:{}"+transId); } // 异常必定要抛在Hmily里面 if (amount == 10) { throw new RuntimeException("Bank2 make exception 10"); } log.info("Bank2 Service end try .." + transId); } @Transactional(rollbackFor = Exception.class) public void commit(String accountNo, double amount) { String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank1 Service begin commit .." + transId); } @Transactional(rollbackFor = Exception.class) public void rollback(String accountNo, double amount) { String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank1 Service begin rollback..." + transId); // 空回滚处理,try阶段没有执行什么也不用作。 if (accountInfoDao.isExistTry(transId) == 0) { log.info("Bank1 try 阶段失败 。。无需rollback " + transId); return; } // 幂等性校验,已经执行过了,什么也不用作 if (accountInfoDao.isExistCancel(transId) > 0) { log.info("Bank1 已经执行过rollback 。。无需再次rollback " + transId); return; } // 再将金额加回帐户 accountInfoDao.addAccountBalance(accountNo, amount); // 添加cancel日志,用于幂等性控制标识 accountInfoDao.addCancel(transId); log.info("Bank1 Service end rollback ... " + transId); } }
3)feignClient
@FeignClient(value = "seata-demo-bank2", fallback = Bank2Client.class) public interface Bank2Client { @GetMapping("/bank2/transfer") @Hmily Boolean transfer(@RequestParam("amount") Double amount); }
@RestController public class Bank1Controller { @Autowired private AccountInfoService accountInfoService; @RequestMapping("/transfer") public String test(@RequestParam("amount") Double amount) { accountInfoService.updateAccountBalance("1", amount); return "bank1" + amount; } }
dtx-tcc-demo-bank2实现以下功能 :
try: 空 confirm: confirm幂等校验 正式增长金额 cancel: 空
1)Dao
@Component @Mapper public interface AccountInfoDao { @Update("update account_info set account_balance=account_balance + #{amount} where account_no=#{accountNo} ") int addAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount); /** * 增长某分支事务try执行记录 * @param localTradeNo 本地事务编号 * @return */ @Insert("insert into local_try_log values(#{txNo},now());") int addTry(String localTradeNo); @Insert("insert into local_confirm_log values(#{txNo},now());") int addConfirm(String localTradeNo); @Insert("insert into local_cancel_log values(#{txNo},now());") int addCancel(String localTradeNo); /** * 查询分支事务try是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_try_log where tx_no = #{txNo} ") int isExistTry(String localTradeNo); /** * 查询分支事务confirm是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_confirm_log where tx_no = #{txNo} ") int isExistConfirm(String localTradeNo); /** * 查询分支事务cancel是否已执行 * @param localTradeNo 本地事务编号 * @return */ @Select("select count(1) from local_cancel_log where tx_no = #{txNo} ") int isExistCancel(String localTradeNo); }
2)实现confirm方法
@Slf4j @Service public class AccountInfoServiceImpl implements AccountInfoService { @Autowired private AccountInfoDao accountInfoDao; @Transactional(rollbackFor = Exception.class) @Hmily(confirmMethod = "confirmMethod", cancelMethod = "cancelMethod") @Override public void updateAccountBalance(String accountNo, Double amount) { String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank2 Service Begin try ... " + transId); } @Transactional(rollbackFor = Exception.class) public void confirmMethod(String accountNo, Double amount) { String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank2 Service commit ..." + transId); // 幂等性校验,已经执行过了,什么也不用作 if (accountInfoDao.isExistConfirm(transId) > 0) { log.info("Bank2 已经执行过confirm 。。无需再次confirm " + transId); return; } // 正式增长金额 accountInfoDao.addAccountBalance(accountNo, amount); // 添加confirm日志 accountInfoDao.addConfirm(transId); } @Transactional(rollbackFor = Exception.class) public void cancelMethod(String accountNo, Double amount) { String transId = HmilyTransactionContextLocal.getInstance().get().getTransId(); log.info("Bank2 Service begin cancel ... " + transId); } }
3)Controller
@RestController public class Bank2Controller { @Autowired private AccountInfoService accountInfoService; @RequestMapping("/transfer") public Boolean test2(@RequestParam("amount") Double amount) { accountInfoService.updateAccountBalance("2", amount); return true; } }
若是拿TCC事务的处理流程与2PC两阶段提交作比较,2PC一般都是在跨库的DB层面,而TCC则在应用层面的处 理,须要经过业务逻辑来实现。这种分布式事务的实现方式的优点在于,可让应用本身定义数据操做的粒度,使得下降锁冲突、提升吞吐量成为可能。而不足之处则在于对应用的侵入性很是强,业务逻辑的每一个分支都须要实现try、confirm、cancel三个操做。此外,其实现难度也比较大,须要按照网络状态、系统故障等不一样的失败缘由实现不一样的回滚策略。