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

一.以下介绍Spring中直接集成JOTM提供JTA事务管理、将JOTM集成到Tomcat中。 
（经过测试JOTM在批量持久化时有BUG需要修改源码GenericPool类解决)！ 
参考文章http://mavin.zhou.blog.163.com/blog/static/114522435200971822334475/ 
通过集成JOTM，直接在Spring中使用JTA事务 
JOTM(Java Open Transaction Manager)是ObjectWeb的一个开源JTA实现，它本身也是开源应用程序服务器JOnAS(Java Open Application Server)的一部分，为其提供JTA分布式事务的功能。 
Spring 2.0附带的依赖类库中虽然包含jotm类库，但是并不完整，你可以到http://jotm.objectweb.org下载完全版的JOTM。 
Spring为JOTM提供了一个org.springframework.transaction.jta.JotmFactoryBean支持类，通过该支持类可以方便地创建JOTM本地实例。 
1.将jotm的jar包lib目录下所有jar复制到项目中 
2.将jotm的jar包conf目录下carol.properties文件复制到项目类路径下,修改内容为:

Xml代码  

  1. # do not use CAROL JNDI wrapper
  2. carol.start.jndi=false
  3. # do not start a name server
  4. carol.start.ns=false
  5. # Naming Factory
  6. carol.jndi.java.naming.factory.url.pkgs=org.apache.naming

3.建立两个数据库，配置两个数据源

Xml代码  

  1. <!-- XAPool配置，内部包含了一个XA数据源，对应相应的数据库 -->
  2. <bean id="mysqlJta" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
  3. <!-- 内部XA数据源-->
  4. <property name="dataSource">
  5. <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
  6. <property name="transactionManager" ref="jotm"/>
  7. <property name="driverName" value="com.mysql.jdbc.Driver"/>
  8. <property name="url" value="jdbc:MySQL://localhost:3309/test"/>
  9. <property name="user" value="root"/>
  10. <property name="password" value=""/>
  11. </bean>
  12. </property>
  13. <property name="user" value="root"/>
  14. <property name="password" value=""/>
  15. </bean>
  16. <bean id="oracleJta" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
  17. <property name="dataSource">
  18. <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
  19. <property name="transactionManager" ref="jotm"/>
  20. <property name="driverName" value="oracle.jdbc.driver.OracleDriver"/>
  21. <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
  22. <property name="user" value="orcl"/>
  23. <property name="password" value=""/>
  24. </bean>
  25. </property>
  26. <property name="user" value="orcl"/>
  27. <property name="password" value=""/>
  28. </bean>

4.事务配置

Xml代码  

  1. <!-- JOTM本地实例 -->
  2. <bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean" />
  3. <!-- JTA事务管理器 -->
  4. <bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager">
  5. <property name="userTransaction" ref="jotm"/>
  6. </bean>
  7. <!-- JTA事务传播特性 -->
  8. <tx:advice id="txAdviceJta" transaction-manager="txManager">
  9. <tx:attributes>
  10. <tx:method name="Jta*"     isolation="DEFAULT" propagation="REQUIRED" rollback-for="Exception"/>
  11. <tx:method name="*" read-only="true"/>
  12. </tx:attributes>
  13. </tx:advice>
  14. <aop:config>
  15. <aop:advisor pointcut="execution(* com.xxxxl.service.impl..*(..))"   advice-ref="txAdviceJta" />
  16. </aop:config>
  17. <bean id="timerDaoMysql" class="com.xxxxl.TimerDaoImpl" scope="prototype">
  18. <property name="dataSource" ref="mysqlJta"></property>
  19. </bean>
  20. <bean id="timerDaoOracle" class="com.xxxxl.TimerDaoImpl" scope="prototype">
  21. <property name="dataSource" ref="oracleJta"></property>
  22. </bean>

二.以下介绍Spring中直接集成Atomikos提供JTA事务管理、将Atomikos集成到Tomcat中。(经过测试推荐此方法) 
Atomikos Transactions Essentials现在的版本是3.1.7,可以在http://www.atomikos.com/Main/TransactionsEssentialsDownloadForm 下载，在发布包里的examples文件夹下面有些例子，非常实用，我在使用中参考里面的例子很容易配置成功。1.将Atomikos的jar包dist目录下所有jar复制到项目中 
2.建立两个数据库，配置两个数据源。 
Atomikos数据源配置方法有三种分别有：SimpleDataSourceBean,AtomikosDataSourceBean,AtomikosNonXADataSourceBean可任选一种

