Seata 是一款开源的分布式事务解决方案,提供高性能和简单易用的分布式事务服务。
基于 Seata TCC模式,演示分布式事务的提交和回滚;
本demo中一个分布式事务内会有2个TCC事务参与者,分别是: TccActionOne 和 TccActionTwo ;分布式事务提交则两者均提交,分布式事务回滚则两者均回滚;
这2个TCC参与者均是 SofaRpc 远程服务,一个应用实现TCC参与者,并将其发布成 <sofa:service />;
另外一个事务发起方应用,订阅TCC sofa 服务,调用 <sofa:reference /> 编排TCC参与者,执行远程TCC服务;其接口定义如下:
public interface TccActionOne { @TwoPhaseBusinessAction(name = "SofaRpcTccActionOne" , commitMethod = "commit", rollbackMethod = "rollback") public boolean prepare(BusinessActionContext actionContext, int a); public boolean commit(BusinessActionContext actionContext); public boolean rollback(BusinessActionContext actionContext); }
public interface TccActionTwo { @TwoPhaseBusinessAction(name = "SofaRpcTccActionTwo" , commitMethod = "commit", rollbackMethod = "rollback") public boolean prepare(BusinessActionContext actionContext, String b); public boolean commit(BusinessActionContext actionContext); public boolean rollback(BusinessActionContext actionContext); }
运行 SeataServerStarter ,启动 Seata Server;
运行 SofaRpcTccProviderApplication
本应用发布TCC sofa-rpc 服务;
运行 SofaRPCTccTransactionApplication , 启动 demo工程;
本应用订阅TCC sofa-rpc 服务,发起方分布式事务,调用TCC sofa-rpc 参与者;内含TCC 事务提交场景和TCC事务回滚场景的演示;