分布式事务处理两阶段提交实例2

标签: | 发表时间:2017-01-11 02:44 | 作者:y806839048
分享到:
出处:http://www.iteye.com

引言:
  Spring 通过AOP技术可以让我们在脱离EJB的情况下享受声明式事务的丰盛大餐。
  通过配合使用ObjectWeb的JOTM开源项目,在不需要Java EE应用服务器的情况下,Spring也可以提供JTA事务。

Sping对JTA支持的三种方式:
  1. 直接集成JOTM提供JTA事务管理(无应用服务器支持,常用于单元测试)
  2. 引用应用服务器(如Tomcat)的JNDI数据源,间接实现JTA事务管理
  3. 使用特定于应用服务器的事务管理器,使用JTA事务的高级功能(Weblogic,Websphere)

1. JOTM直接集成
1.1. 将JOTM以下类库添加到类路径中: 
  jotm.jar 
  xapool.jar 
  jotm_jrmp_stubs.jar 
  jta-spec1_0_1.jar 
  connector-1_5.jar

1.2. 编写JOTM配置文件,放到类路径下 
  carol.properties 
  #JNDI调用协议 
  carol.protocols=jrmp 
  #不使用CAROL JNDI封装器 
  carol.start.jndi=false 
  #不启动命名服务器 
  carol.start.ns=false

1.3. 在MySQL上建立两个数据库 
  在MySQL数据库中运行SQL脚本,建立topicdb和postdb两个数据库,
  在topicdb数据库中创建t_topic表,在postdb数据库中创建t_post表。
  我们希望在这两个数据库上进行JTA事务。

1.4. 在Spring配置文件中配置JOTM,并实现具体业务类
代码清单 1 applicationContext-jta.xml

<bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean" />
①JOTM本地实例 ②JTA事务管理器
<bean id="txManager"
    class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="userTransaction" ref="jotm" />
    ②-1:指定userTransaction属性
</bean>
③XAPool配置,内部包含了一个XA数据源,对应topicdb数据库
<bean id="topicDS" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"
    destroy-method="shutdown">
    <property name="dataSource">
        ③-1:内部XA数据源
        <bean class="org.enhydra.jdbc.standard.StandardXADataSource"
            destroy-method="shutdown">
            <property name="transactionManager" ref="jotm" />
            <property name="driverName" value="com.MySQL.jdbc.Driver" />
            <property name="url" value="jdbc:MySQL://localhost:3309/topicdb" />
        </bean>
    </property>
    <property name="user" value="root" />
    <property name="password" value="1234" />
</bean>
④按照③相似的方式配置另一个XAPool,对应postdb数据库,
<bean id="postDS" 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="com.mysql.jdbc.Driver" />
            <property name="url" value="jdbc:mysql://localhost:3309/postdb" />
        </bean>
    </property>
    <property name="user" value="root" />
    <property name="password" value="1234" />
</bean>
⑤配置访问topicDB数据源的Spring JDBC模板
<bean id="topicTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="topicDS" />
</bean>
⑥配置访问postDB数据源的Spring JDBC模板
<bean id="postTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="postDS" />
</bean>
⑦基于topicTemplate数据源的topicDao
<bean id="topicDao" class="com.baobaotao.dao.jdbc.TopicJdbcDao">
    <property name="jdbcTemplate" ref="topicTemplate" />
</bean>
⑧基于postTemplate数据源的postDao
<bean id="postDao" class="com.baobaotao.dao.jdbc.PostJdbcDao">
    <property name="jdbcTemplate" ref="postTemplate" />
</bean>
⑨进行跨数据库JTA事务的业务类
<bean id="bbtForum" class="com.baobaotao.service.impl.BbtForumImpl">
    <property name="topicDao" ref="topicDao" />
    <property name="postDao" ref="postDao" />
</bean>
⑩对BbtForumImpl业务类中的@Transaction注解进行驱动
<tx:annotation-driven transaction-manager="txManager" />

 

代码清单 2 BbtForumImpl

package com.baobaotao.service.impl;  

