2. 程式人生 > >spring+mybatis+Atomikos JTA事務配置說明

spring+mybatis+Atomikos JTA事務配置說明

阿新 • • 發佈：2017-12-28
user roo aspect code out oracle mysq nta 4.2

一、概覽

Atomikos是一個公司名字，旗下最著名的莫過於其Atomikos的事務管理器產品。產品分兩個：一個是開源的TransactionEssentials，一個是商業的ExtremeTransactions。

TransactionEssentials的主要特征：

  • JTA/XA 事務管理 —— 提供事務管理和連接池
  • 不需要應用服務器 —— TransactionEssentials可以在任何Java EE應用服務器中運行，也就是不依賴於任何應用服務器
  • 開源 —— TransactionEssentials是遵守Apache版本2許可的開源軟件
  • 專註於JDBC/JMS —— 支持所有XA資源，但是資源池和消息監聽是專供JDBC和JMS的
  • 與Spring 和 Hibernate 集成 —— 提供了描述如何與Spring和Hibernate集成的文檔

ExtremeTransactions 是基於TransactionEssentials之上的，增加了對非XA事務的支持，在servlet容器中提供了圖形化管理控制面板。Atomikos還提供了基於訂閱的支持服務，一份訂閱可以得到訪問ExtremeTransactions中額外功能的權限。

二、什麽是Atomikos TransactionsEssentials

Atomikos TransactionsEssentials 是一個為Java平臺提供增值服務的並且開源類事務管理器，以下是包括在這個開源版本中的一些功能：

  • 全面崩潰 / 重啟恢復
  • 兼容標準的SUN公司JTA API
  • 嵌套事務
  • 為XA和非XA提供內置的JDBC適配器
  • 內置的JMS適配器XA-capable JMS隊列連接器
  • 通過XA API兼容第三方適配器
  • 更好的整合您的項目
  • 集成Hibernate、mybatis等

註釋：XA：XA協議由Tuxedo首先提出的，並交給X/Open組織，作為資源管理器（數據庫）與事務管理器的接口標準。目前，Oracle、Informix、DB2和Sybase等各大數據庫廠家都提供對XA的支持。XA協議采用兩階段提交方式來管理分布式事務。XA接口提供資源管理器與事務管理器之間進行通信的標準接口。XA協議包括兩套函數，以xa_開頭的及以ax_開頭的。

三、如何使用Atomikos TransactionsEssentials

Atomikos TransactionsEssentials 是一個可靠的庫，可以加入到您的Java應用程序，也就是說為了使用這個產品，您必須添加一些jar文件（包括在dist和lib文件夾下）到您的應用程序或者應用程序服務器。

請註意：Atomikos TransactionsEssentials是一個非常快速的嵌入式事務管理器，這就意味著，您不需要另外啟動一個單獨的事務管理器進程（不要查找任何的bin文件夾）。相反，您的應用服務器將有它自己的intra-VM事務管理器。

配置需求：至少Java1.5 jdk，並且最少128M的內存

性能優化：盡管這個軟件有著很大的優勢，但是想要更好的發揮其作用，可以按以下的方法優化：

  • 更高的內存，意味著更高的吞吐量（每秒的事務數目）
  • 使連接池盡可能的大
  • 一旦你不需要的連接請馬上關閉它們。不要把你的應用程序放在緩存裏，讓內部連接池為你做這些，這將促使更高效的連接使用
  • 不要讓活動的事務閑置：終止所有情況下的事務，尤其是在異常報錯情況下的事務。這將減少數據庫的鎖定時間，並且最大效率的處理啟用的使用。

值得註意的是，在我們所有的壓力測試中，Atomikos TransactionsEssentials比J2EE的web容器更高效的吞吐量。這些測量值包括日誌記錄的高效的事務狀態，同樣，在我們所有的測量中，包括XA和non-XA，高效的效率是一樣的。

四、spring+mybatis+ Atomikos實現JTA事務

1.環境

  • Spring3.1.3
  • mybatis3.2.2
  • Atomikos3.4.2
  • jdk1.6
  • mysql5.1.51

2.創建數據庫環境，註意數據庫引擎為InnoDB，只有這樣才能支持事務

3.依賴jar包

