![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250523101330-68304a4a6248d.png\")
<\/p>\n<\/p>\n\u5927\u7eb2<\/p>\n
1.Seata TCC\u5206\u5e03\u5f0f\u4e8b\u52a1\u6848\u4f8b\u914d\u7f6e<\/p>\n
2.Seata TCC\u6848\u4f8b\u670d\u52a1\u63d0\u4f9b\u8005\u542f\u52a8\u5206\u6790<\/p>\n
3.@TwoPhaseBusinessAction\u6ce8\u89e3\u626b\u63cf\u6e90\u7801<\/p>\n
4.Seata TCC\u6848\u4f8b\u5206\u5e03\u5f0f\u4e8b\u52a1\u5165\u53e3\u5206\u6790<\/p>\n
5.TCC\u6838\u5fc3\u6ce8\u89e3\u626b\u63cf\u4e0e\u4ee3\u7406\u521b\u5efa\u5165\u53e3\u6e90\u7801<\/p>\n
6.TCC\u52a8\u6001\u4ee3\u7406\u62e6\u622a\u5668TccActionInterceptor<\/p>\n
7.Action\u62e6\u622a\u5904\u7406\u5668ActionInterceptorHandler<\/p>\n
8.Seata TCC\u5206\u5e03\u5f0f\u4e8b\u52a1\u7684\u6ce8\u518c\u63d0\u4ea4\u56de\u6eda\u5904\u7406\u6e90\u7801<\/p>\n<\/p>\n
1.Seata TCC\u5206\u5e03\u5f0f\u4e8b\u52a1\u6848\u4f8b\u914d\u7f6e<\/p>\n
(1)\u4f4d\u4e8eseata-samples\u7684tcc\u6a21\u5757\u4e0b\u7684Demo\u5de5\u7a0b<\/p>\n
(2)Demo\u5de5\u7a0b\u7684\u914d\u7f6e\u6587\u4ef6<\/p>\n
(3)Demo\u5de5\u7a0b\u8fd0\u884c\u8bf4\u660e<\/p>\n<\/p>\n
(1)\u4f4d\u4e8eseata-samples\u7684tcc\u6a21\u5757\u4e0b\u7684Demo\u5de5\u7a0b<\/p>\n
dubbo-tcc-sample\u6a21\u5757\u4e3b\u8981\u6f14\u793a\u4e86TCC\u6a21\u5f0f\u4e0b\u5206\u5e03\u5f0f\u4e8b\u52a1\u7684\u63d0\u4ea4\u548c\u56de\u6eda\u3002\u8be5Demo\u4e2d\u4e00\u4e2a\u5206\u5e03\u5f0f\u4e8b\u52a1\u5185\u4f1a\u6709\u4e24\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005，\u8fd9\u4e24\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005\u5206\u522b\u662fTccActionOne\u548cTccActionTwo\u3002\u5206\u5e03\u5f0f\u4e8b\u52a1\u63d0\u4ea4\u5219\u4e24\u8005\u5747\u63d0\u4ea4，\u5206\u5e03\u5f0f\u4e8b\u52a1\u56de\u6eda\u5219\u4e24\u8005\u5747\u56de\u6eda\u3002<\/p>\n<\/p>\n
\u8fd9\u4e24\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005\u5747\u662fDubbo\u8fdc\u7a0b\u670d\u52a1\u3002\u4e00\u4e2a\u5e94\u7528\u4f5c\u4e3a\u670d\u52a1\u63d0\u4f9b\u65b9，\u4f1a\u5b9e\u73b0\u8fd9\u4e24\u4e2aTCC\u53c2\u4e0e\u8005，\u5e76\u5c06\u5b83\u4eec\u53d1\u5e03\u6210Dubbo\u670d\u52a1\u3002\u53e6\u5916\u4e00\u4e2a\u5e94\u7528\u4f5c\u4e3a\u4e8b\u52a1\u53d1\u8d77\u65b9，\u4f1a\u8ba2\u9605Dubbo\u670d\u52a1，\u7136\u540e\u8c03\u7528\u7f16\u6392TCC\u53c2\u4e0e\u8005，\u6267\u884c\u8fdc\u7a0bDubbo\u670d\u52a1\u3002<\/p>\n<\/p>\n
TccActionOne\u63a5\u53e3\u5b9a\u4e49\u5982\u4e0b：<\/p>\n
public interface TccActionOne {
\n @TwoPhaseBusinessAction(name = "DubboTccActionOne", commitMethod = "commit", rollbackMethod = "rollback")
\n public boolean prepare(BusinessActionContext actionContext,
\n @BusinessActionContextParameter(paramName = "a") int a);
\n public boolean commit(BusinessActionContext actionContext);
\n public boolean rollback(BusinessActionContext actionContext);
\n} <\/p>\n
TccActionTwo\u63a5\u53e3\u5b9a\u4e49\u5982\u4e0b：<\/p>\n
public interface TccActionTwo {
\n @TwoPhaseBusinessAction(name = "DubboTccActionTwo", commitMethod = "commit", rollbackMethod = "rollback")
\n public boolean prepare(BusinessActionContext actionContext,
\n @BusinessActionContextParameter(paramName = "b") String b,
\n @BusinessActionContextParameter(paramName = "c", index = 1) List list);
\n public boolean commit(BusinessActionContext actionContext);
\n public boolean rollback(BusinessActionContext actionContext);
\n} <\/p>\n
(2)Demo\u5de5\u7a0b\u7684\u914d\u7f6e\u6587\u4ef6<\/p>\n
\u4e00.seata-tcc.xml<\/p>\n
<beans xmlns:xsi="http:\/\/www.w3.org\/2001\/XMLSchema-instance"
\n xmlns="http:\/\/www.springframework.org\/schema\/beans"
\n xsi:schemaLocation="http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd"
\n default-autowire="byName"><\/p>\n
<!– fescar bean scanner –>
\n <bean class="io.seata.spring.annotation.GlobalTransactionScanner">
\n <constructor-arg value="tcc-sample"\/>
\n <constructor-arg value="my_test_tx_group"\/>
\n <\/bean><\/p>\n
<bean id="tccActionOneImpl" class="io.seata.samples.tcc.dubbo.action.impl.TccActionOneImpl"\/>
\n <bean id="tccActionTwoImpl" class="io.seata.samples.tcc.dubbo.action.impl.TccActionTwoImpl"\/>
\n <bean id="tccTransactionService" class="io.seata.samples.tcc.dubbo.service.TccTransactionService"\/>
\n<\/beans> <\/p>\n
\u4e8c.seata-dubbo-provider.xml<\/p>\n
<beans xmlns:xsi="http:\/\/www.w3.org\/2001\/XMLSchema-instance"
\n xmlns:dubbo="http:\/\/code.alibabatech.com\/schema\/dubbo"
\n xmlns="http:\/\/www.springframework.org\/schema\/beans"
\n xsi:schemaLocation="http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd
\n http:\/\/code.alibabatech.com\/schema\/dubbo
\n http:\/\/code.alibabatech.com\/schema\/dubbo\/dubbo.xsd" default-autowire="byName">
\n <dubbo:application name="tcc-sample">
\n <dubbo:parameter key="qos.enable" value="false"\/>
\n <\/dubbo:application><\/p>\n
<!–\u4f7f\u7528 zookeeper \u6ce8\u518c\u4e2d\u5fc3\u66b4\u9732\u670d\u52a1，\u6ce8\u610f\u8981\u5148\u5f00\u542f zookeeper–>
\n <dubbo:registry address="zookeeper:\/\/127.0.0.1:2181"\/>
\n <dubbo:protocol name="dubbo" port="-1"\/>
\n <dubbo:provider timeout="10000" threads="10" threadpool="fixed" loadbalance="roundrobin"\/><\/p>\n
<!– \u7b2c\u4e00\u4e2aTCC \u53c2\u4e0e\u8005\u670d\u52a1\u53d1\u5e03 –>
\n <dubbo:service interface="io.seata.samples.tcc.dubbo.action.TccActionOne" ref="tccActionOneImpl"\/>
\n <!– \u7b2c\u4e8c\u4e2aTCC \u53c2\u4e0e\u8005\u670d\u52a1\u53d1\u5e03 –>
\n <dubbo:service interface="io.seata.samples.tcc.dubbo.action.TccActionTwo" ref="tccActionTwoImpl"\/>
\n<\/beans> <\/p>\n
\u4e09.seata-dubbo-reference.xml<\/p>\n
<beans xmlns:xsi="http:\/\/www.w3.org\/2001\/XMLSchema-instance"
\n xmlns:dubbo="http:\/\/code.alibabatech.com\/schema\/dubbo"
\n xmlns="http:\/\/www.springframework.org\/schema\/beans"
\n xsi:schemaLocation="http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd
\n http:\/\/code.alibabatech.com\/schema\/dubbo
\n http:\/\/code.alibabatech.com\/schema\/dubbo\/dubbo.xsd" default-autowire="byName">
\n <dubbo:application name="tcc-sample-reference">
\n <dubbo:parameter key="qos.enable" value="false"\/>
\n <\/dubbo:application><\/p>\n
<!–\u4f7f\u7528 zookeeper \u6ce8\u518c\u4e2d\u5fc3\u66b4\u9732\u670d\u52a1，\u6ce8\u610f\u8981\u5148\u5f00\u542f zookeeper–>
\n <dubbo:registry address="zookeeper:\/\/127.0.0.1:2181"\/>
\n <dubbo:protocol name="dubbo" port="-1"\/>
\n <dubbo:provider timeout="10000" threads="10" threadpool="fixed" loadbalance="roundrobin"\/><\/p>\n
<!– \u7b2c\u4e00\u4e2aTCC\u53c2\u4e0e\u8005 \u670d\u52a1\u8ba2\u9605 –>
\n <dubbo:reference id="tccActionOne" interface="io.seata.samples.tcc.dubbo.action.TccActionOne" check="false" lazy="true"\/>
\n <!– \u7b2c\u4e8c\u4e2aTCC\u53c2\u4e0e\u8005 \u670d\u52a1\u8ba2\u9605 –>
\n <dubbo:reference id="tccActionTwo" interface="io.seata.samples.tcc.dubbo.action.TccActionTwo" check="false" lazy="true"\/>
\n<\/beans> <\/p>\n
(3)Demo\u5de5\u7a0b\u8fd0\u884c\u6307\u5357<\/p>\n
\u4e00.\u542f\u52a8Seata Server<\/p>\n<\/p>\n
\u4e8c.\u542f\u52a8Dubbo\u670d\u52a1\u5e94\u7528<\/p>\n
\u8fd0\u884cDubboTccProviderStarter\u3002\u8be5\u5e94\u7528\u4f1a\u53d1\u5e03Dubbo\u670d\u52a1，\u5e76\u4e14\u5b9e\u73b0\u4e86\u4e24\u4e2aTCC\u53c2\u4e0e\u8005\u3002<\/p>\n
public class TccProviderStarter extends AbstractStarter {
\n public static void main(String[] args) throws Exception {
\n new TccProviderStarter().start0(args);
\n }<\/p>\n
@Override
\n protected void start0(String[] args) throws Exception {
\n ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
\n new String[]{"spring\/seata-tcc.xml", "spring\/seata-dubbo-provider.xml"}
\n );
\n new ApplicationKeeper().keep();
\n }
\n}<\/p>\n
public class TccActionOneImpl implements TccActionOne {
\n @Override
\n public boolean prepare(BusinessActionContext actionContext, int a) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionOne prepare, xid:" + xid + ", a:" + a);
\n return true;
\n }<\/p>\n
@Override
\n public boolean commit(BusinessActionContext actionContext) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionOne commit, xid:" + xid + ", a:" + actionContext.getActionContext("a"));
\n ResultHolder.setActionOneResult(xid, "T");
\n return true;
\n }<\/p>\n
@Override
\n public boolean rollback(BusinessActionContext actionContext) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionOne rollback, xid:" + xid + ", a:" + actionContext.getActionContext("a"));
\n ResultHolder.setActionOneResult(xid, "R");
\n return true;
\n }
\n}<\/p>\n
public class TccActionTwoImpl implements TccActionTwo {
\n @Override
\n public boolean prepare(BusinessActionContext actionContext, String b, List list) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionTwo prepare, xid:" + xid + ", b:" + b + ", c:" + list.get(1));
\n return true;
\n }<\/p>\n
@Override
\n public boolean commit(BusinessActionContext actionContext) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionTwo commit, xid:" + xid + ", b:" + actionContext.getActionContext("b") + ", c:" + actionContext.getActionContext("c"));
\n ResultHolder.setActionTwoResult(xid, "T");
\n return true;
\n }<\/p>\n
@Override
\n public boolean rollback(BusinessActionContext actionContext) {
\n String xid = actionContext.getXid();
\n System.out.println("TccActionTwo rollback, xid:" + xid + ", b:" + actionContext.getActionContext("b") + ", c:" + actionContext.getActionContext("c"));
\n ResultHolder.setActionTwoResult(xid, "R");
\n return true;
\n }
\n} <\/p>\n
\u4e09.\u542f\u52a8\u4e8b\u52a1\u5e94\u7528<\/p>\n
\u8fd0\u884cTccConsumerStarter\u3002\u8be5\u5e94\u7528\u4f1a\u8ba2\u9605Dubbo\u670d\u52a1，\u53d1\u8d77\u5206\u5e03\u5f0f\u4e8b\u52a1，\u8c03\u7528\u4e0a\u8ff0\u4e24\u4e2aTCC\u53c2\u4e0e\u8005，\u5185\u542bTCC\u4e8b\u52a1\u63d0\u4ea4\u573a\u666f\u548cTCC\u4e8b\u52a1\u56de\u6eda\u573a\u666f\u7684\u6f14\u793a\u3002<\/p>\n
public class TccConsumerStarter extends AbstractStarter {
\n static TccTransactionService tccTransactionService = null;<\/p>\n
public static void main(String[] args) throws Exception {
\n new TccConsumerStarter().start0(args);
\n }<\/p>\n
@Override
\n protected void start0(String[] args) throws Exception {
\n ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
\n new String[]{"spring\/seata-tcc.xml", "spring\/seata-dubbo-reference.xml"}
\n );
\n tccTransactionService = (TccTransactionService) applicationContext.getBean("tccTransactionService");
\n \/\/\u5206\u5e03\u5f0f\u4e8b\u52a1\u63d0\u4ea4demo
\n transactionCommitDemo();
\n \/\/\u5206\u5e03\u5f0f\u4e8b\u52a1\u56de\u6edademo
\n transactionRollbackDemo();
\n }<\/p>\n
private static void transactionCommitDemo() throws InterruptedException {
\n String txId = tccTransactionService.doTransactionCommit();
\n System.out.println(txId);
\n Assert.isTrue(StringUtils.isNotEmpty(txId), "\u4e8b\u52a1\u5f00\u542f\u5931\u8d25");
\n System.out.println("transaction commit demo finish.");
\n }<\/p>\n
private static void transactionRollbackDemo() throws InterruptedException {
\n Map map = new HashMap(16);
\n try {
\n tccTransactionService.doTransactionRollback(map);
\n Assert.isTrue(false, "\u5206\u5e03\u5f0f\u4e8b\u52a1\u672a\u56de\u6eda");
\n } catch (Throwable t) {
\n Assert.isTrue(true, "\u5206\u5e03\u5f0f\u4e8b\u52a1\u5f02\u5e38\u56de\u6eda");
\n }
\n String txId = (String) map.get("xid");
\n System.out.println(txId);
\n System.out.println("transaction rollback demo finish.");
\n }
\n}<\/p>\n
public class TccTransactionService {
\n private TccActionOne tccActionOne;
\n private TccActionTwo tccActionTwo;<\/p>\n
\/\/\u63d0\u4ea4\u5206\u5e03\u5f0f\u4e8b\u52a1
\n @GlobalTransactional
\n public String doTransactionCommit() {
\n \/\/\u7b2c\u4e00\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n boolean result = tccActionOne.prepare(null, 1);
\n if (!result) {
\n throw new RuntimeException("TccActionOne failed.");
\n }
\n List list = new ArrayList();
\n list.add("c1");
\n list.add("c2");
\n \/\/\u7b2c\u4e8c\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n result = tccActionTwo.prepare(null, "two", list);
\n if (!result) {
\n throw new RuntimeException("TccActionTwo failed.");
\n }
\n return RootContext.getXID();
\n }<\/p>\n
\/\/\u56de\u6eda\u5206\u5e03\u5f0f\u4e8b\u52a1
\n @GlobalTransactional
\n public String doTransactionRollback(Map map) {
\n \/\/\u7b2c\u4e00\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n boolean result = tccActionOne.prepare(null, 1);
\n if (!result) {
\n throw new RuntimeException("TccActionOne failed.");
\n }
\n List list = new ArrayList();
\n list.add("c1");
\n list.add("c2");
\n \/\/\u7b2c\u4e8c\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n result = tccActionTwo.prepare(null, "two", list);
\n if (!result) {
\n throw new RuntimeException("TccActionTwo failed.");
\n }
\n map.put("xid", RootContext.getXID());
\n throw new RuntimeException("transacton rollback");
\n }<\/p>\n
public void setTccActionOne(TccActionOne tccActionOne) {
\n this.tccActionOne = tccActionOne;
\n }<\/p>\n
public void setTccActionTwo(TccActionTwo tccActionTwo) {
\n this.tccActionTwo = tccActionTwo;
\n }
\n} <\/p>\n
2.Seata TCC\u6848\u4f8b\u670d\u52a1\u63d0\u4f9b\u8005\u542f\u52a8\u5206\u6790<\/p>\n
\u6dfb\u52a0\u4e86@TwoPhaseBusinessAction\u6ce8\u89e3\u7684\u63a5\u53e3\u53d1\u5e03\u6210Dubbo\u670d\u52a1：<\/p>\n
<\/p>\n<\/p>\n
3.@TwoPhaseBusinessAction\u6ce8\u89e3\u626b\u63cf\u6e90\u7801<\/p>\n
(1)\u5168\u5c40\u4e8b\u52a1\u6ce8\u89e3\u626b\u63cf\u5668\u7684wrapIfNecessary()\u65b9\u6cd5\u626b\u63cfSpring Bean<\/p>\n
(2)TCCBeanParserUtils\u7684isTccAutoProxy()\u65b9\u6cd5\u5224\u65ad\u662f\u5426\u8981\u521b\u5efaTCC\u52a8\u6001\u4ee3\u7406<\/p>\n<\/p>\n
(1)\u5168\u5c40\u4e8b\u52a1\u6ce8\u89e3\u626b\u63cf\u5668\u7684wrapIfNecessary()\u65b9\u6cd5\u626b\u63cfSpring Bean<\/p>\n
\u5168\u5c40\u4e8b\u52a1\u6ce8\u89e3\u626b\u63cf\u5668GlobalTransactionScanner\u4f1a\u5728\u8c03\u7528initClient()\u65b9\u6cd5\u521d\u59cb\u5316Seata Client\u5ba2\u6237\u7aef\u540e，\u901a\u8fc7wrapIfNecessary()\u65b9\u6cd5\u626b\u63cfSpring Bean\u4e2d\u542b\u6709@TwoPhaseBusinessAction\u6ce8\u89e3\u7684\u65b9\u6cd5\u3002<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250523101330-68304a4a9df0e.png\")
<\/p>\n
\/\/AbstractAutoProxyCreator：Spring\u7684\u52a8\u6001\u4ee3\u7406\u81ea\u52a8\u521b\u5efa\u8005
\n\/\/ConfigurationChangeListener：\u5173\u6ce8\u914d\u7f6e\u53d8\u66f4\u4e8b\u4ef6\u7684\u76d1\u542c\u5668
\n\/\/InitializingBean：Spring Bean\u521d\u59cb\u5316\u56de\u8c03
\n\/\/ApplicationContextAware：\u7528\u6765\u611f\u77e5Spring\u5bb9\u5668
\n\/\/DisposableBean：\u652f\u6301\u53ef\u629b\u5f03Bean
\npublic class GlobalTransactionScanner extends AbstractAutoProxyCreator
\n implements ConfigurationChangeListener, InitializingBean, ApplicationContextAware, DisposableBean {
\n …<\/p>\n
\/\/InitializingBean\u63a5\u53e3\u7684\u56de\u8c03\u65b9\u6cd5
\n \/\/Spring\u5bb9\u5668\u542f\u52a8\u548c\u521d\u59cb\u5316\u5b8c\u6bd5\u540e，\u4f1a\u8c03\u7528\u5982\u4e0b\u7684afterPropertiesSet()\u65b9\u6cd5\u8fdb\u884c\u56de\u8c03
\n @Override
\n public void afterPropertiesSet() {
\n \/\/\u662f\u5426\u7981\u7528\u4e86\u5168\u5c40\u4e8b\u52a1，\u9ed8\u8ba4\u662ffalse
\n if (disableGlobalTransaction) {
\n if (LOGGER.isInfoEnabled()) {
\n LOGGER.info("Global transaction is disabled.");
\n }
\n ConfigurationCache.addConfigListener(ConfigurationKeys.DISABLE_GLOBAL_TRANSACTION, (ConfigurationChangeListener)this);
\n return;
\n }
\n \/\/\u901a\u8fc7CAS\u64cd\u4f5c\u786e\u4fddinitClient()\u521d\u59cb\u5316\u52a8\u4f5c\u4ec5\u4ec5\u6267\u884c\u4e00\u6b21
\n if (initialized.compareAndSet(false, true)) {
\n \/\/initClient()\u65b9\u6cd5\u4f1a\u5bf9Seata Client\u8fdb\u884c\u521d\u59cb\u5316，\u6bd4\u5982\u548cSeata Server\u5efa\u7acb\u957f\u8fde\u63a5
\n \/\/seata-samples\u7684tcc\u6a21\u5757\u7684seata-tcc.xml\u914d\u7f6e\u6587\u4ef6\u91cc\u90fd\u914d\u7f6e\u4e86GlobalTransactionScanner\u8fd9\u4e2aBean
\n \/\/\u800cGlobalTransactionScanner\u8fd9\u4e2aBean\u4f34\u968f\u7740Spring\u5bb9\u5668\u7684\u521d\u59cb\u5316\u5b8c\u6bd5，\u90fd\u4f1a\u56de\u8c03\u5176\u521d\u59cb\u5316\u903b\u8f91initClient()
\n initClient();
\n }
\n }<\/p>\n
\/\/initClient()\u662f\u6838\u5fc3\u65b9\u6cd5，\u8d1f\u8d23\u5bf9Seata Client\u5ba2\u6237\u7aef\u8fdb\u884c\u521d\u59cb\u5316
\n private void initClient() {
\n if (LOGGER.isInfoEnabled()) {
\n LOGGER.info("Initializing Global Transaction Clients … ");
\n }
\n if (DEFAULT_TX_GROUP_OLD.equals(txServiceGroup)) {
\n LOGGER.warn("…", DEFAULT_TX_GROUP_OLD, DEFAULT_TX_GROUP);
\n }
\n if (StringUtils.isNullOrEmpty(applicationId) || StringUtils.isNullOrEmpty(txServiceGroup)) {
\n throw new IllegalArgumentException(String.format("applicationId: %s, txServiceGroup: %s", applicationId, txServiceGroup));
\n }<\/p>\n
\/\/\u5bf9\u4e8eSeata Client\u6765\u8bf4，\u6700\u91cd\u8981\u7684\u7ec4\u4ef6\u6709\u4e24\u4e2a：
\n \/\/\u4e00\u4e2a\u662fTM，\u5373Transaction Manager，\u7528\u6765\u7ba1\u7406\u5168\u5c40\u4e8b\u52a1
\n \/\/\u4e00\u4e2a\u662fRM，\u5373Resource Manager，\u7528\u6765\u7ba1\u7406\u5404\u5206\u652f\u4e8b\u52a1\u7684\u6570\u636e\u6e90<\/p>\n
\/\/init TM
\n \/\/TMClient.init()\u4f1a\u5bf9\u5ba2\u6237\u7aef\u7684TM\u5168\u5c40\u4e8b\u52a1\u7ba1\u7406\u5668\u8fdb\u884c\u521d\u59cb\u5316
\n TMClient.init(applicationId, txServiceGroup, accessKey, secretKey);
\n if (LOGGER.isInfoEnabled()) {
\n LOGGER.info("Transaction Manager Client is initialized. applicationId[{}] txServiceGroup[{}]", applicationId, txServiceGroup);
\n }<\/p>\n
\/\/init RM
\n \/\/RMClient.init()\u4f1a\u5bf9\u5ba2\u6237\u7aef\u7684RM\u5206\u652f\u4e8b\u52a1\u8d44\u6e90\u7ba1\u7406\u5668\u8fdb\u884c\u521d\u59cb\u5316
\n RMClient.init(applicationId, txServiceGroup);
\n if (LOGGER.isInfoEnabled()) {
\n LOGGER.info("Resource Manager is initialized. applicationId[{}] txServiceGroup[{}]", applicationId, txServiceGroup);
\n }<\/p>\n
if (LOGGER.isInfoEnabled()) {
\n LOGGER.info("Global Transaction Clients are initialized. ");
\n }<\/p>\n
\/\/\u6ce8\u518cSpring\u5bb9\u5668\u88ab\u9500\u6bc1\u65f6\u7684\u56de\u8c03\u94a9\u5b50，\u91ca\u653eTM\u548cRM\u4e24\u4e2a\u7ec4\u4ef6\u7684\u4e00\u4e9b\u8d44\u6e90
\n registerSpringShutdownHook();
\n }<\/p>\n
\/\/The following will be scanned, and added corresponding interceptor:
\n \/\/\u6dfb\u52a0\u4e86\u5982\u4e0b\u6ce8\u89e3\u7684\u65b9\u6cd5\u4f1a\u88ab\u626b\u63cf\u5230，\u7136\u540e\u65b9\u6cd5\u4f1a\u6dfb\u52a0\u76f8\u5e94\u7684\u62e6\u622a\u5668\u8fdb\u884c\u62e6\u622a<\/p>\n
\/\/TM:
\n \/\/@see io.seata.spring.annotation.GlobalTransactional \/\/ TM annotation
\n \/\/Corresponding interceptor:
\n \/\/@see io.seata.spring.annotation.GlobalTransactionalInterceptor#handleGlobalTransaction(MethodInvocation, AspectTransactional) \/\/ TM handler<\/p>\n
\/\/GlobalLock:
\n \/\/@see io.seata.spring.annotation.GlobalLock \/\/ GlobalLock annotation
\n \/\/Corresponding interceptor:
\n \/\/@see io.seata.spring.annotation.GlobalTransactionalInterceptor# handleGlobalLock(MethodInvocation, GlobalLock) \/\/ GlobalLock handler<\/p>\n
\/\/TCC mode:
\n \/\/@see io.seata.rm.tcc.api.LocalTCC \/\/ TCC annotation on interface
\n \/\/@see io.seata.rm.tcc.api.TwoPhaseBusinessAction \/\/ TCC annotation on try method
\n \/\/@see io.seata.rm.tcc.remoting.RemotingParser \/\/ Remote TCC service parser
\n \/\/Corresponding interceptor:
\n \/\/@see io.seata.spring.tcc.TccActionInterceptor \/\/ the interceptor of TCC mode<\/p>\n
@Override
\n \/\/\u7531\u4e8eGlobalTransactionScanner\u7ee7\u627f\u4e86Spring\u63d0\u4f9b\u7684AbstractAutoProxyCreator，
\n \/\/\u6240\u4ee5Spring\u4f1a\u628aSpring Bean\u4f20\u9012\u7ed9GlobalTransactionScanner.wrapIfNecessary()\u8fdb\u884c\u5224\u65ad；
\n \/\/\u8ba9GlobalTransactionScanner\u6765\u51b3\u5b9a\u662f\u5426\u8981\u6839\u636eBean\u7684Class\u3001\u6216\u8005Bean\u7684\u65b9\u6cd5\u662f\u5426\u6709\u4e0a\u8ff0\u6ce8\u89e3，
\n \/\/\u4ece\u800c\u51b3\u5b9a\u662f\u5426\u9700\u8981\u9488\u5bf9Bean\u7684Class\u521b\u5efa\u52a8\u6001\u4ee3\u7406，\u6765\u5bf9\u6dfb\u52a0\u4e86\u6ce8\u89e3\u7684\u65b9\u6cd5\u8fdb\u884c\u62e6\u622a；
\n protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
\n \/\/do checkers
\n if (!doCheckers(bean, beanName)) {
\n return bean;
\n }<\/p>\n
try {
\n synchronized (PROXYED_SET) {
\n if (PROXYED_SET.contains(beanName)) {
\n return bean;
\n }
\n interceptor = null;<\/p>\n
\/\/check TCC proxy
\n \/\/\u5224\u65ad\u4f20\u9012\u8fdb\u6765\u7684Bean\u662f\u5426\u662fTCC\u52a8\u6001\u4ee3\u7406
\n \/\/\u670d\u52a1\u542f\u52a8\u65f6\u4f1a\u628a\u6240\u6709\u7684Bean\u4f20\u9012\u8fdb\u6765\u8fd9\u4e2awrapIfNecessary()，\u68c0\u67e5\u8fd9\u4e2aBean\u662f\u5426\u9700\u8981\u521b\u5efaTCC\u52a8\u6001\u4ee3\u7406
\n if (TCCBeanParserUtils.isTccAutoProxy(bean, beanName, applicationContext)) {
\n \/\/init tcc fence clean task if enable useTccFence
\n TCCBeanParserUtils.initTccFenceCleanTask(TCCBeanParserUtils.getRemotingDesc(beanName), applicationContext);
\n \/\/TCC interceptor, proxy bean of sofa:reference\/dubbo:reference, and LocalTCC
\n interceptor = new TccActionInterceptor(TCCBeanParserUtils.getRemotingDesc(beanName));
\n ConfigurationCache.addConfigListener(ConfigurationKeys.DISABLE_GLOBAL_TRANSACTION, (ConfigurationChangeListener)interceptor);
\n } else {
\n \/\/\u83b7\u53d6\u76ee\u6807class\u7684\u63a5\u53e3
\n Class<?> serviceInterface = SpringProxyUtils.findTargetClass(bean);
\n Class<?>[] interfacesIfJdk = SpringProxyUtils.findInterfaces(bean);<\/p>\n
\/\/existsAnnotation()\u65b9\u6cd5\u4f1a\u5224\u65adBean\u7684Class\u6216Method\u662f\u5426\u6dfb\u52a0\u4e86@GlobalTransactional\u7b49\u6ce8\u89e3
\n if (!existsAnnotation(new Class[]{serviceInterface}) && !existsAnnotation(interfacesIfJdk)) {
\n return bean;
\n }<\/p>\n
if (globalTransactionalInterceptor == null) {
\n \/\/\u6784\u5efa\u4e00\u4e2aGlobalTransactionalInterceptor，\u5373\u5168\u5c40\u4e8b\u52a1\u6ce8\u89e3\u7684\u62e6\u622a\u5668
\n globalTransactionalInterceptor = new GlobalTransactionalInterceptor(failureHandlerHook);
\n ConfigurationCache.addConfigListener(ConfigurationKeys.DISABLE_GLOBAL_TRANSACTION, (ConfigurationChangeListener)globalTransactionalInterceptor);
\n }
\n interceptor = globalTransactionalInterceptor;
\n }<\/p>\n
LOGGER.info("Bean[{}] with name [{}] would use interceptor [{}]", bean.getClass().getName(), beanName, interceptor.getClass().getName());
\n if (!AopUtils.isAopProxy(bean)) {\/\/\u5982\u679c\u8fd9\u4e2aBean\u5e76\u4e0d\u662fAOP\u4ee3\u7406
\n \/\/\u63a5\u4e0b\u6765\u4f1a\u57fa\u4e8eSpring\u7684AbstractAutoProxyCreator\u521b\u5efa\u9488\u5bf9\u76ee\u6807Bean\u63a5\u53e3\u7684\u52a8\u6001\u4ee3\u7406
\n \/\/\u8fd9\u6837\u540e\u7eed\u8c03\u7528\u5230\u76ee\u6807Bean\u7684\u65b9\u6cd5，\u5c31\u4f1a\u8c03\u7528\u5230TccActionInterceptor\u62e6\u622a\u5668
\n bean = super.wrapIfNecessary(bean, beanName, cacheKey);
\n } else {
\n AdvisedSupport advised = SpringProxyUtils.getAdvisedSupport(bean);
\n Advisor[] advisor = buildAdvisors(beanName, getAdvicesAndAdvisorsForBean(null, null, null));
\n int pos;
\n for (Advisor avr : advisor) {
\n \/\/Find the position based on the advisor's order, and add to advisors by pos
\n pos = findAddSeataAdvisorPosition(advised, avr);
\n advised.addAdvisor(pos, avr);
\n }
\n }
\n PROXYED_SET.add(beanName);
\n return bean;
\n }
\n } catch (Exception exx) {
\n throw new RuntimeException(exx);
\n }
\n }
\n …
\n} <\/p>\n
(2)TCCBeanParserUtils\u7684isTccAutoProxy()\u65b9\u6cd5\u5224\u65ad\u662f\u5426\u8981\u521b\u5efaTCC\u52a8\u6001\u4ee3\u7406<\/p>\n
public class TCCBeanParserUtils {
\n private TCCBeanParserUtils() {
\n }<\/p>\n
\/\/is auto proxy TCC bean
\n public static boolean isTccAutoProxy(Object bean, String beanName, ApplicationContext applicationContext) {
\n boolean isRemotingBean = parserRemotingServiceInfo(bean, beanName);
\n \/\/get RemotingBean description
\n RemotingDesc remotingDesc = DefaultRemotingParser.get().getRemotingBeanDesc(beanName);
\n \/\/is remoting bean
\n if (isRemotingBean) {
\n if (remotingDesc != null && remotingDesc.getProtocol() == Protocols.IN_JVM) {
\n \/\/LocalTCC
\n \/\/\u521b\u5efa\u4e00\u4e2alocal tcc\u4ee3\u7406
\n return isTccProxyTargetBean(remotingDesc);
\n } else {
\n \/\/sofa:reference \/ dubbo:reference, factory bean
\n return false;
\n }
\n } else {
\n if (remotingDesc == null) {
\n \/\/check FactoryBean
\n if (isRemotingFactoryBean(bean, beanName, applicationContext)) {
\n remotingDesc = DefaultRemotingParser.get().getRemotingBeanDesc(beanName);
\n return isTccProxyTargetBean(remotingDesc);
\n } else {
\n return false;
\n }
\n } else {
\n return isTccProxyTargetBean(remotingDesc);
\n }
\n }
\n }
\n …<\/p>\n
\/\/is TCC proxy-bean\/target-bean: LocalTCC , the proxy bean of sofa:reference\/dubbo:reference
\n public static boolean isTccProxyTargetBean(RemotingDesc remotingDesc) {
\n if (remotingDesc == null) {
\n return false;
\n }
\n \/\/check if it is TCC bean
\n boolean isTccClazz = false;
\n \/\/\u9488\u5bf9\u6211\u4eec\u7684class\u62ff\u5230\u4e00\u4e2a\u63a5\u53e3class
\n Class<?> tccInterfaceClazz = remotingDesc.getInterfaceClass();
\n \/\/\u83b7\u53d6\u6211\u4eec\u7684\u63a5\u53e3\u91cc\u5b9a\u4e49\u7684\u6240\u6709\u7684\u65b9\u6cd5
\n Method[] methods = tccInterfaceClazz.getMethods();<\/p>\n
TwoPhaseBusinessAction twoPhaseBusinessAction;<\/p>\n
\/\/\u904d\u5386\u6240\u6709\u7684\u65b9\u6cd5
\n for (Method method : methods) {
\n \/\/\u83b7\u53d6\u7684\u65b9\u6cd5\u662f\u5426\u52a0\u4e86@TwoPhaseBusinessAction\u6ce8\u89e3
\n twoPhaseBusinessAction = method.getAnnotation(TwoPhaseBusinessAction.class);
\n if (twoPhaseBusinessAction != null) {
\n isTccClazz = true;
\n break;
\n }
\n }
\n if (!isTccClazz) {
\n return false;
\n }
\n short protocols = remotingDesc.getProtocol();
\n \/\/LocalTCC
\n if (Protocols.IN_JVM == protocols) {
\n \/\/in jvm TCC bean , AOP
\n return true;
\n }
\n \/\/sofa:reference \/ dubbo:reference, AOP
\n return remotingDesc.isReference();
\n }
\n …
\n} <\/p>\n
4.Seata TCC\u6848\u4f8b\u5206\u5e03\u5f0f\u4e8b\u52a1\u5165\u53e3\u5206\u6790<\/p>\n
TccTransactionService\u4f5c\u4e3a\u5206\u5e03\u5f0f\u4e8b\u52a1\u7684\u5165\u53e3，\u5176\u63d0\u4ea4\u4e8b\u52a1\u548c\u56de\u6eda\u4e8b\u52a1\u7684\u63a5\u53e3\u90fd\u4f1a\u88ab\u6dfb\u52a0\u4e0a@GlobalTransactional\u6ce8\u89e3\u3002<\/p>\n<\/p>\n
\u6240\u4ee5\u5e94\u7528\u542f\u52a8\u65f6，TccTransactionService\u7684Bean\u5c31\u4f1a\u88abGlobalTransactionScanner\u626b\u63cf，\u7136\u540e\u5176\u4e0b\u6dfb\u52a0\u4e86@GlobalTransactional\u6ce8\u89e3\u7684\u63a5\u53e3\u5c31\u4f1a\u88ab\u521b\u5efa\u52a8\u6001\u4ee3\u7406\u3002<\/p>\n<\/p>\n
\u5728TccTransactionService\u7684\u63d0\u4ea4\u5206\u5e03\u5f0f\u4e8b\u52a1\u7684\u63a5\u53e3\u4e2d，\u4f1a\u5148\u540e\u8c03\u7528TccActionOne\u548cTccActionTwo\u4e24\u4e2aDubbo\u670d\u52a1\u3002\u5e76\u4e14\u5728\u8c03\u7528\u4e24\u4e2aDubbo\u670d\u52a1\u65f6，\u4f1a\u901a\u8fc7ApacheDubboTransactionPropagationFilter\u4f20\u9012xid\u3002<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250523101331-68304a4b16ab5.png\")
<\/p>\n
public class TccTransactionService {
\n private TccActionOne tccActionOne;
\n private TccActionTwo tccActionTwo;<\/p>\n
\/\/\u63d0\u4ea4\u5206\u5e03\u5f0f\u4e8b\u52a1
\n @GlobalTransactional
\n public String doTransactionCommit() {
\n \/\/\u7b2c\u4e00\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n boolean result = tccActionOne.prepare(null, 1);
\n if (!result) {
\n throw new RuntimeException("TccActionOne failed.");
\n }
\n List list = new ArrayList();
\n list.add("c1");
\n list.add("c2");
\n \/\/\u7b2c\u4e8c\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n result = tccActionTwo.prepare(null, "two", list);
\n if (!result) {
\n throw new RuntimeException("TccActionTwo failed.");
\n }
\n return RootContext.getXID();
\n }<\/p>\n
\/\/\u56de\u6eda\u5206\u5e03\u5f0f\u4e8b\u52a1
\n @GlobalTransactional
\n public String doTransactionRollback(Map map) {
\n \/\/\u7b2c\u4e00\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n boolean result = tccActionOne.prepare(null, 1);
\n if (!result) {
\n throw new RuntimeException("TccActionOne failed.");
\n }
\n List list = new ArrayList();
\n list.add("c1");
\n list.add("c2");
\n \/\/\u7b2c\u4e8c\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005
\n result = tccActionTwo.prepare(null, "two", list);
\n if (!result) {
\n throw new RuntimeException("TccActionTwo failed.");
\n }
\n map.put("xid", RootContext.getXID());
\n throw new RuntimeException("transacton rollback");
\n }<\/p>\n
public void setTccActionOne(TccActionOne tccActionOne) {
\n this.tccActionOne = tccActionOne;
\n }<\/p>\n
public void setTccActionTwo(TccActionTwo tccActionTwo) {
\n this.tccActionTwo = tccActionTwo;
\n }
\n} <\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb534\u6b21\uff0c\u70b9\u8d5e26\u6b21\uff0c\u6536\u85cf16\u6b21\u3002\u5728TccTransactionService\u7684\u63d0\u4ea4\u5206\u5e03\u5f0f\u4e8b\u52a1\u7684\u63a5\u53e3\u4e2d\uff0c\u4f1a\u5148\u540e\u8c03\u7528TccActionOne\u548cTccActionTwo\u4e24\u4e2aDubbo\u670d\u52a1\u3002\u8be5Demo\u4e2d\u4e00\u4e2a\u5206\u5e03\u5f0f\u4e8b\u52a1\u5185\u4f1a\u6709\u4e24\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005\uff0c\u8fd9\u4e24\u4e2aTCC\u4e8b\u52a1\u53c2\u4e0e\u8005\u5206\u522b\u662fTccActionOne\u548cTccActionTwo\u3002\u53e6\u5916\u4e00\u4e2a\u5e94\u7528\u4f5c\u4e3a\u4e8b\u52a1\u53d1\u8d77\u65b9\uff0c\u4f1a\u8ba2\u9605Dubbo\u670d\u52a1\uff0c\u7136\u540e\u8c03\u7528\u7f16\u6392TCC\u53c2\u4e0e\u8005\uff0c\u6267\u884c\u8fdc\u7a0bDubbo\u670d\u52a1\u3002\u8be5\u5e94\u7528\u4f1a\u8ba2\u9605Dubbo\u670d\u52a1\uff0c\u53d1\u8d77\u5206\u5e03\u5f0f\u4e8b\u52a1\uff0c\u8c03\u7528\u4e0a\u8ff0\u4e24\u4e2aTCC\u53c2\u4e0e\u8005\uff0c\u5185\u542bTCC\u4e8b\u52a1\u63d0\u4ea4\u573a\u666f\u548cTCC\u4e8b\u52a1\u56de\u6eda\u573a\u666f\u7684\u6f14\u793a\u3002<\/p>\n","protected":false},"author":2,"featured_media":39441,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[3535,3534,664,3536],"topic":[],"class_list":{"0":"post-39444","1":"post","2":"type-post","3":"status-publish","4":"format-standard","5":"has-post-thumbnail","6":"hentry","7":"category-server","8":"tag-seata","10":"tag-664","11":"tag-3536"},"yoast_head":"\n