import org.springframework.transaction.annotation.Transactional;  
import com.baobaotao.dao.PostDao;  
import com.baobaotao.dao.TopicDao;  
import com.baobaotao.domain.Forum;  
import com.baobaotao.domain.Topic;  
import com.baobaotao.service.BbtForum;  

@Transactional 
//①事务注解,以便Spring动态织入事务管理功能  
public class BbtForumImpl implements BbtForum {
    private TopicDao topicDao;  
    private PostDao postDao; 

    public void addTopic(Topic topic) throws Exception { 
    //②将方法将被施加JTA事务的增强  
    topicDao.addTopic(topic);  
    postDao.addPost(topic.getPost());  
    }
}

1.5. 在Spring中运行测试

package com.baobaotao.service;  

import org.springframework.test.AbstractDependencyInjectionSpringContextTests;  
…  

public class TestBbtForumJta extends AbstractDependencyInjectionSpringContextTests{
    private BbtForum bbtForum;  
    private final Logger logger = Logger.getLogger(getClass());  
    
    public void setBbtForum(BbtForum bbtForum) {  
        this.bbtForum = bbtForum;  
    }  
    
    protected String[] getConfigLocations() {
        return new String[]{"classpath:applicationContext-jta.xml"};  
    }  
    
    public void testAddPost() throws Exception{  
        logger.info("begin........");  
        Topic topic = new Topic();  
        topic.setTopicTitle("Title -pfb");  
        
        Post post = new Post();  
        post.setPostText("post content -pfb");  
        topic.setPost(post);  
        
        bbtForum.addTopic(topic); 
        //①使用了JTA事务的业务方法  
        logger.info("end........");  
    }  
}

2. Spring引用Tomcat的 JTA事务
  Tomcat是Servlet容器,但它提供了JNDI的实现,
  因此用户可以象在Java EE应用程序服务器中一样,在Tomcat中使用JNDI查找JDBC数据源。
  在事务处理方面,Tomcat本身并不支持JTA,但是可以通过集成JOTM达到目的。
  (测试环境:Tomcat 5.5+JOTM 2.3)
2.1. 添加所需的JAR文件 
  将JOTM以下类包添加到<Tomcat安装目录>/common/lib目录中: 
    jotm.jar 
    jotm_jrmp_stubs.jar 
    jotm_iiop_stubs.jar 
    ow_carol.jar 
    jta-spec1_0_1.jar 
    jts1_0.jar 
    objectweb-datasource.jar 
    xapool.jar 
    howl.jar 
    connector-1_5.jar 
  同时,还需要添加相应数据库的JDBC驱动类包,例如MySQL的mysql.jar。

2.2. 配置JOTM 
  新建一个carol.properties配置文件,放置到<Tomcat安装目录>/common/classes目录下,配置文件内容如下:
    #JNDI调用协议 
    carol.protocols=jrmp 
    # 本地RMI调用 
    carol.jvm.rmi.local.call=true 
    # 不使用CAROL的JNDI封装器 
    carol.start.jndi=false 
    # 不启用命名服务器 
    carol.start.ns=false 
    # 命名工厂类 
    carol.jndi.java.naming.factory.url.pkgs=org.apache.naming 
    将carol.start.jndi设置为false,让JOTM不使用CAROL JNDI wrapper,从而可以避免类装载错误的发生。

2.3. 配置Tomcat环境,配置JNDI的数据源 
  在<Tomcat安装目录>/conf/context.xml文件中添加以下内容:

<!-- ①:JNDI数据源 -->
<Resource name="jdbc/topicDS" auth="Container" type="javax.sql.DataSource" 
    factory="org.objectweb.jndi.DataSourceFactory"
    username="root"
    password="1234"
    driverClassName="com.mysql.jdbc.Driver"
    url="jdbc:mysql://localhost:3309/topicdb"
    maxActive="30"
    maxIdle="30" />