技術分享圖片
4.配置

jta.properties也可命名為transactions.properties。如果不配置這個文件，項目也能啟動，因為幾乎所有配置項都有默認值，最好還是配置了。

jta.properties：

Xml代碼 技術分享圖片
  1. comcom.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory
  2. com.atomikos.icatch.console_file_name = tm.out
  3. com.atomikos.icatch.log_base_name = tmlog
  4. comcom.atomikos.icatch.tm_unique_name = com.atomikos.spring.jdbc.tm
  5. com.atomikos.icatch.console_log_level = INFO

db.properties：

Xml代碼 技術分享圖片
  1. jdbc.xaDataSourceClassName=com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
  2. jdbcjdbc.url.a=jdbc:mysql://localhost:3306/trans_a?useUnicode=true&characterEncoding=utf-8&autoReconnect=true
  3. jdbc.username.a=root
  4. jdbcjdbc.password.a=
  5. jdbc.uniqueResourceName.a=trans_a
  8. jdbcjdbc.url.b=jdbc:mysql://localhost:3306/trans_b?useUnicode=true&characterEncoding=utf-8&autoReconnect=true
  9. jdbc.username.b=root
  10. jdbcjdbc.password.b=
  11. jdbc.uniqueResourceName.b=trans_b
  14. transactionManager.forceShutdown =true
  15. transactionManager.transactionTimeout=3000
  18. #*********************atomikos連接池參數設置*****************************
  19. #連接池中保留的最小連接數
  20. atomikos.minPoolSize=1
  21. #連接池中保留的最大連接數
  22. atomikos.maxPoolSize=3
  23. #最大空閑時間,60秒內未使用則連接被丟棄。若為0則永不丟棄。Default: 0
  24. atomikos.maxIdleTime=60

applicationContext-a.xml：

Xml代碼 技術分享圖片
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:aop="http://www.springframework.org/schema/aop"
  6. xmlns:tx="http://www.springframework.org/schema/tx"
  7. xsi:schemaLocation="http://www.springframework.org/schema/beans
  8. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  9. http://www.springframework.org/schema/aop
  10. http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  11. http://www.springframework.org/schema/tx
  12. http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  13. http://www.springframework.org/schema/context
  14. http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  16. <!-- 數據庫配置文件位置 -->
  17. <context:property-placeholder location="classpath:db.properties" />
  19. <bean id="dataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean"
  20. init-method="init" destroy-method="close">
  21. <property name="uniqueResourceName" value="${jdbc.uniqueResourceName.a}" />
  22. <property name="xaDataSourceClassName" value="${jdbc.xaDataSourceClassName}" />
  23. <property name="xaProperties">
  24. <props>
  25. <prop key="user">${jdbc.username.a}</prop>
  26. <prop key="password">${jdbc.password.a}</prop>
  27. <prop key="URL">${jdbc.url.a}</prop>
  28. </props>
  29. </property>
  30. <property name="minPoolSize" value="${atomikos.minPoolSize}" />
  31. <property name="maxPoolSize" value="${atomikos.maxPoolSize}" />
  32. <property name="maxIdleTime" value="${atomikos.maxIdleTime}" />
  33. </bean>
  35. <!-- 采用註釋的方式配置bean -->
  36. <context:annotation-config />
  38. <!-- 配置要掃描的包 -->
  39. <context:component-scan base-package="com.ssm"></context:component-scan>
  41. <!--proxy-target-class="true"強制使用cglib代理 如果為false則spring會自動選擇-->
  42. <aop:aspectj-autoproxy proxy-target-class="true"/>
  44. <!-- 配置mybitasSqlSessionFactoryBean -->
  45. <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  46. <property name="dataSource" ref="dataSource" />
  47. <property name="configLocation" value="classpath:mybatis-config.xml"></property>
  48. </bean>
  50. <!-- 配置SqlSessionTemplate -->
  51. <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
  52. <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory" />
  53. </bean>
  55. <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
  56. init-method="init" destroy-method="close">
  57. <property name="forceShutdown" value="${transactionManager.forceShutdown}" />
  58. </bean>
  60. <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
  61. <property name="transactionTimeout" value="${transactionManager.transactionTimeout}" />
  62. </bean>
  64. <bean id="transactionManager"
  65. class="org.springframework.transaction.jta.JtaTransactionManager">
  66. <property name="transactionManager">
  67. <ref bean="atomikosTransactionManager" />
  68. </property>
  69. <property name="userTransaction">
  70. <ref bean="atomikosUserTransaction" />
  71. </property>
  72. </bean>
  74. <!-- 使用annotation註解方式配置事務 -->
  75. <tx:annotation-driven transaction-manager="transactionManager"/>
  77. </beans>

