使用Atomikos Transactions Essentials实现多数据源JTA分布式事务

buaashang 2007-09-10

9.17 update:使用NonXADataSourceBean. Mysql在5.0版本和Connecter/J5.0版本后提供了XADatasource支持，如果使用了支持XADatasouce版本，可以参考2楼补充.

最近做的project中遇到要将数据库中的表分布到两台不同的服务器上的Mysql5.0中，project主要使用spring+ibatis。因此需要JTA的支持，但是tomcat不支持，所以就搜索开源的JTA实现。

最开始使用的是JOTM，但是使用中不能自动rollback，无论什么情况都commit。然后看到infoq上一篇文章提到AtomikosTransactionsEssentials，AtomikosTransactionsEssentials3.0是Atomikos开发的核心事务引擎，支持JDBC以及JMS的JTA/XA事务。易于部署，轻量级，同时支持JDBC以及JMS。

AtomikosTransactionsEssentials现在的版本是3.1.7,可以在http://www.atomikos.com/Main/TransactionsEssentialsDownloadForm下载，在发布包里的examples文件夹下面有些例子，非常实用，我在使用中参考里面的例子很容易配置成功。先将发布包里面dist目录下的atomikos-util.jar，transactions.jar，transactions-api.jar，transactions-jta.jarcopy到项目lib里面，如果使用hibernate则需要将另外两个hibernate相关的jar页copy到项目里面，spring配置文件如下:

 
  1. <!-- 第一个数据库 -->  
  2. <bean id="dataSource" class="com.atomikos.jdbc.SimpleDataSourceBean" init-method="init" destroy-method="close">  
  3.     <property name="uniqueResourceName">  
  4.         <value>mysql/main</value>  
  5.     </property>  
  6.     <property name="xaDataSourceClassName">  
  7.         <!-- 使用Mysql XADataSource(mysql>=5.0, Connector/J>=5.0才可以支持XADatasource)-->  
  8.         <value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>  
  9.     </property>  
  10.     <property name="xaDataSourceProperties">  
  11.         <value>URL=${jdbc.url};user=${jdbc.username};password=${jdbc.password}</value>  
  12.     </property>  
  13.     <property name="exclusiveConnectionMode">  
  14.         <value>true</value>  
  15.     </property>  
  16.     <property name="connectionPoolSize">  
  17.         <value>3</value>  
  18.     </property>  
  19.     <property name="validatingQuery">  
  20.         <value>SELECT 1</value>  
  21.     </property>  
  22. </bean>  
  23. <!-- 第二个数据库 -->  
  24. <bean id="dataSourceB" class="com.atomikos.jdbc.SimpleDataSourceBean" init-method="init" destroy-method="close">  
  25.     <property name="uniqueResourceName">  
  26.         <value>mysql/news</value>  
  27.     </property>  
  28.     <property name="xaDataSourceClassName">  
  29.         <!-- 使用Mysql XADataSource(mysql>=5.0, Connector/J>=5.0才可以支持XADatasource)-->  
  30.         <value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>  
  31.     </property>  
  32.     <property name="xaDataSourceProperties">  
  33.         <value>URL=${jdbc.url.b};user=${jdbc.username.b};password=${jdbc.password.b}</value>  
  34.     </property>  
  35.     <property name="exclusiveConnectionMode">  
  36.         <value>true</value>  
  37.     </property>  
  38.     <property name="connectionPoolSize">  
  39.         <value>3</value>  
  40.     </property>  
  41.     <property name="validatingQuery">  
  42.         <value>SELECT 1</value>  
  43.     </property>  
  44. </bean>  
  45.   
  46.   
  47. <bean id="lobHandler" class="org.springframework.jdbc.support.lob.DefaultLobHandler" />  
  48.   
  49. <!-- 第一个数据库的sqlMapClient -->  
  50. <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">  
  51.     <property name="configLocation">  
  52.         <!-- 包含第一个数据库表的map -->  
  53.         <value>classpath:/sqlmap-config.xml</value>  
  54.     </property>  
  55.     <property name="dataSource" ref="dataSource" />  
  56.     <property name="lobHandler" ref="lobHandler" />  
  57. </bean>  
  58. <!-- 第二个数据库的sqlMapClient -->  
  59. <bean id="sqlMapClientB" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">  
  60.     <property name="configLocation">  
  61.         <!-- 包含第一个数据库表的map -->  
  62.         <value>classpath:/sqlmap-configb.xml</value>  
  63.     </property>  
  64.     <property name="dataSource" ref="dataSourceB" />  
  65.     <property name="lobHandler" ref="lobHandler" />  
  66. </bean>  
  67.   
  68. <!-- Construct Atomikos UserTransactionManager, needed to configure Spring -->  
  69. <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init"  
  70.     destroy-method="close">  
  71.     <!--  when close is called, should we force transactions to terminate or not? -->  
  72.     <property name="forceShutdown">  
  73.         <value>true</value>  
  74.     </property>  
  75. </bean>  
  76.   
  77. <!-- Also use Atomikos UserTransactionImp, needed to configure Spring  -->  
  78. <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">  
  79.     <property name="transactionTimeout" value="240" />  
  80. </bean>  
  81.   
  82. <!-- Configure the Spring framework to use JTA transactions from Atomikos -->  
  83. <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">  
  84.     <property name="transactionManager">  
  85.         <ref bean="atomikosTransactionManager" />  
  86.     </property>  
  87.     <property name="userTransaction">  
  88.         <ref bean="atomikosUserTransaction" />  
  89.     </property>  
  90. </bean>  

