atomikos实现多数据源支持分布式事务管理（spring、tomcat、JTA）

Atomikos TransactionsEssentials 是一个可靠的库，能够加入到您的Java应用程序，也就是说为了使用这个产品，您必须添加一些jar文件（包括在dist和lib文件夹下）到您的应用程序或者应用程序服务器。

原由： 
小项目，没有用分布式，但要操做两个数据库。本觉得随便用spring配置两个数据源就搞定，查询是没问题，问题是有一个数据库总是插不进数据。Google狂搜以后，大概了解到是事务控制的问题。我用的是spring的声明式事务管理(<tx:annotation-driven/>)。用通常的数据源配置，只有一个数据源的事务生效，其它数据源只能读不能写。 

有帖子说，要支持多数据源的事务，只能用JTA事务管理（没用过 -_-||），并且应用服务器还不能是Tomcat（一直在用tomcat，不想换-_-!!），头疼了。幸好后面还有说，有第三方的实现支持JTA事务管理，一是JOTM，一是Atomikos。只要用了其中一个，还能继续用Tomcat。由于名字短，先考虑用JOTM。到官网一看，最后更新日期是2010年。。呃。。转向Atomikos。在Atomikos的官网看看文档，看看例子，边作边调试，一个下午下来，总算有点成果，高兴之余作个记录。其中会涉及到一些概念，好比分布式事务、JTA、XA，我都有搜来了解一下，因理解肤浅无法作记录。下面只是记录

 Atomikos TransactionsEssentials 是一个为Java平台提供增值服务的而且开源类事务管理器，如下是包括在这个开源版本中的一些功能：

l  全面崩溃 / 重启恢复

l  兼容标准的SUN公司JTA API

l  嵌套事务

l  为XA和非XA提供内置的JDBC适配器

注释：XA：XA协议由Tuxedo首先提出的，并交给X/Open组织，做为资源管理器（数据库）与事务管理器的接口标准。目前，Oracle、Informix、DB2和Sybase等各大数据库厂家都提供对XA的支持。XA协议采用两阶段提交方式来管理分布式事务。XA接口提供资源管理器与事务管理器之间进行通讯的标准接口。XA协议包括两套函数，以xa_开头的及以ax_开头的。

如下的函数使事务管理器能够对资源管理器进行的操做：

　　1）xa_open,xa_close：创建和关闭与资源管理器的链接。

　　2）xa_start,xa_end：开始和结束一个本地事务。

　　3）xa_prepare,xa_commit,xa_rollback：预提交、提交和回滚一个本地事务。

　　4）xa_recover：回滚一个已进行预提交的事务。

　　5）ax_开头的函数使资源管理器能够动态地在事务管理器中进行注册，并能够对XID(TRANSACTION IDS)进行操做。

　　6）ax_reg,ax_unreg；容许一个资源管理器在一个TMS(TRANSACTION MANAGER SERVER)中动态注册或撤消注册。

l  内置的JMS适配器XA-capable JMS队列链接器

注释：JMS:jms即Java消息服务（Java Message Service）应用程序接口是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通讯。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。

l  经过XA API兼容第三方适配器

l  更好的整合您的项目

l  集成Hibernate

atomikos配合spring的使用方法： 

一、依赖包 
Atomikos的： 
transactions-jdbc 
transactions-jta 
transactions-api 
transactions 
atomikos-utils 
还有一个不要忘了，是jta的包。 
用maven要简单一点，只须要加入两个依赖： 

Xml代码 

<dependency>  
    <groupId>com.atomikos</groupId>  
    <artifactId>transactions-jdbc</artifactId>  
    <version>3.7.0</version>  
</dependency>  
<dependency>  
    <groupId>javax.transaction</groupId>  
    <artifactId>jta</artifactId>  
    <version>1.1</version>  
</dependency>  

二、配置数据源 
    这一步是比较重要的。要用AtomikosDataSourceBean，而不是之前用的链接池如dbcp。最好也用XA(这东西我还不太懂)，注意jdbc的连接地址和登录帐号与普通链接池的配置的格式不同。下面是一个mysql数据库的配置举例： 

Xml代码 

<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">  
    <property name="uniqueResourceName" value="ds1"/>  
    <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>  
    <property name="xaProperties">  
        <props>  
            <prop key="url">jdbc:mysql://localhost/test</prop>  
            <prop key="user">test</prop>  
            <prop key="password">test</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>  

再来一个sybase的配置举例： 

Xml代码 

<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">  
    <property name="uniqueResourceName" value="ds2"/>  
    <property name="xaDataSourceClassName" value="com.sybase.jdbc3.jdbc.SybXADataSource"/>  
    <property name="xaProperties">  
        <props>  
            <prop key="serverName">192.168.1.10</prop>  
                        <prop key="portNumber">2638</prop>  
                        <prop key="databaseName">test</prop>  
            <prop key="user">test</prop>  
            <prop key="password">test</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>  

三、使用数据源 
    这一步与平时好像没什么不同。我作例子的时候是用mybatis，配置以下： 

Xml代码 

<bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">  
    <property name="dataSource" ref="dataSource1"/>  
</bean>  
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">  
    <property name="dataSource" ref="dataSource2"/>  
</bean>  

固然，mybatis还要配置一下映射文件的自动扫描，这里与atomikos无关： 

Xml代码 

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  
    <property name="basePackage" value="xx.xx;" />  
    <property name="sqlSessionFactory" ref="sqlSessionFactory1"/>  
</bean>  
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  
    <property name="basePackage" value="yy.yy;" />  
    <property name="sqlSessionFactory" ref="sqlSessionFactory2"/>  
</bean>  

用spring JdbcTemplate应该与普通使用没什么不一样，用hibernate可能会有点不同，没测试过。 

四、配置jta事务管理 
    这是很关键的一步。原理我不太懂，例子以下： 

Xml代码 

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">  
    <property name="transactionManager">  
        <bean class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">  
            <property name="forceShutdown" value="true"/>  
        </bean>  
    </property>  
    <property name="userTransaction">  
        <bean class="com.atomikos.icatch.jta.UserTransactionImp"/>  
    </property>  
</bean>  

固然，用spring的声明式事务配置，再加上一行： 

Xml代码 

<tx:annotation-driven/>  

（注意，原本要配置transaction-manager属性，如：<tx:annotation-driven transaction-manager="transactionManager"/>。这里没有配置是由于它的默认值是transactionManager） 

五、atomikos的配置文件jta.properties      这个文件通常放在根路径吧，与log4j.properties相似。jta.properties也可命名为transactions.properties。若是不配置这个文件，项目也能启动，由于几乎全部配置项都有默认值。最好仍是配置了，详细配置信息请查看：http://www.atomikos.com/Documentation/JtaProperties。  六、不论是用JdbcTemplate、mybatis仍是hibernate，应该均可以写代码来测试了。。