`

在spring、tomcat中使用多数据源并支持分布式事务管理

    博客分类:
  • Java
阅读更多

原文:http://zxlaiye.iteye.com/blog/1441299

 

题目起得有点模糊,第一次接触这东西,还不怎么理解。 

起因: 
小项目,没有用分布式,但要操作两个数据库。本以为随便用spring配置两个数据源就搞定,查询是没问题,问题是有一个数据库老是插不进数据。Google狂搜之后,大概了解到是事务控制的问题。我用的是spring的声明式事务管理(<tx:annotation-driven/>)。用一般的数据源配置,只有一个数据源的事务生效,其它数据源只能读不能写。 

有帖子说,要支持多数据源的事务,只能用JTA事务管理(没用过 -_-||),而且应用服务器还不能是Tomcat(一直在用tomcat,不想换-_-!!),头疼了。幸亏后面还有说,有第三方的实现支持JTA事务管理,一是JOTM,一是Atomikos。只要用了其中一个,还能继续用Tomcat。因为名字短,先考虑用JOTM。到官网一看,最后更新日期是2010年。。呃。。转向Atomikos。在Atomikos的官网看看文档,看看例子,边做边调试,一个下午下来,总算有点成果,高兴之余做个记录。其中会涉及到一些概念,比如分布式事务、JTA、XA,我都有搜来了解一下,因理解肤浅没法做记录。下面只是记录atomikos配合spring的使用方法: 

1、依赖包 
Atomikos的: 
transactions-jdbc 
transactions-jta 
transactions-api 
transactions 
atomikos-utils 
还有一个不要忘了,是jta的包。 
用maven要简单一点,只需要加入两个依赖: 

<dependency>
	<groupId>com.atomikos</groupId>
	<artifactId>transactions-jdbc</artifactId>
	<version>3.7.0</version>
</dependency>
<dependency>
	<groupId>javax.transaction</groupId>
	<artifactId>jta</artifactId>
	<version>1.1</version>
</dependency>

 

2、配置数据源 
    这一步是比较重要的。要用AtomikosDataSourceBean,而不是以前用的连接池如dbcp。最好也用XA(这东西我还不太懂),注意jdbc的链接地址和登陆账号与普通连接池的配置的格式不一样。下面是一个mysql数据库的配置举例: 

<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
	<property name="uniqueResourceName" value="ds1"/>
	<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
	<property name="xaProperties">
		<props>
			<prop key="url">jdbc:mysql://localhost/test</prop>
			<prop key="user">test</prop>
			<prop key="password">test</prop>
		</props>
	</property>
	<property name="minPoolSize" value="10" />
	<property name="maxPoolSize" value="100" />
	<property name="borrowConnectionTimeout" value="30" />
	<property name="testQuery" value="select 1" />
	<property name="maintenanceInterval" value="60" />
</bean>

 

再来一个sybase的配置举例:

<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
	<property name="uniqueResourceName" value="ds2"/>
	<property name="xaDataSourceClassName" value="com.sybase.jdbc3.jdbc.SybXADataSource"/>
	<property name="xaProperties">
		<props>
			<prop key="serverName">192.168.1.10</prop>
                        <prop key="portNumber">2638</prop>
                        <prop key="databaseName">test</prop>
			<prop key="user">test</prop>
			<prop key="password">test</prop>
		</props>
	</property>
	<property name="minPoolSize" value="10" />
	<property name="maxPoolSize" value="100" />
	<property name="borrowConnectionTimeout" value="30" />
	<property name="testQuery" value="select 1" />
	<property name="maintenanceInterval" value="60" />
</bean>

 

3、使用数据源 
    这一步与平时好像没什么不一样。我做例子的时候是用mybatis,配置如下:

<bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">
	<property name="dataSource" ref="dataSource1"/>
</bean>
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
	<property name="dataSource" ref="dataSource2"/>
</bean>

 当然,mybatis还要配置一下映射文件的自动扫描,这里与atomikos无关:

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	<property name="basePackage" value="xx.xx;" />
	<property name="sqlSessionFactory" ref="sqlSessionFactory1"/>
</bean>
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	<property name="basePackage" value="yy.yy;" />
	<property name="sqlSessionFactory" ref="sqlSessionFactory2"/>
</bean>

 用spring JdbcTemplate应该与普通使用没什么不同,用hibernate可能会有点不一样,没测试过。

 

4、配置jta事务管理 
    这是很关键的一步。原理我不太懂,例子如下: 

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
	<property name="transactionManager">
		<bean class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
			<property name="forceShutdown" value="true"/>
		</bean>
	</property>
	<property name="userTransaction">
		<bean class="com.atomikos.icatch.jta.UserTransactionImp"/>
	</property>
</bean>

 当然,用spring的声明式事务配置,再加上一行:

<tx:annotation-driven/>
 (注意,本来要配置transaction-manager属性,如:<tx:annotation-driven transaction-manager="transactionManager"/>。这里没有配置是因为它的默认值是transactionManager) 


5、atomikos的配置文件jta.properties 
    这个文件一般放在根路径吧,与log4j.properties类似。jta.properties也可命名为transactions.properties。如果不配置这个文件,项目也能启动,因为几乎所有配置项都有默认值。最好还是配置了,详细配置信息请查看:http://www.atomikos.com/Documentation/JtaProperties。 

6、不管是用JdbcTemplate、mybatis还是hibernate,应该都可以写代码来测试了。。。 

分享到:
评论
1 楼 baso4233 2013-05-08  
学习中。先抢个沙发。

相关推荐

    Spring Boot + Druid + Mybatis + Atomikos 配置多数据源 并支持分布式事务

    本教程将探讨如何利用Spring Boot、Druid、Mybatis以及Atomikos来配置多数据源并实现分布式事务。 首先,Spring Boot是Java生态系统中的一个流行框架,它简化了设置和配置过程,使得开发人员可以快速启动新项目。在...

    Spring多数据源配置_分布式数据

    ### Spring多数据源配置与分布式数据管理 #### 环境及框架介绍 在本案例中,我们将探讨如何在基于Tomcat服务器的环境下配置多个数据源,并实现分布式数据的交互。该系统的架构主要包括:Tomcat作为应用服务器,...

    spring+jotm 多数据源事务管理(三)JNDI+Tomcat

    本文详细介绍了如何在Tomcat服务器环境下使用Spring框架结合JOTM进行多数据源下的分布式事务管理。通过上述步骤,开发者可以轻松地搭建起一套完整的多数据源事务处理环境,为复杂业务场景提供强大的支持。这种配置...

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

    在IT行业中,分布式事务处理是复杂系统架构中的一个重要环节,特别是在多数据库或者微服务环境中。Spring框架提供了对JTA(Java Transaction API)的支持,允许开发者处理跨多个数据存储的事务一致性。本文将深入...

    spring boot动态切换多数据源

    - 为了保证事务的一致性,需要考虑如何在多数据源间协调事务管理,可能需要用到`PlatformTransactionManager`的适配。 总结来说,Spring Boot动态切换多数据源是通过合理的配置和自定义逻辑实现的,它使得应用能够...

    springboot多数据源配置

    在Spring Boot应用中,多数据源配置是一项重要的技术实践,特别是在大型系统中,可能需要连接到多个数据库以实现数据隔离、读写分离或是分布式事务管理。Spring Boot以其强大的自动化配置能力,使得设置多数据源变得...

    如何在spring中等价配置得到原本由jndi配置实现的数据源

    通常,在Web应用程序中,数据源常常通过Java Naming and Directory Interface (JNDI)进行管理,这允许多个应用共享同一个数据源,例如在应用服务器如Tomcat、JBoss或WebLogic中。然而,有时我们可能希望在非Web环境...

    springboot+mybatisplus+mysql 多数据源

    8. **事务管理**: 在多数据源环境中,事务管理变得复杂,因为需要确保跨数据源的操作一致性。Spring Boot通过`PlatformTransactionManager`接口提供支持,根据配置的策略来处理多数据源的事务。 9. **测试与调试**:...

    spring boot下学习mybatis+mysql使用jta对多数据源事务进行整合.zip

    在Spring Boot框架中,集成MyBatis和MySQL数据库并利用JTA(Java Transaction API)来管理多数据源的事务是一项常见的需求。这个压缩包文件名表明了它包含了一个示例项目,展示了如何在Spring Boot环境下配置和使用...

    基于 SpringBoot 多数据源 动态数据源 主从分离 快速启动器 支持分布式事务.zip

    3.自动配置:SpringBoot的自动配置特性利用了Spring对条件化配置的支持,合理地推测应用所需的bean并自动化配置他们。 4.使部署变得简单,SpringBoot内置了三种Servlet容器,Tomcat,Jetty,undertow.我们只需要一个...

    Spring中的全局(分布式、容器)事务的项目,可以脱离JBOSS的存在

    2. 配置Spring:在Spring的配置文件中,声明Atomikos的UserTransaction和TransactionManager,同时需要定义数据源以及相应的JTA配置。 3. 配置数据源:创建Atomikos数据源,并设置为JTA兼容模式。 4. 配置Spring...

    spring boot+Druid+mybatis搭建多数据源java项目

    在多数据源项目中,Druid能帮助我们有效地管理多个数据库的连接,保证高效的数据访问。Druid的数据源代理可以收集SQL执行信息,方便进行性能分析和调优。 3. **MyBatis**: MyBatis是一个优秀的持久层框架,它支持...

    SpringBoot多数据源成果源代码.rar

    在Spring Boot微服务框架中,整合配置和应用多数据源是一项关键任务,特别是在大型企业级应用中,可能需要连接到多个数据库以实现数据隔离、负载均衡或者读写分离。本项目名为"SpringBoot多数据源成果源代码",提供...

    在Spring中使用JTA事务管理

    在Spring框架中,JTA(Java Transaction API)事务管理是一种用于处理分布式事务的高级机制,它允许应用程序在多个数据源之间进行协调的事务操作。本文将详细介绍如何在Spring中使用JTA事务管理,包括通过集成JOTM...

    springboot双数据源(oracle,mysql).rar

    在多数据源场景下,可以使用AOP来决定在执行哪个DAO方法时使用哪个数据源。 6. **Transaction管理**:处理多个数据源的事务管理可能比较复杂,因为跨数据源的事务管理通常不被支持。因此,可能需要将事务划分为独立...

    springboot-mybatis-多数据源

    本项目“springboot-mybatis-多数据源”聚焦于如何在Spring Boot环境中实现多数据源的支持,这对于大型分布式系统或是需要连接多个数据库的应用来说至关重要。 Spring Boot是由Pivotal团队维护的Java框架,它旨在...

    springboot+mybatis+jta+atomikos解决多数据源事务问题.pdf

    在多数据源环境中,JTA用来保证多个数据源之间的事务一致性。 ### Atomikos Atomikos是一个提供JTA事务管理的开源库,它提供了一个事务管理器来控制和管理多个数据源的事务边界。在Spring Boot中集成Atomikos可以...

    多数据源spring boot.zip_学习资料

    5. **事务管理**:在多数据源环境中,需要特别注意事务管理。Spring的`PlatformTransactionManager`可以配置为使用`DataSourceTransactionManager`,并根据数据源选择适当的事务管理器。 通过这份学习资料,你可以...

    spring-boot-atomikos.rar

    本资源包"spring-boot-atomikos.rar"聚焦于如何在Spring Boot环境中使用Atomikos这一开源的分布式事务管理器来实现分布式事务处理。下面我们将详细探讨相关的知识点。 1. **分布式事务**:在分布式系统中,事务处理...

Global site tag (gtag.js) - Google Analytics