applicationContext-b.xml：

Xml代碼 技術分享圖片
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:aop="http://www.springframework.org/schema/aop"
  6. xmlns:tx="http://www.springframework.org/schema/tx"
  7. xsi:schemaLocation="http://www.springframework.org/schema/beans
  8. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  9. http://www.springframework.org/schema/aop
  10. http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  11. http://www.springframework.org/schema/tx
  12. http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  13. http://www.springframework.org/schema/context
  14. http://www.springframework.org/schema/context/spring-context-3.0.xsd">
  16. <!-- 數據庫配置文件位置 -->
  17. <context:property-placeholder location="classpath:db.properties" />
  19. <bean id="dataSource_b" class="com.atomikos.jdbc.AtomikosDataSourceBean"
  20. init-method="init" destroy-method="close">
  21. <property name="uniqueResourceName" value="${jdbc.uniqueResourceName.b}" />
  22. <property name="xaDataSourceClassName" value="${jdbc.xaDataSourceClassName}" />
  23. <property name="xaProperties">
  24. <props>
  25. <prop key="user">${jdbc.username.b}</prop>
  26. <prop key="password">${jdbc.password.b}</prop>
  27. <prop key="URL">${jdbc.url.b}</prop>
  29. </props>
  30. </property>
  31. <property name="minPoolSize" value="${atomikos.minPoolSize}" />
  32. <property name="maxPoolSize" value="${atomikos.maxPoolSize}" />
  33. <property name="maxIdleTime" value="${atomikos.maxIdleTime}" />
  34. </bean>
  37. <bean id="sqlSessionFactory_b" class="org.mybatis.spring.SqlSessionFactoryBean">
  38. <property name="dataSource" ref="dataSource_b" />
  39. <property name="configLocation" value="classpath:mybatis-config.xml"></property>
  40. </bean>
  42. <!-- 配置SqlSessionTemplate -->
  43. <bean id="sqlSessionTemplate_b" class="org.mybatis.spring.SqlSessionTemplate">
  44. <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory_b" />
  45. </bean>
  47. </beans>

  • transactions-essentials-all.jar (552 KB)
  • 下載次數: 10
  • 查看圖片附件

spring+mybatis+Atomikos JTA事務配置說明

相關推薦

spring+mybatis+Atomikos JTA事務配置說明

user roo aspect code out oracle mysq nta 4.2 一、概覽Atomikos是一個公司名字，旗下最著名的莫過於其Atomikos的事務管理器產品。產品分兩個：一個是開源的Transacti

基於spring+mybatis+atomikos+jta實現分布式事務(1)

dto action 綁定 adapter lns url tab source private 本文介紹基於spring+mybatis+atomikos+jta實現分布式事務，分布式事務的實現方式基於配置文件，不同的mybatis mapper綁定在不同的數據源上，通過

Spring+Mybatis+Atomikos多資料來源事務一致性

1、背景 由於應用多資料來源的寫操作，一定會涉及到資料的一致性問題，由於mybatis-plus 的侷限性，採用spring+mybatis+atomikos+druid實現分散式事務一致性。 2、實現 pom.xml <?xml version="1.0" encoding="

spring mybatis atomikos 多庫分散式事務demo

        最近有點時間 , 就準備搭個多庫事務的例子 , 不過中間碰到一些問題 , 這裡記錄下來 .         我的atomikos   版本是 3.7.0 ; Spring4 mybatis3 ;         碰到問題主要有兩類  :  

spring 事物控制---多資料來源與 atomikos 分散式事務配置(接之前未完成的部分)

