【分布式事務】使用atomikos+jta解決分布式事務問題

一、前言

分布式事務，這個問題困惑了小編很久，在3個月之前，就間斷性的研究分布式事務。從MQ方面，數據庫事務方面，jta方面。近期終於成功了，使用JTA解決了分布式事務問題。先寫一下心得，后面的二級提交也會在研究。

二、介紹

分布式事務

說到分布式事務，可以理解為，由於分布式而引起的事務不一致的問題。隨着項目做大，模塊拆分，數據庫拆分。一次包含增刪改操作數據庫涉及到了更新兩個不同物理節點的數據庫，這樣的數據庫事務只能保證自己處理的部分的事務，但是整個的事務就不能保證一致性。

網上針對分布式事務常見的例子有：轉賬

我從農行轉賬100元到建設銀行。首先，農行和建行的數據庫是分開的，其次要在農行數據庫中-100，在建行數據庫+100。分布式事務就是要保障建行+100出錯了，使得農行回滾為原來的數目。

JTA

JTA（java Transaction API）是JavaEE 13 個開發規范之一。java 事務API，允許應用程序執行分布式事務處理——在兩個或多個網絡計算機資源上訪問並且更新數據。JDBC驅動程序的JTA支持極大地增強了數據訪問能力。事務最簡單最直接的目的就是保證數據的有效性，數據的一致性。

atomikos

實現JTA事務管理第三方管理工具 ，一個是JOTM，一個是Atomikos。在其他的博客中看到了JOTM最后更新日期是2010年，然后果斷研究是Atomikos。

Atomikos TransactionsEssentials 是一個為Java平台提供增值服務的並且開源類事務管理器，以下是包括在這個開源版本中的一些功能：

　　　　　　

<code> 全面崩潰 / 重啟恢復
 
 兼容標准的SUN公司JTA API
 
 嵌套事務
 
 為XA和非XA提供內置的JDBC適配器
</code>

 

三、解決分布式事務

3.1 業務說明

業務

有兩個數據庫，分別在192.168.22.58和192.168.22.58上，分別有t_allusers表和t_student表，業務是要想兩個表中添加一條記錄，如果后一條失敗了，那么前一條要回滾：

　　　　　　　　

 

3.2 環境說明

SSM框架

Mysql

Maven

 　　　　　　　　　　

3.3 引入依賴

<!--分布式事務相關Atomikos+jta-->

<dependency>

  　　<groupid>com.atomikos</groupid>

  　　<artifactid>transactions-jdbc</artifactid>

  　　<version>4.0.6</version>

</dependency>

<dependency>

 　　<groupid>javax.transaction</groupid>

　　 <artifactid>jta</artifactid>

　　 <version>1.1</version>

</dependency>

 

 

3.4 配置數據源

在spring配置文件applicationContext-dao.xml配置文件中，添加分布式事務相關的配置：jta事務管理器，不同數據庫的數據源配置。

<!-- 分布式事務 -->
    <!-- jta事務管理器 -->
    <bean class="org.springframework.transaction.jta.JtaTransactionManager" id="jtaTransactionManager">
        <property name="transactionManager">
            <bean class="com.atomikos.icatch.jta.UserTransactionManager" destroy-method="close" init-method="init">
                <property name="forceShutdown" value="true"/>
            </bean>
        </property>
        <property name="userTransaction">
            <bean class="com.atomikos.icatch.jta.UserTransactionImp">
                <property name="transactionTimeout" value="300"/>
            </bean>
        </property>
    </bean>
    <!-- 配置數據源 -->
    <bean class="com.atomikos.jdbc.AtomikosDataSourceBean" destroy-method="close" id="jtaDataSource1" init-method="init">
        <property name="uniqueResourceName" value="ds1">
        <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource">
        <property name="xaProperties">
            <props>
                <prop key="url">
　　　　　　　　　　　　　　jdbc:mysql://192.168.22.58:3306/db?useUnicode=true&characterEncoding=UTF-8
                </prop>
                <prop key="user">root</prop>
                <prop key="password">root</prop>
                <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
        </property>
        <property name="minPoolSize" value="10"/>
        <property name="maxPoolSize" value="100"/>
        <property name="borrowConnectionTimeout" value="30"/>
        <property name="testQuery" value="select 1"/>
        <property name="maintenanceInterval" value="60"/>
    </bean>
    <!-- 配置數據源 -->
    <bean class="com.atomikos.jdbc.AtomikosDataSourceBean" destroy-method="close" id="jtaDataSource2" init-method="init">
        <property name="uniqueResourceName" value="ds2"/>
        <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
        <property name="xaProperties">
            <props>
                <prop key="url">
　　　　　　　　　　　　　　jdbc:mysql://192.168.22.59:3306/db?useUnicode=true&characterEncoding=UTF-8
                </prop>
                <prop key="user">root</prop>
                <prop key="password">root</prop>
                <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
        </property>
        <property name="minPoolSize" value="10"/>
        <property name="maxPoolSize" value="100"/>
        <property name="borrowConnectionTimeout" value="30"/>
        <property name="testQuery" value="select 1"/>
        <property name="maintenanceInterval" value="60"/>
   　</bean>

 

3.5 與mybatis整合

項目開發使用ssm框架，所以還要配置spring和mybatis整合：

首先通過逆向工程，生成兩個數據庫中兩個表的mapper和實體，這里小編把兩個數據庫生成的mapper放置到了連個不同的路徑下：

 

 

spring和mybatis結合，建立兩個sqlsessionfactory ，分別管理兩個數據庫：

