Spring3 JOTM实现分布式事务 博客分类： Spring Spring3JOTM分布式事务JTA
Spring3 JOTM实现分布式事务
1. 创建web工程,将JOTM版本中lib下所有jar包拷贝到web-inf的lib下面
相关准备工作参考:http://jackyin5918.iteye.com/blog/1922379
主要包括:建数据库用户,建表,考jar包,拷贝tomcat 7jdbc pool的jar.
配置carol.properties,放置到src目录下面.
2. spring分布式事务的相关配置
注意这个org.springframework.transaction.jta.JotmFactoryBean类在Spring3中已经没有了,
需要下载spring2.5.6(附件中有)的代码然后拷贝代码,再在工程中新建一个包,
org.springframework.transaction.jta,然后创建JotmFactoryBean类.
<!-- 分布式 事务处理 开始.....-->
<!-- PropertyPlaceholderconfigure是一个Bean后处理器,它读取属性文件信息,
并将这些信息设置为Spring配置文件元数据,这里用于读取数据库连接信息
-->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>dbconn.properties</value>
<!-- 这里可列出多个属性文件 -->
</list>
</property>
</bean>
<!-- jotm实例,就是userTransaction(用户事务管理器) -->
<bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean" />
<!--
注意这个org.springframework.transaction.jta.JotmFactoryBean类在Spring3中已经没有了,
需要下载spring2.5.6的代码然后拷贝代码,再在工程中新建一个包,
org.springframework.transaction.jta,然后创建JotmFactoryBean类.
-->
<!-- jta分布式事务管理器 -->
<bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="userTransaction" ref="jotm" />
</bean>
<!--mysql数据源-->
<bean id="mysqlDataSource" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
<property name="dataSource">
<bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
<property name="transactionManager" ref="jotm"/>
<property name="driverName" value="${dbmysql.driverClassName}"/>
<property name="url" value="${dbmysql.url}"/>
<property name="user" value="${dbmysql.username}"/>
<property name="password" value="${dbmysql.password}"/>
</bean>
</property>
<!-- 这里必须额外再配置用户名和密码 -->
<property name="user" value="${dbmysql.username}"/>
<property name="password" value="${dbmysql.password}"/>
</bean>
<!--oracle数据源-->
<bean id="oracleDataSource" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
<property name="dataSource">
<bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
<property name="transactionManager" ref="jotm"/>
<property name="driverName" value="${dboracle.driverClassName}"/>
<property name="url" value="${dboracle.url}"/>
<property name="user" value="${dboracle.username}"/>
<property name="password" value="${dboracle.password}"/>
</bean>
</property>
<!-- 这里必须额外再配置用户名和密码 -->
<property name="user" value="${dboracle.username}"/>
<property name="password" value="${dboracle.password}"/>
</bean>
<!-- 配置和mysql数据源管理的数据库操作模板 ,用于操作数据库-->
<bean id = "mysqlJdbcTpl" class = "org.springframework.jdbc.core.JdbcTemplate">
<property name = "dataSource" ref="mysqlDataSource"/>
</bean>
<!-- 配置和oracle数据源管理的数据库操作模板,用于操作数据库 -->
<bean id = "oracleJdbcTpl" class = "org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="oracleDataSource"/>
</bean>
<!-- 配置两个数据源的Dao,并注入 JDBC数据库操作模板JdbcTemplate-->
<bean id = "jtaDaoMysqlImp1" class = "test.spring.transaction.jta.JtaDaoMysqlImp1">
<property name="jtp" ref="mysqlJdbcTpl"/>
</bean>
<bean id = "jtaDaoOracleImp1" class = "test.spring.transaction.jta.JtaDaoOracleImp1">
<property name="jtp" ref="oracleJdbcTpl"/>
</bean>
<!-- 配置业务逻辑Bean,并注入相关的Dao组件 -->
<bean id = "businessBean" class = "test.spring.transaction.jta.BusinessDaoImp1">
<property name="jtaDaoMysql" ref="jtaDaoMysqlImp1"/>
<property name="jtaDaoOracle" ref="jtaDaoOracleImp1"/>
</bean>
<!-- 全局事务配置,主要是使用的transaction-manager不一样
配置增强处理的bean(相当于切面类),也是Spring自动生成普通
业务逻辑bean(targetBean)的代理Bean.里面的tx:method配置每个方法的事务属性,
name配置方法名,可使用通配符.
-->
<tx:advice id="txJpaAdvice" transaction-manager="txManager">
<!-- 配置详细的事务语义 -->
<tx:attributes>
<!-- 表示get开头的方法是只读的 -->
<tx:method name="get*" read-only="true" />
<!-- 其他方法使用默认的事务设置 -->
<tx:method name="*" />
</tx:attributes>
</tx:advice>
<!-- 全局事务切面配置,AOP元素配置 -->
<aop:config>
<!--
配置一个切入点 test.spring.transaction.jta包下面所有已Imp1结尾的类的所有方法,
即BusinessDaoImp1的doBusinuss()方法
-->
<aop:pointcut id="myJpaPoint"
expression="execution(* test.spring.transaction.jta.*Imp1.*(..))" />
<!-- 配置 (事务代理)切入点(aop:pointcut) 和 切面类(tx:advice),将二者关联起来 -->
<aop:advisor advice-ref="txJpaAdvice" pointcut-ref="myJpaPoint" />
</aop:config>
<!-- 分布式 事务处理 结束-->
3. 测试.
执行:test.spring.transaction.jta.TestSpringJTAClient类
初始化:
两个数据库的表都建立了唯一索引,保证数据不能重复插入,
在mysql中插入一条数据oracle中没有数据.
程序执行:
调用businessDao.doBusinuss();分别往oracle和msyql中插入同一条数据(
与mysql中已有数据重复)
在织入全局事务AOP之前,因为oracle中没有数据,所以往oracle中插入数据正常,
在mysql中插入数据报异常.程序执行完毕后,oracle中会被插入一条数据.
而在织入全局事务AOP之后,mysql中插入数据异常导致全局事务回滚,
这样,程序执行完毕后,oracle中仍然没有数据.
4. 尝试使用tomcat7的连接池代替XAPool连接池.
需要替换 org.enhydra.jdbc.pool.StandardXAPoolDataSource和
org.enhydra.jdbc.standard.StandardXADataSource
还没搞定.不知道怎么配置,待研究...
spring中使用 tomcat jdbc 连接池配置(局部事务,不支持全局事务的配置)
http://weitd.iteye.com/blog/1497020
注:根据类名找jar包的 网站:
http://www.jarfinder.com/index.php/jars/versionInfo/66324
附件文件名 后缀 需要相应的修改为 001,002,003,004