Seata 是一款开源的分布式事务解决方案,提供高性能和简单易用的分布式事务服务。
基于 Seata TCC模式,以转账场景为例,演示分布式事务的提交和回滚;
本demo中一个分布式事务内会有2个TCC事务参与者,分别是: FirstTccAction 和 SecondTccAction ;
FirstTccAction 实现了转账服务中的扣款TCC服务,SecondTccAction 实现了转账服务中的存款TCC服务;
这2个TCC参与者均是 dubbo远程服务,一个应用(TransferProviderStarter)实现TCC参与者,并将其发布成 <dubbo:service />;
另外一个事务发起方应用(TransferApplication),订阅TCC dubbo服务,调用 <dubbo:reference /> 编排TCC参与者,执行远程TCC服务;
public interface FirstTccAction { @TwoPhaseBusinessAction(name = "firstTccAction", commitMethod = "commit", rollbackMethod = "rollback") public boolean prepare_minus(BusinessActionContext businessActionContext, @BusinessActionContextParameter(paramName = "accountNo") String accountNo, @BusinessActionContextParameter(paramName = "amount") double amount); public boolean commit(BusinessActionContext businessActionContext); public boolean rollback(BusinessActionContext businessActionContext); }
public interface SecondTccAction { @TwoPhaseBusinessAction(name = "secondTccAction", commitMethod = "commit", rollbackMethod = "rollback") public boolean prepare_add(BusinessActionContext businessActionContext, @BusinessActionContextParameter(paramName = "accountNo") String accountNo, @BusinessActionContextParameter(paramName = "amount") double amount); public boolean commit(BusinessActionContext businessActionContext); public boolean rollback(BusinessActionContext businessActionContext); }
运行 SeataServerStarter ,启动 Seata Server;
本应用发布TCC dubbo服务;
运行 TransferApplication , 启动 demo工程;
本应用订阅TCC dubbo服务,发起方分布式事务,调用TCC dubbo参与者,完成转账;内含转账事务提交(doTransferSuccess)场景和转账事务回滚(doTransferFailed)场景的演示;