TXC SDK for MQ__TXC for MQ_消息队列 MQ-阿里云

业务代码中在需要发起全局事务的 bean 中添加 @TxcTransaction 注解，简单举例，如：

class BussinessImpl { /* 此为声明的带有@TxcTransaction注解方法的bean */
    @TxcTransaction(timeout = 60000)
    void edasSample(HsfService hsf) {
        // 调用远端服务
        boolean ret = hsf.runBusiness();
        if(ret == false)
            throw new TxcExecption;
    }
}

这样一旦有异常被抛出这个注解函数的范围，表示客户端期望事务回滚，则凡是参与这个全局事务的资源都会在 TXC 的指导下自动进行全局回滚。另外如果没有在指定全局事务超时时间内提交这个事务，也会导致整个全局事务的回滚。

说明：

1. 带有 @TxcTransaction 注解的方法可以在其他的类中被调用，但如果在本类的其他方法中被调用的时候需要显示指定实例。例如：class A 有 @TxcTransaction 注解的方法 tran_func 和不带注解的 no_tran_func，客户可以在 class B 中的一般方法中调用 a.tran_func。但不应该在 no_tran_func 中直接调用 tran_func，否则事务无法正常开启。
2. 开启事务只能直接调用带有 @TxcTransaction 注解的 bean 的注解方法。例如：上面例子中 bussiness 的 bean，应调用 bussiness.edasSample(…) 开启事务。
3. 使用 DRDS 作为数据源时，需要客户发送 DRDS 开通 TXC 的申请的文档，文档包括 DRDS 数据实例名称，数据库名称等信息，DRDS 接入分布式事务（TXC）须知 - 模板 下载。同时需要咨询 DRDS 人员关于此专享实例的版本信息是否支持 TXC 要求，如果 DRDS 实例版本较低需要申请 DRDS 实例版本进行升级。
4. 同一台机器上只允许一个 TXC 客户端运行。
5. 在 TXC 中使用 MQ 时，com.taobao.txc.client.aop.MTRelationShipManager 一定要先于 com.taobao.txc.client.aop.TxcTransactionScaner 进行声明。

<bean class="com.taobao.txc.client.aop.MTRelationShipManager">
        <property name="beanNames" ref="mtServicesClassList" />
        <property name="interceptorNames">
            <list>
                <value>mtBranchInterceptor</value>
            </list>
        </property>
        <property name="order" value="1"></property>
        <property name="proxyTargetClass" value="false">
        </property>
</bean>
<bean class="com.taobao.txc.client.aop.TxcTransactionScaner">
        <constructor-arg value="test111.1325460969176422.BJ"/>
        <constructor-arg value="3"/>
        <accessKey>xxx</accessKey>
        <secretKey>xxx</secretKey>
</bean>

TXC EDAS for RDS 使用注意事项

使用 EDS+RDS(MySQL) 时需要使用 TXC 提供的数据源包，才能自动打通分布式事务。

<bean id="DataSource_rds" class="com.taobao.txc.datasource.cobar.TxcDataSource">
    <property name="url" value="jdbc:mysql://rds-ip:3306/xxx" />
    <property name="username" value="xxx" />
    <property name="password" value="xxx" />
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
</bean>

如果 EDAS 调用的是 DRDS 的数据源，服务端可以使用标准 MySQL JDBC 或者 Druid 连接池等方式，如：

<bean id="DataSource_drds" class="com.alibaba.druid.pool.DruidDataSource" init-method="init">
    <property name="url" value="jdbc:mysql://drds-ip/xxx"/>
    <property name="username" value="xxx"/>
    <property name="connectProperties">
        <props>
            <prop key="password">xxx</prop>
        </props>
    </property>
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="filters" value="stat" />
    <property name="maxActive" value="300" />
    <property name="initialSize" value="10" />
    <property name="maxWait" value="60000" />
    <property name="minIdle" value="1" />
    <property name="timeBetweenEvictionRunsMillis" value="60000" />
    <property name="minEvictableIdleTimeMillis" value="300000" />
    <property name="validationQuery" value="SELECT 'x'" />
    <property name="testWhileIdle" value="true" />
    <property name="testOnBorrow" value="false" />
    <property name="testOnReturn" value="false" />
    <property name="poolPreparedStatements" value="true" />
    <property name="maxPoolPreparedStatementPerConnectionSize" value="30" />
</bean>