<!-- 讓spring管理sqlsessionfactory 使用mybatis和spring整合包中的 -->
    <bean class="org.mybatis.spring.SqlSessionFactoryBean" id="sqlSessionFactory">
        <!-- 數據庫連接池 -->
        <property name="dataSource" ref="jtaDataSource1"/>
        <!-- 加載mybatis的全局配置文件 -->
        <property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml"/>
    </bean>
 
    <bean class="org.mybatis.spring.SqlSessionFactoryBean" id="sqlSessionFactory2">
        <!-- 數據庫連接池 -->
        <property name="dataSource" ref="jtaDataSource2"/>
        <!-- 加載mybatis的全局配置文件 -->
        <property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml"/>
    </bean>
 
    <!--指定mybatis的mapper文件的位置-->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.dmsd.studentdao"/>
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.dmsd.dao"/>
        <property name="sqlSessionFactory" ref="sqlSessionFactory2"/>
    </bean>

 

3.6 使用Spring AOP 添加事務

這里需要注意的是：通知的事務管理器是jtaTransactionManager，在前面配置Bean的時候配置的。要使用jta的 事務管理器。

<beans xmlns="https://www.springframework.org/schema/beans" xmlns:aop="https://www.springframework.org/schema/aop" xmlns:context="https://www.springframework.org/schema/context" xmlns:p="https://www.springframework.org/schema/p" xmlns:tx="https://www.springframework.org/schema/tx" xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance" xsi:schemalocation="https://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans-4.2.xsd
    https://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context-4.2.xsd
    https://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop-4.2.xsd https://www.springframework.org/schema/tx https://www.springframework.org/schema/tx/spring-tx-4.2.xsd
    https://www.springframework.org/schema/util https://www.springframework.org/schema/util/spring-util-4.2.xsd">
        <!-- 數據源 -->
        <property name="dataSource" ref="dataSource">
     
    <!-- 通知 -->
    <tx:advice id="txAdvice" transaction-manager="jtaTransactionManager">
        <tx:attributes>
            <!-- 傳播行為 -->
            <tx:method name="save*" propagation="REQUIRED"/>
            <tx:method name="insert*" propagation="REQUIRED"/>
            <tx:method name="add*" propagation="REQUIRED"/>
            <tx:method name="create*" propagation="REQUIRED"/>
            <tx:method name="delete*" propagation="REQUIRED"/>
            <tx:method name="update*" propagation="REQUIRED"/>
            <tx:method name="find*" propagation="SUPPORTS" read-only="true"/>
            <tx:method name="select*" propagation="SUPPORTS" read-only="true"/>
            <tx:method name="get*" propagation="SUPPORTS" read-only="true"/>
        </tx:attributes>
    </tx:advice>
<!--自動為切面方法中匹配的方法所在的類生成代理對象--> 
<aop:aspectj-autoproxy></aop:aspectj-autoproxy> 
 
</beans>

3.7 實現service

package com.dmsd.service;
 
import com.dmsd.api.UserService;
import com.dmsd.dao.TAllusersMapper;
import com.dmsd.pojo.TAllusers;
import com.dmsd.pojo.TStudent;
import com.dmsd.pojo.TUser;
import com.dmsd.studentdao.TStudentMapper;
import com.sun.org.apache.bcel.internal.generic.NEW;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
 
import javax.sql.DataSource;
import java.util.List;
import java.util.Map;
 
/**
 * Created by Ares on 2017/10/24.
 */
@Service
public class UserServiceImpl implements UserService {
 
    @Autowired
    TAllusersMapper tAllusersMapper;
 
    @Autowired
    TStudentMapper tStudentMapper;
 
    @Override
    public void addStudent2() {
        TAllusers tAllusers1 = tAllusersMapper.selectByPrimaryKey(1);
        System.out.println(tAllusers1);
 
        TStudent tStudent = new TStudent();
        tStudent.setAddress("langfang");
        tStudent.setName("AresCCCC");
        tStudentMapper.insert(tStudent);
 
        TAllusers tAllusers2 =new TAllusers();
        tAllusers2.setAddress("shagnhai");
        tAllusers2.setName("AresDDDD");
        tAllusersMapper.insert(tAllusers2);
 
//      int a =1/0;
 
    }
}

3.8 實現Controller

 1 package com.dmsd.controller;
 
import com.dmsd.api.UserService;
import com.dmsd.pojo.TUser;
import com.dmsd.tool.JacksonJsonUntil;
import com.fasterxml.jackson.core.JsonProcessingException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
 
/**
 * Created by Ares on 2017/10/24.
 */
@Controller
public class UserController {
 
    //注入api
    @Autowired
    private UserService userService;
 
    @RequestMapping("/addStudent2")
    @ResponseBody
    public void addStudent2() {
        userService.addStudent2();
    }
 
}

3.9 運行

在瀏覽器中輸入https://localhost:8080/addStudent2，查看數據庫：

當沒有報錯的時候，數據都插入進來：

 

 

 

 

當service中的int a =1/0;代碼解開注釋的時候，就會報錯，這樣兩個庫都插入不進去。

四、小結

分布式事務，系統分布式后，必然會出現的技術問題。

小編就分布式事務來說，小編使用分布式事務的解決機制后，必然會造成性能的消耗。在項目建立的時候，要避免分布式事務，如果實在避免不了，可以采取下面的幾個方案：

同一個web服務器，多個數據庫，可以使用Atomikos

跨越多個web服務器的事務，如果遠程調用支持事務傳播，那么使用JTA就可以；如果不支持事務傳播，進盡量轉化為一個web服務器的情況。

 

 

 

 

轉載：https://www.2cto.com/kf/201801/714523.html