接入单元化能力

DTX 服务配置

1. 添加 maven 依赖：

   <dependency>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>dtx-enterprise-sofa-boot-starter</artifactId>
         <version>${dtx.version}</version>
   </dependency>

2. 服务配置：

   <bean id="dtxService" class="com.alipay.dtx.client.core.api.impl.DtxServiceImpl"/>

发起方配置

发起方应用配置 spring 事务模板，配置示例如下：

<!--声明新的事务模板-->
<bean id="transactionTemplate"class="org.springframework.transaction.support.TransactionTemplate">
        <property name="transactionManager" ref="transactionManager"/>
        <property name="propagationBehaviorName">
               <value>PROPAGATION_REQUIRES_NEW</value>
        </property>
</bean>

在发起方的 spring 事务模板内，调用 dtxService.start(bizType, bizId, userId, context) 方法开启分布式事务（不再使用前文中 [@DtxTransaction](#) 注解的方式开启事务）；其中参数 userId 会作为单元化架构下的路由参数，用作服务路由和数据库路由。

public class YourClass {

    public void yourMethod(yourParams) {

        transactionTemplate.execute(newTransactionCallback() {
            @Override
            public Object doInTransaction (TransactionStatus status){

                //开启分布式事务
                dtxService.start(bizType, bizId, userId, context)

                try {
                    // 调用 TCC1 参与者一阶段try方法, 第一个参数是用户ID，try方法BusinessActionContext参数值传'null';
                    TCC1. try (userId,params1,null) ;

                    // 调用 TCC2 参与者一阶段try方法，第一个参数是用户ID，try方法BusinessActionContext参数值传'null';
                    TCC2. try (userId,params2,null) ;

                    // 方法正常返回，事务提交
                } catch (Throwable t) {
                    // 出现异常，事务回滚
                    throw t;
                }
            }
        });
    }
}

发起方实现回查服务

当事务状态不确定时，dtxserver 需要通过回查服务询问发起方分布式事务状态，发起方需要实现 com.alipay.dtx.client.core.api.ActivityStateResolver 接口，在 isDone 方法中返回事务的状态（0 即未知，1 即提交，2 即回滚）；

public class ActivityStateResolverImpl implements com.alipay.dtx.client.core.api.ActivityStateResolver {

    @Override
    public int isDone(String businessType, String businessId) {
        System.out.println("回查, businessType:" + businessType + ", businessId" + businessId);
        return ActivityStateResolver.NOT_DONE | ActivityStateResolver.DONE;
    }
}

回查服务配置成 spring bean：

<bean id="activityStateResolver" class="com.xxx.ActivityStateResolverImpl"/>