文档章节

atomikos实现多数据源支持分布式事务管理(spring、tomcat、JTA)

刺猬一号
 刺猬一号
发布于 2017/05/29 00:04
字数 1603
阅读 42
收藏 0

Atomikos TransactionsEssentials 是一个可靠的库,可以加入到您的Java应用程序,也就是说为了使用这个产品,您必须添加一些jar文件(包括在dist和lib文件夹下)到您的应用程序或者应用程序服务器。

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

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

 Atomikos TransactionsEssentials 是一个为Java平台提供增值服务的并且开源类事务管理器,以下是包括在这个开源版本中的一些功能:

l  全面崩溃 / 重启恢复

l  兼容标准的SUN公司JTA API

l  嵌套事务

l  为XA和非XA提供内置的JDBC适配器

注释:XA:XA协议由Tuxedo首先提出的,并交给X/Open组织,作为资源管理器(数据库)与事务管理器的接口标准。目前,Oracle、Informix、DB2和Sybase等各大数据库厂家都提供对XA的支持。XA协议采用两阶段提交方式来管理分布式事务。XA接口提供资源管理器与事务管理器之间进行通信的标准接口。XA协议包括两套函数,以xa_开头的及以ax_开头的。

以下的函数使事务管理器可以对资源管理器进行的操作:

  1)xa_open,xa_close:建立和关闭与资源管理器的连接。

  2)xa_start,xa_end:开始和结束一个本地事务。

  3)xa_prepare,xa_commit,xa_rollback:预提交、提交和回滚一个本地事务。

  4)xa_recover:回滚一个已进行预提交的事务。

  5)ax_开头的函数使资源管理器可以动态地在事务管理器中进行注册,并可以对XID(TRANSACTION IDS)进行操作。

  6)ax_reg,ax_unreg;允许一个资源管理器在一个TMS(TRANSACTION MANAGER SERVER)中动态注册或撤消注册。

l  内置的JMS适配器XA-capable JMS队列连接器

注释:JMS:jms即Java消息服务(Java Message Service)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的API,绝大多数MOM提供商都对JMS提供支持。

l  通过XA API兼容第三方适配器

l  更好的整合您的项目

l  集成Hibernate

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,应该都可以写代码来测试了。。

© 著作权归作者所有

刺猬一号
粉丝 12
博文 373
码字总数 616361
作品 0
深圳
私信 提问
Spring事务隔离级别与传播机制,spring+mybatis+atomikos实现分布式事务管理

本文转载于本人另一博客【http://blog.csdn.net/liaohaojian/article/details/68488150】 1.事务的定义:事务是指多个操作单元组成的合集,多个单元操作是整体不可分割的,要么都操作不成功,...

半山闲人
2017/04/13
0
0
关于分布式事务的实现

@黄勇 你好,想跟你请教个问题: 关于分布式事务的实现,之前在高手问答有请教过你,当时说的是用JTA实现。现在我这里的应用环境,服务的主体框架是Spring,按照JTA的实现我查到的信息是使用 ...

Kent_Chen
2015/10/30
297
1
atomikos和Mybatis分布式事务

本项目基于maven,使用spring,mybatis 首先pom.xml引入` <!-- 多数据源事务管理 --> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-jdbc</artifactId> <version>3......

囧先森
2016/03/03
766
2
spring项目加入jta分布式事务的实现方式: Atomikos

一、概述: 本文主要讲述如何基于Atomikos 和spring在项目中实现分布式事务管理 二、应用场景: 如果项目中的数据源来自多个数据库,同时又需要在多数据源中保证事务,此时就需要用到分布式事...

明舞
2015/12/10
797
3
java项目中的事务处理,服务级别的事务处理,数据库级别的跨库事务处理

@红薯 你好,想跟你请教个问题: 您好,冒昧请教下,关于java中的事务处理有两点请教: 第一:数据库级别的跨库事务,在tomcat中使用jta,一定要spring支持吗,我看网上的文章都是在spring中...

金秋九月
2012/12/05
2.3K
3

没有更多内容

加载失败,请刷新页面

加载更多

OSChina 周日乱弹 —— 别问,问就是没空

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @tom_tdhzz :#今日歌曲推荐# 分享容祖儿/彭羚的单曲《心淡》: 《心淡》- 容祖儿/彭羚 手机党少年们想听歌,请使劲儿戳(这里) @wqp0010 :周...

小小编辑
今天
284
6
golang微服务框架go-micro 入门笔记2.1 micro工具之micro api

micro api micro 功能非常强大,本文将详细阐述micro api 命令行的功能 重要的事情说3次 本文全部代码https://idea.techidea8.com/open/idea.shtml?id=6 本文全部代码https://idea.techidea8....

非正式解决方案
今天
5
0
Spring Context 你真的懂了吗

今天介绍一下大家常见的一个单词 context 应该怎么去理解,正确的理解它有助于我们学习 spring 以及计算机系统中的其他知识。 1. context 是什么 我们经常在编程中见到 context 这个单词,当...

Java知其所以然
昨天
5
0
Spring Boot + Mybatis-Plus 集成与使用(二)

前言: 本章节介绍MyBatis-Puls的CRUD使用。在开始之前,先简单讲解下上章节关于Spring Boot是如何自动配置MyBatis-Plus。 一、自动配置 当Spring Boot应用从主方法main()启动后,首先加载S...

伴学编程
昨天
8
0
用最通俗的方法讲spring [一] ──── AOP

@[TOC](用最通俗的方法讲spring [一] ──── AOP) 写这个系列的目的(可以跳过不看) 自己写这个系列的目的,是因为自己是个比较笨的人,我曾一度怀疑自己的智商不适合干编程这个行业.因为在我...

小贼贼子
昨天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部