Spring+iBatis+Atomikos实现JTA事务

╰半橙微兮° 2022-06-16 14:24 256阅读 0赞

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]（Java Message Service）[应用程序][Link 1]接口是一个[Java平台][Java 1]中关于面向[消息中间件][Link 2]（MOM）的API，用于在两个应用程序之间，或[分布式系统][Link 3]中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供[商都][Link 4]对JMS提供支持。

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

l 更好的整合您的项目

l 集成Hibernate

atomikos配合spring的使用方法：   
  
1、依赖包   
Atomikos的：   
transactions-jdbc   
transactions-jta   
transactions-api   
transactions   
atomikos-utils   
还有一个不要忘了，是jta的包。   
用maven要简单一点，只需要加入两个依赖：

Xml代码

1.  **<****dependency****>**
2.  **<****groupId****>**com.atomikos**</****groupId****>**
3.  **<****artifactId****>**transactions-jdbc**</****artifactId****>**
4.  **<****version****>**3.7.0**</****version****>**
5.  **</****dependency****>**
6.  **<****dependency****>**
7.  **<****groupId****>**javax.transaction**</****groupId****>**
8.  **<****artifactId****>**jta**</****artifactId****>**
9.  **<****version****>**1.1**</****version****>**
10. **</****dependency****>**

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

Xml代码

1.  **<****bean** id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"**>**
2.  **<****property** name="uniqueResourceName" value="ds1"**/>**
3.  **<****property** name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"**/>**
4.  **<****property** name="xaProperties"**>**
5.  **<****props****>**
6.  **<****prop** key="url"**>**jdbc:mysql://localhost/test**</****prop****>**
7.  **<****prop** key="user"**>**test**</****prop****>**
8.  **<****prop** key="password"**>**test**</****prop****>**
9.  **</****props****>**
10. **</****property****>**
11. **<****property** name="minPoolSize" value="10" **/>**
12. **<****property** name="maxPoolSize" value="100" **/>**
13. **<****property** name="borrowConnectionTimeout" value="30" **/>**
14. **<****property** name="testQuery" value="select 1" **/>**
15. **<****property** name="maintenanceInterval" value="60" **/>**
16. **</****bean****>**

再来一个sybase的配置举例：

Xml代码

1.  **<****bean** id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"**>**
2.  **<****property** name="uniqueResourceName" value="ds2"**/>**
3.  **<****property** name="xaDataSourceClassName" value="com.sybase.jdbc3.jdbc.SybXADataSource"**/>**
4.  **<****property** name="xaProperties"**>**
5.  **<****props****>**
6.  **<****prop** key="serverName"**>**192.168.1.10**</****prop****>**
7.  **<****prop** key="portNumber"**>**2638**</****prop****>**
8.  **<****prop** key="databaseName"**>**test**</****prop****>**
9.  **<****prop** key="user"**>**test**</****prop****>**
10. **<****prop** key="password"**>**test**</****prop****>**
11. **</****props****>**
12. **</****property****>**
13. **<****property** name="minPoolSize" value="10" **/>**
14. **<****property** name="maxPoolSize" value="100" **/>**
15. **<****property** name="borrowConnectionTimeout" value="30" **/>**
16. **<****property** name="testQuery" value="select 1" **/>**
17. **<****property** name="maintenanceInterval" value="60" **/>**
18. **</****bean****>**

3、使用数据源   
 这一步与平时好像没什么不一样。我做例子的时候是用mybatis，配置如下：

Xml代码

1.  **<****bean** id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean"**>**
2.  **<****property** name="dataSource" ref="dataSource1"**/>**
3.  **</****bean****>**
4.  **<****bean** id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean"**>**
5.  **<****property** name="dataSource" ref="dataSource2"**/>**
6.  **</****bean****>**

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

Xml代码

1.  **<****bean** class="org.mybatis.spring.mapper.MapperScannerConfigurer"**>**
2.  **<****property** name="basePackage" value="xx.xx;" **/>**
3.  **<****property** name="sqlSessionFactory" ref="sqlSessionFactory1"**/>**
4.  **</****bean****>**
5.  **<****bean** class="org.mybatis.spring.mapper.MapperScannerConfigurer"**>**
6.  **<****property** name="basePackage" value="yy.yy;" **/>**
7.  **<****property** name="sqlSessionFactory" ref="sqlSessionFactory2"**/>**
8.  **</****bean****>**

用spring JdbcTemplate应该与普通使用没什么不同，用hibernate可能会有点不一样，没测试过。   
  
4、配置jta事务管理   
 这是很关键的一步。原理我不太懂，例子如下：

Xml代码

1.  **<****bean** id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"**>**
2.  **<****property** name="transactionManager"**>**
3.  **<****bean** class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close"**>**
4.  **<****property** name="forceShutdown" value="true"**/>**
5.  **</****bean****>**
6.  **</****property****>**
7.  **<****property** name="userTransaction"**>**
8.  **<****bean** class="com.atomikos.icatch.jta.UserTransactionImp"**/>**
9.  **</****property****>**
10. **</****bean****>**

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

Xml代码

1.  **<****tx:annotation-driven****/>**

（注意，本来要配置transaction-manager属性，如：<tx:annotation-driven  transaction-manager="transactionManager" />。这里没有配置是因为它的默认值是transactionManager）   
  
5、atomikos的配置文件jta.properties   
 这个文件一般放在根路径吧，与log4j.properties类似。jta.properties也可命名为transactions.properties。如果不配置这个文件，项目也能启动，因为几乎所有配置项都有默认值。最好还是配置了，详细配置信息请查看：http://www.atomikos.com/Documentation/JtaProperties。   
  
6、不管是用JdbcTemplate、mybatis还是hibernate，应该都可以写代码来测试了。。。

[Java]: http://baike.baidu.com/view/3292569.htm
[Link 1]: http://baike.baidu.com/view/330120.htm
[Java 1]: http://baike.baidu.com/view/209634.htm
[Link 2]: http://baike.baidu.com/view/3118541.htm
[Link 3]: http://baike.baidu.com/view/991489.htm
[Link 4]: http://baike.baidu.com/view/19763.htm