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>