Xml代码  

  1. <!-- Simple表示基础数据库连接配置 -->
  2. <bean id="oracleJta" class="com.atomikos.jdbc.SimpleDataSourceBean" init-method="init" destroy-method="close">
  3. <property name="uniqueResourceName">
  4. <value>OracleXADataSource</value>   <!--任意命名，但必须唯一-->
  5. </property>
  6. <property name="xaDataSourceClassName">
  7. <value>oracle.jdbc.xa.client.OracleXADataSource</value>
  8. </property>
  9. <property name="xaDataSourceProperties">
  10. <value>URL=jdbc:oracle:thin:@localhost:1521:orcl;user=orcl;password=</value>
  11. </property>
  12. <property name="exclusiveConnectionMode">
  13. <value>true</value>
  14. </property>
  15. <property name="connectionPoolSize">
  16. <value>3</value>
  17. </property>
  18. <property name="validatingQuery">
  19. <value>SELECT 1</value>
  20. </property>
  21. </bean>
  22. <!-- Atomikos表示必须要用到XA数据库驱动类,可设置连接池(经过测试推荐此方法) -->
  23. <bean id="oracleJta" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close" lazy-init="true">
  24. <property name="uniqueResourceName">
  25. <value>OracleXADataSource</value>
  26. </property>
  27. <property name="xaDataSourceClassName">
  28. <value>oracle.jdbc.xa.client.OracleXADataSource</value>
  29. </property>
  30. <property name="xaProperties">
  31. <props>
  32. <prop key="URL">jdbc:oracle:thin:@localhost:1521:orcl</prop>
  33. <prop key="user">orcl</prop>
  34. <prop key="password"></prop>
  35. </props>
  36. </property>
  37. <property name="poolSize"><value>1</value></property>
  38. <property name="maxPoolSize"><value>30</value></property>
  39. <property name="testQuery" value="SELECT 1 from dual"/>  <!--解决偶尔失去连接的bug-->
  40. </bean>
  41. <!-- AtomikosNon表示必须要用到普通数据库驱动类,可设置连接池 -->
  42. <bean id="oracleJta" class="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean">
  43. <property name="uniqueResourceName"><value>OracleXADataSource</value></property>
  44. <property name="user"><value>orcl</value></property>
  45. <property name="password"><value></value></property>
  46. <property name="url"><value>jdbc:oracle:thin:@192.168.1.217:1521:orcl</value></property>
  47. <property name="driverClassName"><value>oracle.jdbc.OracleDriver</value></property>
  48. <property name="poolSize"><value>1</value></property>
  49. <property name="borrowConnectionTimeout"><value>60</value></property>
  50. </bean>
  51. 另外一个数据库在这就不在写了，设置同上只是mysql的驱动类名为：xaDataSourceClassName:com.mysql.jdbc.jdbc2.optional.MysqlXADataSource

3.事务配置

Xml代码  

    1. <!-- Atomikos事务方法 -->
    2. <bean id="atomikosTransactionManager"
    3. class="com.atomikos.icatch.jta.UserTransactionManager"
    4. init-method="init" destroy-method="close">
    5. <property name="forceShutdown">
    6. <value>true</value>
    7. </property>
    8. </bean>
    9. <bean id="atomikosUserTransaction"
    10. class="com.atomikos.icatch.jta.UserTransactionImp">
    11. <property name="transactionTimeout" value="240" />
    12. </bean>
    13. <bean id="transactionManager"
    14. class="org.springframework.transaction.jta.JtaTransactionManager">
    15. <property name="transactionManager">
    16. <ref bean="atomikosTransactionManager" />
    17. </property>
    18. <property name="userTransaction">
    19. <ref bean="atomikosUserTransaction" />
    20. </property>
    21. </bean>
    22. 接下来的代码和上例类同就不再写。
时间： 2024-10-09 15:51:44

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

Spring事务隔离级别与传播机制，spring+mybatis+atomikos实现分布式事务管理

