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

标签：分布 事务处理 阶段 | 发表时间：2017-01-11 10: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推荐

—软件人才免语言低担保赴美带薪读研！—

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

相关 [分布事务处理阶段] 推荐：