文档章节

JTA分布式事务与Atomikos

ACRushVoid
 ACRushVoid
发布于 2017/03/15 10:53
字数 814
阅读 226
收藏 0

本章主要介绍分布式事务,对于多数据源操作,如果不得不使用分布式事务来处理,那就需要JTA,它主要包括两个部分:事务管理器,支持XA协议的资源管理器。其中事务管理器主要是给开发人员的接口,而资源管理器是给服务提供商的接口,服务提供商就是数据库连接的厂商。对于分布式事务的原理依然是两阶段、三阶段事务提交,百度都有详细介绍,这里不再讲了。

回到之前那个问题,如果项目需要分布式事务,怎么办?目前业内比较好的框架的是Atomikos,它已经10年了,比较稳定。使用它主要是配置,看下代码:

   <!--JTA atomikos-->
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>atomikos-util</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-jta</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-jdbc</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>com.atomikos</groupId>
      <artifactId>transactions-api</artifactId>
      <version>4.0.2</version>
    </dependency>
    <dependency>
      <groupId>cglib</groupId>
      <artifactId>cglib-nodep</artifactId>
      <version>3.2.2</version>
    </dependency>
    <dependency>
      <groupId>javax.transaction</groupId>
      <artifactId>jta</artifactId>
      <version>1.1</version>
    </dependency>

<!-- jtaDataSource0数据源 -->
<bean id="jtaDataSource0" class="com.atomikos.jdbc.AtomikosDataSourceBean"
      init-method="init" destroy-method="close">
    <!-- Set unique name for this DataSource -->
    <property name="uniqueResourceName"><value>jtaDataSource0</value></property>
    <!-- Set XADatasource class name-->
    <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
    <property name="xaProperties">
        <props>
            <prop key="user">root</prop>
            <prop key="password">dlb</prop>
            <prop key="url">${jdbc.url}</prop>
        </props>
    </property>
    <!-- set properties for datasource connection pool -->
    <property name="poolSize" value="3" />
    <!-- 管理 Connection 被占用的时间 -->
    <!-- 如果不设置这个值,Atomikos使用默认的300秒(即5分钟),那么在处理大批量数据读取的时候,一旦超过5分钟,就会抛出类似 Resultset is close 的错误 -->
    <property name="reapTimeout"><value>30000</value></property>
</bean>

<!-- jtaDataSource1数据源 -->
<bean id="jtaDataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean"
      init-method="init" destroy-method="close">
    <property name="uniqueResourceName"><value>jtaDataSource1</value></property>
    <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
    <property name="xaProperties">
        <props>
            <prop key="user">root</prop>
            <prop key="password">dlb</prop>
            <prop key="url">${jdbc1.url}</prop>
        </props>
    </property>
    <!-- 连接池里面连接的个数 -->
    <property name="poolSize" value="3" />
    <!-- 管理 Connection 被占用的时间 -->
    <!-- 如果不设置这个值,Atomikos使用默认的300秒(即5分钟),那么在处理大批量数据读取的时候,一旦超过5分钟,就会抛出类似 Resultset is close 的错误 -->
    <property name="reapTimeout"><value>30000</value></property>
</bean>

<!--jtaSqlsessionFactory0 mybatis-->
<bean id="jtaSqlsessionFactory0" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="configLocation" value="classpath:config/mybatis/SqlMapConfig.xml"/>
    <property name="dataSource" ref="jtaDataSource0"/>
</bean>

<!--jtaSqlsessionFactory1 test-->
<bean id="jtaSqlsessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="configLocation" value="classpath:config/mybatis/SqlMapConfig.xml"/>
    <property name="dataSource" ref="jtaDataSource1"/>
</bean>

<!-- atomikos事务管理器 -->
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
      init-method="init" destroy-method="close">
    <property name="forceShutdown">
        <value>true</value>
    </property>
</bean>

<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
    <!--事务超时时间 最好和max_timeout一样-->
    <property name="transactionTimeout" value="300" />
</bean>

<!-- springJta事务管理器 -->
<bean id="springJtaTransactionManager"
      class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="atomikosTransactionManager"/>
    <property name="userTransaction" ref="atomikosUserTransaction" />
    <property name="allowCustomIsolationLevels" value="true"/>
