JTA分佈式事務與Atomikos

本章主要介紹分佈式事務，對於多數據源操做，若是不得不使用分佈式事務來處理，那就須要JTA，它主要包括兩個部分：事務管理器，支持XA協議的資源管理器。其中事務管理器主要是給開發人員的接口，而資源管理器是給服務提供商的接口，服務提供商就是數據庫鏈接的廠商。對於分佈式事務的原理依然是兩階段、三階段事務提交，百度都有詳細介紹，這裏再也不講了。

回到以前那個問題，若是項目須要分佈式事務，怎麼辦？目前業內比較好的框架的是Atomikos，它已經10年了，比較穩定。使用它主要是配置，看下代碼：

   <!--JTA atomikos-->
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>atomikos-util</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-jta</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-jdbc</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-api</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>cglib</groupId>
      <artifactId>cglib-nodep</artifactId>
      <version>3.2.2</version>
    </dependency>
    <dependency>
      <groupId>javax.transaction</groupId>
      <artifactId>jta</artifactId>
      <version>1.1</version>
    </dependency>

<!-- jtaDataSource0數據源 -->
<bean id="jtaDataSource0" class="com.atomikos.jdbc.AtomikosDataSourceBean"
      init-method="init" destroy-method="close">
    <!-- Set unique name for this DataSource -->
    <property name="uniqueResourceName"><value>jtaDataSource0</value></property>
    <!-- Set XADatasource class name-->
    <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
    <property name="xaProperties">
        <props>
            <prop key="user">root</prop>
            <prop key="password">dlb</prop>
            <prop key="url">${jdbc.url}</prop>
        </props>
    </property>
    <!-- set properties for datasource connection pool -->
    <property name="poolSize" value="3" />
    <!-- 管理 Connection 被佔用的時間 -->
    <!-- 若是不設置這個值，Atomikos使用默認的300秒(即5分鐘)，那麼在處理大批量數據讀取的時候，一旦超過5分鐘，就會拋出相似 Resultset is close 的錯誤 -->
    <property name="reapTimeout"><value>30000</value></property>
</bean>

<!-- jtaDataSource1數據源 -->
<bean id="jtaDataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean"
      init-method="init" destroy-method="close">
    <property name="uniqueResourceName"><value>jtaDataSource1</value></property>
    <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
    <property name="xaProperties">
        <props>
            <prop key="user">root</prop>
            <prop key="password">dlb</prop>
            <prop key="url">${jdbc1.url}</prop>
        </props>
    </property>
    <!-- 鏈接池裏面鏈接的個數 -->
    <property name="poolSize" value="3" />
    <!-- 管理 Connection 被佔用的時間 -->
    <!-- 若是不設置這個值，Atomikos使用默認的300秒(即5分鐘)，那麼在處理大批量數據讀取的時候，一旦超過5分鐘，就會拋出相似 Resultset is close 的錯誤 -->
    <property name="reapTimeout"><value>30000</value></property>
</bean>

<!--jtaSqlsessionFactory0 mybatis-->
<bean id="jtaSqlsessionFactory0" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="configLocation" value="classpath:config/mybatis/SqlMapConfig.xml"/>
    <property name="dataSource" ref="jtaDataSource0"/>
</bean>

<!--jtaSqlsessionFactory1 test-->
<bean id="jtaSqlsessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="configLocation" value="classpath:config/mybatis/SqlMapConfig.xml"/>
    <property name="dataSource" ref="jtaDataSource1"/>
</bean>

<!-- atomikos事務管理器 -->
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
      init-method="init" destroy-method="close">
    <property name="forceShutdown">
        <value>true</value>
    </property>
</bean>

<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
    <!--事務超時時間 最好和max_timeout同樣-->
    <property name="transactionTimeout" value="300" />
</bean>

<!-- springJta事務管理器 -->
<bean id="springJtaTransactionManager"
      class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="atomikosTransactionManager"/>
    <property name="userTransaction" ref="atomikosUserTransaction" />
    <property name="allowCustomIsolationLevels" value="true"/>
</bean>

public void jtaTest(TbFundSeoRecord record, User user) throws Exception {
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        TransactionStatus status = springJtaTransactionManager.getTransaction(def);

        try {
            jtaUserDao.insert(user);
//            int i = 1/ 0;
            jtaSeoFundDao.insert(record);

//            int i = 1/ 0;
            springJtaTransactionManager.commit(status);
        } catch (Exception e) {
            e.printStackTrace();
            springJtaTransactionManager.rollback(status);
     
    }

要注意mysql的版本號，5.1.6會報錯，我用的5.1.35。

分佈式事務性能很低，基本是個擺設，最好不要使用分佈式事務，儘可能從業務拆分。由於對於事務咱們都是追求弱一致性或者最終一致性，而不能一味的爲了追求強一致性而丟了可用性。