事务的配置, 使用了spring2.0的语法，所以将namesapce也帖出来了.

 
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans"  
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.        xmlns:aop="http://www.springframework.org/schema/aop"  
  5.        xmlns:tx="http://www.springframework.org/schema/tx"  
  6.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
  7.            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd  
  8.            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd"  
  9.        default-autowire="byName" default-lazy-init="true">  
  10.     <!-- 支持 @AspectJ 标记-->  
  11.     <aop:aspectj-autoproxy/>  
  12.   
  13.     <aop:config proxy-target-class="true">  
  14.         <aop:advisor pointcut="execution(* *Facade.*(..))" advice-ref="txAdvice"/>  
  15.         <aop:advisor pointcut="execution(* *Manager.*(..))" advice-ref="txAdvice"/>  
  16.     </aop:config>  
  17.   
  18.     <tx:advice id="txAdvice">  
  19.         <tx:attributes>  
  20.             <tx:method name="get*" read-only="true"/>  
  21.             <tx:method name="find*" read-only="true"/>  
  22.             <tx:method name="has*" read-only="true"/>  
  23.             <tx:method name="locate*" read-only="true"/>  
  24.             <tx:method name="*"/>  
  25.         </tx:attributes>  
  26.     </tx:advice>  
  27. </beans>  

这样配置以后就可以使用分布式事务，测试中出现异常时事务也自动提交。和JOTM相比AtomikosTransactionsEssentials更加稳定，它原来是商业项目，现在开源了。象mysql一样卖服务支持的。而且论坛页比较活跃，有问题很快可以解决。

buaashang

buaashang

相关推荐

使用springboot+jta+atomikos 分布式事物管理

当项目在连接多个数据库时可能会发生事务问题，即一个库的事务不可能去操作另一个数据库的事务，这时就需要使用atomikos对数据库的事务进行统一的管理。第二步配置数据源，我这里有2个数据库，你有多少就加多少。然后创建DBConfig1和DBConfig2，这

fengdos / 0评论 2019-12-19

基于spring,Atomikos,mybatis的分布式动态数据源JTA实现