<!-- ①:JNDI数据源 -->
<Resource name="jdbc/postDS" auth="Container" type="javax.sql.DataSource" 
    factory="org.objectweb.jndi.DataSourceFactory"
    username="root"
    password="1234"
    driverClassName="com.mysql.jdbc.Driver"
    url="jdbc:mysql://localhost:3309/postdb"
    maxActive="30"
    maxIdle="30" />
        
<!-- ②JOTM JTA事务管理 -->
<Transaction factory="org.objectweb.jotm.UserTransactionFactory" jotm.timeout="60" /> 

 

4. Spring中相应的配置

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:jee="http://www.springframework.org/schema/jee"
    xsi:schemaLocation="
      http://www.springframework.org/schema/beans   
      http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
      http://www.springframework.org/schema/tx 
      http://www.springframework.org/schema/tx/spring-tx-2.0.xsd   
      http://www.springframework.org/schema/jee 
      http://www.springframework.org/schema/jee/spring-jee-2.0.xsd">

    <jee:jndi-lookup id="topicDS" jndi-name="java:comp/env/jdbc/topicDS" />
    <jee:jndi-lookup id="postDS" jndi-name="java:comp/env/jdbc/postDS" />
    <bean id="topicTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="topicDS" />
    </bean>
    <bean id="postTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="postDS" />
    </bean>
    <bean id="topicDao" class="com.baobaotao.dao.jdbc.TopicJdbcDao">
        <property name="jdbcTemplate" ref="topicTemplate" />
    </bean>
    <bean id="postDao" class="com.baobaotao.dao.jdbc.PostJdbcDao">
        <property name="jdbcTemplate" ref="postTemplate" />
    </bean>
    <bean id="bbtForum" class="com.baobaotao.service.impl.BbtForumImpl">
        <property name="topicDao" ref="topicDao" />
        <property name="postDao" ref="postDao" />
    </bean>
    
<bean id="txManager" 
  class="org.springframework.transaction.jta.JtaTransactionManager" />
    <tx:annotation-driven transaction-manager="txManager" />
</beans>

 

3. 在特定应用服务器使用JTA

BEA WebLogic 
  在一个使用WebLogic 7.0、8.1或更高版本的环境中,你一般会优先选用特定于WebLogic的 WebLogicJtaTransactionManager 类
  来取代基础的 JtaTransactionManager 类。
  因为在WebLogic环境中,该类提供了对Spring事务定义的完全支持,超过了标准的JTA语义。
  你可以使用以下的配置达到目的:

<bean id="txManager" class="org.springframework.transaction.jta.WebLogicJtaTransactionManager"/> 

 

  它的特性包括:支持事务名,支持为每个事务定义隔离级别,以及在任何环境下正确地恢复事务的能力。

IBM WebSphere 
  在WebSphere 5.1、5.0和4.x环境下,你可以使用Spring的 WebSphereTransactionManagerFactoryBean 类。
  这是一个工厂类,通过WebSphere的 静态访问方法(每个版本的WebSphere中都不同)获取到JTA TransactionManager 实例。
  一旦通过工厂bean获取到JTA TransactionManager 实例,
  就可以使用该实例装配一个Spring的 JtaTransactionManager bean,
  它封装了JTA UserTransaction,提供增强的事务语义。

<bean id="wsJtaTm"
    class="org.springframework.transaction.jta.WebSphereTransactionManagerFactoryBean" />
<bean id="transactionManager"
    class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager ref=" wsJtaTm " />
    <!--①引用WebSphere的JTA事务管理器-->
</bean>

 

名称解释:
  JOTM(Java Open Transaction Manager)是ObjectWeb的一个开源JTA实现,
  它本身也是开源应用程序服务器JOnAS(Java Open Application Server)的一部分,
  为其提供JTA分布式事务的功能。 

参考:
JTA事务管理(一)http://mavin.zhou.blog.163.com/blog/static/114522435200971822334475/
JTA事务管理(二)http://mavin.zhou.blog.163.com/blog/static/114522435200971822912342/

 

其它:
JTA集成JOTM或Atomikos配置分布式事务(Tomcat应用服务器) http://kb.cnblogs.com/a/2012014/



已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