930      阿裏雲  技術社區[雲棲]

TXC for MQ 快速入門__TXC for MQ_消息隊列 MQ-阿裏雲

本文介紹在 MQ 裏使用 TXC 的具體步驟和注意事項。

1. 登陸控製台

從瀏覽器中訪問 MQ 控製台， 建議使用 Chrome 瀏覽器獲得最佳體驗。

2. 創建並申請事務分組

在控製台左側菜單選擇事務總覽，創建事務分組，輸入自定義的事務分組名稱創建事務分組。

剛創建的事務分組處於等待狀態，這時 TXC 管理人員會在後台幫您關聯一個可用的 TXC 集群，開通後的分組顯示為開通狀態。這個唯一事務分組號（例如: test111.1325460969176422.BJ）是客戶端 TXC 配置 Scanner 中的必要參數。

3. 創建 MQ 應用

下載 TXC SDK，並參考 MQ 快速入門創建客戶端和服務端應用。

（1） 創建基於 TXC 的 MQ Producer

Spring 配置文件中需要指定 MTRelationShipManager， mtBranchInterceptor， mtServicesClassList， TxcMQProducerImpl 這些 bean 並建立關聯。

注意: MTRelationShipManager 一定要先於 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 name="proxyTargetClass" value="false"/>
</bean>

Spring 配置文件中需要指定使用的事務分組名稱, AK 以及 SK，如：

<bean class="com.taobao.txc.client.aop.TxcTransactionScaner">
        <constructor-arg value="test111.1325460969176422.BJ"/>
        <accessKey>xxx</accessKey>
        <secretKey>xxx</secretKey>
</bean>

在參與 TXC 事務的業務方法 Bean 中添加 TXC 注解，如:

@TxcTransaction(appName = "myapp")
    public void hello() {
       ...
    }

並將帶有 TXC 注解的業務 Bean 聲明在 Spring 配置文件中，如：

<bean id="bussiness" class="com.taobao.txc.tests.Client" init-method="init"/>

添加 MtBranchInterceptor， TxcMQProducerImpl 並建立關聯關係。

<bean id="mtBranchInterceptor" class="com.taobao.txc.resourcemanager.mt.MtBranchInterceptor"/>
<bean id="mtServicesClassList" class="org.springframework.beans.factory.config.ListFactoryBean">
    <property name="sourceList">
        <list>
                <value>com.taobao.txc.rm.mq.TxcMQProducer</value>
        </list>
    </property>
</bean>
<bean id="txc_mq_producer" class="com.taobao.txc.rm.mq.TxcMQProducerImpl">
    <constructor-arg name="ProducerId" value="PID_txc_mq_prod_test"/>
    <constructor-arg name="AccessKey" value="xxxx"/>
    <constructor-arg name="SecretKey" value="xxxx"/>
</bean>