本文的几个关键词，分布式数据源，数据源的动态寻找，分布式事务JTA实现。对于一些较大规模的应用，单个数据源是无法支撑起庞大的用户量，需要引入多数据源，水平层面进行分库分表，降低单个DB的负载。另外，跨库就意味着之前单DB的事务就失效了，所以J2EE提出了J

cuterabbitbaby / 0评论 2015-09-24

spring + atomikos解决多数据源事务管理

一般的企业管理系统免不了要访问多个数据库，如框架数据库、仓库数据库等，但spring的jdbc事务只支持一个数据源的事务配置，为了在tomcat中支持多数据源事务，可以采用开源框架atomikos来进行配置。采用的开发环境:Spring4 + hibern

laiwanwanyihao / 0评论 2016-01-27

基于Spring声明式事务的 分布式事务管理

开发传统应用遇到的最大问题就是多数据源的事务一致性问题， 下面介绍一种常用的分布式事务处理方式的使用。开发环境：Eclipse+Java1.7 + tomcat7， 另外使用到的开源框架 Spring3.X. 提到分布式事务大家首先想到的肯定是jta，我们

shixiaoguo0 / 0评论 2015-09-02

spring+mybatis+Atomikos JTA事务配置说明

Atomikos是一个公司名字，旗下最著名的莫过于其Atomikos的事务管理器产品。目前，Oracle、Informix、DB2和Sybase等各大数据库厂家都提供对XA的支持。XA协议采用两阶段提交方式来管理分布式事务。XA接口提供资源管理器与事务管理

choice0 / 0评论 2013-10-16

【转】使用Atomikos Transactions Essentials实现多数据源JTA分布式事务

Atomikos数据源配置方法有三种。Simple表示基础数据库连接配置。--任意命名，但必须唯一-->. Atomikos表示必须要用到XA数据库驱动类,可设置连接池

shiaisun / 0评论 2013-04-03

在spring、tomcat中使用多数据源并支持分布式事务管理

题目起得有点模糊，第一次接触这东西，还不怎么理解。小项目，没有用分布式，但要操作两个数据库。本以为随便用spring配置两个数据源就搞定，查询是没问题，问题是有一个数据库老是插不进数据。Google狂搜之后，大概了解到是事务控制的问题。我用的是spring

BlogForUS / 0评论 2012-03-06

Spring + Atomikos配置多个数据源，并且管理事务

本例子中使用的spring3，atomikos的下载地址：Atomikos，一个免费版和收费版的，注意区分。

zhangdy0 / 0评论 2011-05-23

jta

最近做个移动多维平台，涉及到短信群发任务，短信需要插入到另一台服务器数据库中，所以涉及到jta分布式事物，atomikos，jotm的选择，atomikos的xa驱动或者直接用非xa驱动，jta事务据说比较吃性能，各种纠结。暂且先配置个atomikos的非

especialjie / 0评论 2011-04-19

Spring使用JTA进行分布式事务管理

使用SpringJTA进行分布式事务管理,需要引入第三方UserTransaction。JOTM是一个独立的开源事务管理器，它实现了 XA 协议并且与 JTA API 兼容。这里使用的是Atomikos作为事务管理器。

dananhai / 0评论 2011-03-31

JTA集成JOTM或Atomikos配置分布式事务(Tomcat应用服务器)

一.以下介绍Spring中直接集成JOTM提供JTA事务管理、将JOTM集成到Tomcat中。-- XAPool配置，内部包含了一个XA数据源，对应相应的数据库 -->

buaashang / 0评论 2010-01-15

Spring JTA应用JOTM & Atomikos I Application

关于SpringJTA的介绍非常多了，这里就不再一再阐述其优越性怎么怎么了，直接开始正题。一个大致的需求如下，用户在进行增删改操作时，会同时更新2至3个数据库的数据表，操作需要事务来包裹，以便在操作其中一个数据库的数据表失败时，可以将其他数据库已执行的动作

taotaoSi / 0评论 2007-12-11