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>