</bean>
public void jtaTest(TbFundSeoRecord record, User user) throws Exception {
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        TransactionStatus status = springJtaTransactionManager.getTransaction(def);

        try {
            jtaUserDao.insert(user);
//            int i = 1/ 0;
            jtaSeoFundDao.insert(record);

//            int i = 1/ 0;
            springJtaTransactionManager.commit(status);
        } catch (Exception e) {
            e.printStackTrace();
            springJtaTransactionManager.rollback(status);
     
    }

要注意mysql的版本号,5.1.6会报错,我用的5.1.35。

分布式事务性能很低,基本是个摆设,最好不要使用分布式事务,尽量从业务拆分。因为对于事务我们都是追求弱一致性或者最终一致性,而不能一味的为了追求强一致性而丢了可用性。

© 著作权归作者所有

ACRushVoid
粉丝 59
博文 18
码字总数 19761
作品 0
威海
私信 提问
【分布式事务系列】提出疑问和研究过程

分布式事务 【分布式事务系列】提出疑问和研究过程 对于我们这种初学者,可能会使用Spring带给我们的@Transactional,可能了解JTA,可能会使用jotm、atomikos,又会遇到一些名词XA,支持XA的...

陶邦仁
2015/12/09
568
0
【分布式事务系列七】Atomikos的分布式案例

分布式事务 【分布式事务系列一】提出疑问和研究过程 【分布式事务系列二】Spring事务管理器PlatformTransactionManager 【分布式事务系列三】Spring的事务体系 【分布式事务系列四】分布式事...

陶邦仁
2015/12/21
385
0
分布式事务系列(开篇)提出疑问和研究过程

1 前言 系列目录 - 分布式事务系列(开篇)提出疑问和研究过程- 分布式事务系列(1.1)Spring事务管理器PlatformTransactionManager源码分析- 分布式事务系列(1.2)Spring事务体系- 分布式事...

乒乓狂魔
2015/05/12
6.6K
7
分布式事务系列(4.1)Atomikos的分布式案例

1 系列目录 - 分布式事务系列(开篇)提出疑问和研究过程- 分布式事务系列(1.1)Spring事务管理器PlatformTransactionManager源码分析- 分布式事务系列(1.2)Spring事务体系- 分布式事务系...

乒乓狂魔
2015/06/01
5.7K
4
JTA分布式事务实践

最近一直在研究怎么实现分布式事务,花了不少时间,测试工程启停测试了无数次,最终实现的时候其实也就是写一些配置文件,对于工程代码没什么影响。目前研究还不是很深入,对于全面崩溃恢复如...

引鸩怼孑
2016/04/27
214
2

没有更多内容

加载失败,请刷新页面

加载更多

kibana汉化

kibana5 / 6 需要下载补丁包,https://github.com/anbai-inc/Kibana_Hanization 其中 v6 版本原生支持国际化,只需要添加资源文件并且配置即可 kibana7 v7版本官方内置汉化资源,在配置文件 ...

细肉云吞
19分钟前
5
0
spring boot 自定义日志 log4j2

使用默认的日志在实际开发中会存在很多问题,比如备份文件名称无法自动重命名、各个等级的日志被放在一个文件中等,所以实际开发中为了更好满足我们的需求,我们一般都会自定义采用配置的方式...

雷开你的门
23分钟前
7
0
PCB设计-Allegro软件入门系列-设计参数配置(上)

前言 经历了导入网表,和放置器件后,我们就要画板子了,但是必要的设计参数也要先准备好,磨刀不误砍柴工。 《一》显示参数 这里主要设置DRC报错标志大小和飞线显示类型 (1)DRC标志可以适当...

demyar
24分钟前
6
0
js实现微博、微信分享

html <!-- 分享 --><div class="share-box"> <b style="vertical-align: middle;">分享到:</b> <a title="分享到新浪微博" class="shareSina"><span class="share-icon"></span><......

张兴华ZHero
40分钟前
7
0
创龙TMS320DM8168浮点DSP C674x + ARM Cortex-A8的CPU、NAND FLASH、NOR FLASH

TL6678-EasyEVM是广州创龙基于SOM-TL6678核心板而研发的一款多核高性能DSP开发板。开发板采用核心板+底板方式,底板采用沉金无铅工艺的四层板设计,尺寸为200mm*106.65mm,它为用户提供了SOM...

Tronlong创龙
43分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部