Spring3 JOTM实现分布式事务

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