接上一篇 說明：解決了多個數據源的資料同步問題（例如：在一個事物裡add操作A庫的a表,同時add操作B庫b表，如果B庫連線中斷或者因為別的異常造成b表寫入失敗，希望a表回滾）需要引入相關jar包。 1.pom.xml(需要新的jar包，就不一一列舉了)

Spring+MyBatis雙數據庫配置

模塊 base hold clas system.in mon min rac audit Spring+MyBatis雙數據庫配置 近

springMVC+spring+mybatis多數據源配置

expr init mybatis onf exp 超時 png wait http 1.application.properties配置 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http

Spring+Mybatis @Transactional註解事務不生效

排除 context mage prop span 文件 action aso eight @Transactional聲明式事務配置： 　　<bean id="transactionManager" 　　　　class="org.springframework.j

springMVC+spring+MyBatis(SSM)的簡單配置

ram web 調用 定制 troy mls param border 並不會 SSM(Spring+SpringMVC+MyBatis)框架集由Spring、SpringMVC、MyBatis三個開源框架整合而成，常作為數據源較簡單的web項目的框架。 其

談一談Spring-Mybatis在多資料來源配置上的坑

蘇格團隊 作者：JayceKon 交流QQ群：855833773 歡迎加入我們的團隊，微信聯絡方式：foreverpx_cjl 概述 先聊一聊業務背景,隨著系統服務的不斷開發,我們的系統會充斥著各種個樣的業務.這種時候,我們應該要開始考慮一下如何將系統的粒度細化.

談一談 Spring-Mybatis 在多資料來源配置上的坑

團隊部落格: https://juejin.im/post/5bfb607f6fb9a04a08215920 概述 先聊一聊業務背景,隨著系統服務的不斷開發,我們的系統會充斥著各種個樣的業務.這種時候,我們應該要開始考慮一下如何將系統的粒度細化.舉個常見的例子: 電商系統可以拆分為 商品模組,訂單模組,地

spring+mybatis兩種事務控制編寫

一.宣告式事務管理 1.spring主配置檔案頭部新增以下程式碼 xmlns:aop=“http://www.springframework.org/schema/aop” xmlns:tx=“http://www.springframework.org/schema/tx” xsi:s

spring+mybatis-->多資料來源配置

配置檔案：dataSource.xml，在ApplicationContext.xml中引入即可 <!-- 資料庫管理 --> <import resource ="classpath:dataSource.xml"/>   dataSource.xml

spring基於xml的事務配置方式

配置步驟 一、配置事務管理器 1.在Bean配置檔案中配置事務管理器。 2.需要注入資料來源。 3.舉個例子： <!-- 配置事務管理器 --> <bean id="transactionManager" class="org.springf

springcloud1、spring+mybatis+mysql的yml配置檔案

server:   port: 8001   mybatis:   config-location: classpath:mybatis/mybatis.cfg.xml             # mybati

spring mybatis 的註解事務

首先要在 spring-mybatis的配置檔案新增 事務支援，和事務annotation支援 注意：如果是mysql請使用innodb innodb 支援事務功能，myisam 不支援。 <!-- transaction support--> <!-

Spring+Mybatis+MySql雙資料來源配置(手動切換資料來源)

直接上程式碼。 .properties資原始檔，資料來源的配置項直接從這裡讀取 jdbc_driverClassName=com.mysql.jdbc.Driver jdbc_url=jdbc:mysql://xxx.xx.x.xxx:xxxx/gic?

spring的面向切面事務配置

    spring被視為java專案開發不可或缺的大佬，其精髓在Aop（面向切面程式設計）以及DI（依賴注入）和IoC（控制反轉），控制反轉讓我們能通過spring容器獲得所有自己想要的物件，而不是像以前一樣new出來，方便控制層和業務層，持久層的解耦，實現高內聚，低耦

spring + mybatis 多資料來源事務

1.配置Druid資料庫資料來源 <bean id="master_dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close"> <!-- 資料

Spring, MyBatis 多資料來源的配置和管理

原文連結：http://www.2cto.com/kf/201505/400273.html 同一個專案有時會涉及到多個數據庫，也就是多資料來源。多資料來源又可以分為兩種情況： 1）兩個或多個數據庫沒有相關性，各自獨立，其實這種可以作為兩個專案來開