本文转载于本人另一博客[http://blog.csdn.net/liaohaojian/article/details/68488150] 1.事务的定义:事务是指多个操作单元组成的合集,多个单元操作是整体不可分割的,要么都操作不成功,要么都成功.其必须遵循四个原则(ACID). 原子性(Atomicity):即事务是不可分割的最小工作单元,事务内的操作要么全做,要么全不做: 一致性(Consistency):在事务执行前数据库的数据处于正确的状态,而事务执行完成后数据库的数据还是应该处于正确

spring事务隔离级别、传播行为以及spring+mybatis+atomikos实现分布式事务管理

转载自:http://blog.csdn.net/liaohaojian/article/details/68488150 1.事务的定义:事务是指多个操作单元组成的合集,多个单元操作是整体不可分割的,要么都操作不成功,要么都成功.其必须遵循四个原则(ACID). 原子性(Atomicity):即事务是不可分割的最小工作单元,事务内的操作要么全做,要么全不做: 一致性(Consistency):在事务执行前数据库的数据处于正确的状态,而事务执行完成后数据库的数据还是应该处于正确的状态,即数据完整

如何配置分布式事务

在使用SQL Server时有时会用到分布式事务,下面是我总结的:如何配置分布式事务的详细步骤 1. 双方启动MSDTC服务 MSDTC服务提供分布式事务服务,如果要在数据库中使用 SQL Server分布式事务,必须在参与的双方服务器启动MSDTC(Distributed Transaction Coordinator)服务. 2. 打开双方135端口 MSDTC服务依赖于RPC(Remote Procedure Call (RPC))服务,RPC使用135端口,保证RPC服务启动,如果服务器

使用Atomikos实现JTA分布式事务

使用Atomikos实现JTA分布式事务 在这篇文章中: 1.1 JTA事务模型 2 JTA规范接口 3 Atomikos分布式事务 本文全面的介绍了JTA分布式事务模型和接口规范,以及开源的分布式事务解决方案Atomikos.笔者认同"talk is cheap,show me the code",因此在文章最后,给出一个完整的Atomikos与spring.mybatis整合的完整案例. 1 JTA规范 Java事务API(JTA:Java Transaction API)和它的同

javaweb分布式事务

分布式事务是指操作多个数据库之间的事务,spring的 org.springframework.transaction.jta.JtaTransactionManager,提供了分布式事务支持.如果使 用WAS的JTA支持,把它的属性改为WebSphere对应的TransactionManager.     在tomcat下,是没有分布式事务的,不过可以借助于第三方软件jotm(Java Open Transaction Manager )和AtomikosTransactionsEssenti

Spring分布式事务实现

分布式事务是指操作多个数据库之间的事务,spring的org.springframework.transaction.jta.JtaTransactionManager,提供了分布式事务支持.如果使用WAS的JTA支持,把它的属性改为WebSphere对应的TransactionManager.     在tomcat下,是没有分布式事务的,不过可以借助于第三方软件jotm(Java Open Transaction Manager )和AtomikosTransactionsEssential

Atomikos实现分布式事物管理

分布式事务管理,简单来说就是多个数据库之间的事务管理.之前也试过使用Spring动态切换数据库,通过继承AbstractRoutingDataSource重写determineCurrentLookupKey()方法,来决定使用那个数据库.在开启事务之前,通过改变lookupKey来达到切换数据源目的.但是这种方法多个数据库之前没办法做事务管理,或许对于主从(读写)数据库会好用一些,而对于需要一个操作中更新多个数据库的情况,使用Atomikos或许会更好一些. 本文采用spring4+hiber

Hibernate如何实现分布式事务

[http://blog.csdn.net/liu78778/article/details/4805423] 对于横跨多个Hibernate SessionFacotry的分布式事务,只需简单地将 JtaTransactionManager 同多个 LocalSessionFactoryBean 的定义结合起来作为事务策略.你的每一个DAO通过bean属性得到各自的 SessionFactory 引用. 如果所有的底层JDBC数据源都是支持事务的容器,那么只要业务对象使用了 JtaTransa

LCN分布式事务管理（一）

前言 好久没写东西了,9月份换了份工作,一上来就忙的要死.根本没时间学东西,好在新公司的新项目里面遇到了之前没遇到过的难题.那遇到难题就要想办法解决咯,一个请求,调用两个服务,同时操作更新两个数据库.这就带来事务不一致的问题了,分布式事务管理被强行拉出来了.导致原本两个springboot的单体项目,必须要协同管理起来.刚好微服务也接触过,小试牛刀咯. 框架介绍 LCN分布式事务框架其本身并不创建事务,而是基于对本地事务的协调从而达到事务一致性的效果 核心步骤 创建事务组是指在事务发起方开始执行