`
chenjiepengc
  • 浏览: 2067 次
  • 性别: Icon_minigender_1
文章分类
社区版块
存档分类
最新评论

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

阅读更多


原文: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要简单一点,只需要加入两个依赖:

Xml代码  收藏代码

    <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数据库的配置举例:

Xml代码  收藏代码

    <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的配置举例:

Xml代码  收藏代码

    <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,配置如下:

Xml代码  收藏代码

    <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无关:

Xml代码  收藏代码

    <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事务管理
    这是很关键的一步。原理我不太懂,例子如下:

Xml代码  收藏代码

    <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的声明式事务配置,再加上一行:

Xml代码  收藏代码

    <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,应该都可以写代码来测试了。。。
分享到:
评论

相关推荐

    spring 结合druid和hibernate使用jta配置分布式事务

    atomikos实现多数据源支持分布式事务管理(spring、tomcat、JTA) 结合spring 和durid进行配置,

    springboot参考指南

    在Spring环境中使用YAML暴露属性 iii. 23.6.3. Multi-profile YAML文档 iv. 23.6.4. YAML缺点 vii. 23.7. 类型安全的配置属性 i. 23.7.1. 第三方配置 ii. 23.7.2. 松散的绑定(Relaxed binding) iii. 23.7.3. @...

    基于SSM架构实现的大型分布式购物网站-B2C项目源码+项目说明.zip

    - 1、配置数据源 - 2、让spring容器管理SqlSessionFactory,单例存在 - 3、把mapper的代理对象放到spring容器中。使用扫描包的方式加载mapper的代理对象。 ###Service层 - 1、事务管理 - 2、需要把service实现类放...

    JAVA上百实例源码以及开源项目源代码

    Java非对称加密源码实例 1个目标文件 摘要:Java源码,算法相关,非对称加密 Java非对称加密源程序代码实例,本例中使用RSA加密技术,定义加密算法可用 DES,DESede,Blowfish等。 设定字符串为“张三,你好,我是李四”...

    JAVA上百实例源码以及开源项目

     Java非对称加密源程序代码实例,本例中使用RSA加密技术,定义加密算法可用 DES,DESede,Blowfish等。  设定字符串为“张三,你好,我是李四”  产生张三的密钥对(keyPairZhang)  张三生成公钥(publicKeyZhang...

    java开源包8

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包1

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包11

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包2

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包3

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包6

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包5

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包10

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包4

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包7

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包9

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    java开源包101

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    Java资源包01

    3、连接复用,因此在多线程获取连接时无需阻塞; 4、同步调用; 5、超时机制; 6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换...

    Java源码 SpringMVC Mybatis Shiro Bootstrap Rest Webservice

    Druid Monitor(监控):集成阿里巴巴连接池,提供在线连接池监控程序,包括:数据源、SQL监控、URL监控、Session监控、Spring监控等 网站信息管理:通过系统配置文件进行网站内容操作,包括邮件服务器配置、公司...

Global site tag (gtag.js) - Google Analytics