`

使用spring+mybatis+atomikos+tomcat构建分布式事务

 
阅读更多

完整工程下载路径 http://download.csdn.net/detail/npf_java/8786825

 

拿一个MySQL + oracle 数据源配置为例吧

 

database.properties

 

[html] view plain copy
  1. #mysql DB  
  2. mysql.qa.db.url=jdbc:mysql://localhost:3306/ssm_qa?useUnicode=true&characterEncoding=UTF-8  
  3. mysql.qa.db.user=root  
  4. mysql.qa.db.password=ROOT  
  5.   
  6. mysql.dev.db.url=jdbc:mysql://localhost:3306/ssm_dev?useUnicode=true&characterEncoding=UTF-8  
  7. mysql.dev.db.user=root  
  8. mysql.dev.db.password=ROOT  
  9.   
  10. #oracle DB  
  11. oracle.qa.db.url=jdbc\:oracle\:thin\:@1.1.1.32\:1521\:nyj  
  12. oracle.qa.db.driverClassName=oracle.jdbc.OracleDriver  
  13. oracle.qa.db.testQuery=select 1 from dual  
  14. oracle.qa.db.user=oms  
  15. oracle.qa.db.password=oms  
  16.   
  17. oracle.dev.db.url=jdbc\:oracle\:thin\:@1.1.1.32\:1521\:nyj  
  18. oracle.dev.db.driverClassName=oracle.jdbc.OracleDriver  
  19. oracle.dev.db.testQuery=select 1 from dual  
  20. oracle.dev.db.user=com  
  21. oracle.dev.db.password=lsd  
  22.   
  23.   
  24. #sqlserver DB  
  25. sqlserver.qa.db.driverClass=com.microsoft.sqlserver.jdbc.SQLServerDriver  
  26. sqlserver.qa.db.url=jdbc:sqlserver://1.1.1.11:1433;DatabaseName=dl_xbny  
  27. sqlserver.qa.db.user=dl_xbny  
  28. sqlserver.qa.db.password=dl123456  
  29.   
  30. sqlserver.dev.db.driverClass=com.microsoft.sqlserver.jdbc.SQLServerDriver  
  31. sqlserver.dev.db.url=jdbc:sqlserver://1.1.1.11:1433;DatabaseName=com_xbny  
  32. sqlserver.dev.db.user=com_xbny  
  33. sqlserver.dev.db.password=com123456  


mysql-oracle-beans.xml

[html] view plain copy
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.        xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context"  
  4.        xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc"  
  5.        xmlns:rabbit="http://www.springframework.org/schema/rabbit"  
  6.        xmlns:cache="http://www.springframework.org/schema/cache" xmlns:task="http://www.springframework.org/schema/task"  
  7.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd  
  8.        http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">  
  9.     <context:component-scan base-package="com.xy">  
  10.         <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>  
  11.     </context:component-scan>  
  12.     <context:property-placeholder location="classpath:context/database.properties"/>  
  13.     <tx:annotation-driven/>  
  14.   
  15.      <bean id="abstractXADataSource" class="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean" init-method="init"  
  16.           destroy-method="close" abstract="true">  
  17.         <property name="xaDataSourceClassName" value="com.mysql.jdbc.Driver"/>  
  18.         <property name="poolSize" value="10" />  
  19.         <property name="minPoolSize" value="10"/>  
  20.         <property name="maxPoolSize" value="30"/>  
  21.         <property name="borrowConnectionTimeout" value="60"/>  
  22.         <property name="reapTimeout" value="20"/>  
  23.         <!-- 最大空闲时间 -->  
  24.         <property name="maxIdleTime" value="60"/>  
  25.         <property name="maintenanceInterval" value="60"/>  
  26.         <property name="loginTimeout" value="60"/>  
  27.         <property name="testQuery">  
  28.             <value>select 1</value>  
  29.         </property>  
  30.     </bean>  
  31.   
  32.    <bean id="qadataSource" class="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean">  
  33.         <!-- value只要两个数据源不同就行，随便取名 -->  
  34.         <property name="uniqueResourceName" value="dlDB" />  
  35.         <property name="driverClassName">  
  36.             <value>com.mysql.jdbc.Driver</value>  
  37.         </property>  
  38.         <property name="url">  
  39.             <value>${mysql.qa.db.url}</value>  
  40.         </property>  
  41.         <property name="user">  
  42.             <value>${mysql.qa.db.user}</value>  
  43.         </property>  
  44.         <property name="password">  
  45.             <value>${mysql.qa.db.password}</value>  
  46.         </property>  
  47.     </bean>  
  48.   
  49.     <bean id="devdataSource" class="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean">  
  50.         <!-- value只要两个数据源不同就行，随便取名 -->  
  51.         <property name="uniqueResourceName" value="nyxsDB" />  
  52.        <property name="driverClassName">  
  53.             <value>${oracle.dev.db.driverClassName}</value>  
  54.         </property>  
  55.         <property name="url">  
  56.             <value>${oracle.dev.db.url}</value>  
  57.         </property>  
  58.         <property name="user">  
  59.             <value>${oracle.dev.db.user}</value>  
  60.         </property>  
  61.         <property name="password">  
  62.             <value>${oracle.dev.db.password}</value>  
  63.         </property>  
  64.     </bean>  
  65.   
  66.     <bean id="qasqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  
  67.         <property name="dataSource" ref="qadataSource" />  
  68.         <property name="mapperLocations" value="classpath*:com/xy/dao/*.xml" />  
  69.     </bean>  
  70.   
  71.     <bean id="devsqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  
  72.         <property name="dataSource" ref="devdataSource" />  
  73.         <property name="mapperLocations" value="classpath*:com/xy/daodev/*.xml" />  
  74.     </bean>  
  75.   
  76.     <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"  
  77.           init-method="init" destroy-method="close">  
  78.         <property name="forceShutdown">  
  79.             <value>true</value>  
  80.         </property>  
  81.     </bean>  
  82.     <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">  
  83.         <property name="transactionTimeout" value="300" />  
  84.     </bean>  
  85.   
  86.     <bean id="transactionManager"  
  87.           class="org.springframework.transaction.jta.JtaTransactionManager">  
  88.         <property name="transactionManager">  
  89.             <ref bean="atomikosTransactionManager"/>  
  90.         </property>  
  91.         <property name="userTransaction">  
  92.             <ref bean="atomikosUserTransaction"/>  
  93.         </property>  
  94.         <!-- 必须设置，否则程序出现异常 JtaTransactionManager does not support custom isolation levels by default -->  
  95.         <property name="allowCustomIsolationLevels" value="true"/>  
  96.   
  97.     </bean>  
  98.   
  99.     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  
  100.         <property name="basePackage" value="com.xy.dao"/>  
  101.         <property name="sqlSessionFactoryBeanName" value="qasqlSessionFactory" />  
  102.     </bean>  
  103.   
  104.     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  
  105.         <property name="basePackage" value="com.xy.daodev"/>  
  106.         <property name="sqlSessionFactoryBeanName" value="devsqlSessionFactory" />  
  107.     </bean>  
  108. </beans>  


web.xml

[html] view plain copy
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.          xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"  
  4.          version="2.5">  
  5.     <listener>  
  6.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>  
  7.     </listener>  
  8.     <listener>  
  9.         <listener-class>  
  10.             org.springframework.web.context.request.RequestContextListener  
  11.         </listener-class>  
  12.     </listener>  
  13.       
  14.     <!--  
  15.     <context-param>  
  16.         <param-name>contextConfigLocation</param-name>  
  17.         <param-value>classpath:context/mysql-beans.xml</param-value>  
  18.     </context-param>  
  19.       
  20.      <context-param>  
  21.         <param-name>contextConfigLocation</param-name>  
  22.         <param-value>classpath:context/oracle-beans.xml</param-value>  
  23.     </context-param>  
  24.       
  25.      <context-param>  
  26.         <param-name>contextConfigLocation</param-name>  
  27.         <param-value>classpath:context/sqlserver-beans.xml</param-value>  
  28.     </context-param>  
  29.       
  30.       <context-param>  
  31.         <param-name>contextConfigLocation</param-name>  
  32.         <param-value>classpath:context/sqlserver-oracle-beans.xml</param-value>  
  33.      </context-param>  
  34.      -->  
  35.        
  36.     <span style="color:#ff6666;">  <context-param>  
  37.         <param-name>contextConfigLocation</param-name>  
  38.         <param-value>classpath:context/mysql-oracle-beans.xml</param-value>  
  39.      </context-param></span>  
  40.       
  41.     <servlet>  
  42.         <servlet-name>test</servlet-name>  
  43.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>  
  44.         <init-param>  
  45.             <param-name>contextConfigLocation</param-name>  
  46.             <param-value>classpath:context/test-web.xml</param-value>  
  47.         </init-param>  
  48.         <load-on-startup>100</load-on-startup>  
  49.     </servlet>  
  50.     <servlet-mapping>  
  51.         <servlet-name>test</servlet-name>  
  52.         <url-pattern>/</url-pattern>  
  53.     </servlet-mapping>  
  54.     <welcome-file-list>  
  55.         <welcome-file>index</welcome-file>  
  56.     </welcome-file-list>  
  57.   
  58. </web-app>  

 

 

基本上看这个三个配置文件就可以了，不明白的话，可以下载完整工程，dbsql有完整的建表语句

分享到：
| 高效的缓存管理解决方案-AutoLoadCache
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

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

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

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

    本篇文档主要讲述如何使用Spring Boot结合MyBatis、JTA（Java Transaction API）以及Atomikos实现多数据源的事务管理。 ### Spring Boot框架 Spring Boot是Spring家族中的一个全新框架，用于简化新Spring应用的...

    Atomikos分布式事务DEMO

    Atomikos分布式事务DEMO是一个基于Spring、MyBatis、MySQL和Tomcat的示例项目，主要用于演示和验证分布式事务的处理能力。分布式事务在现代企业级应用中扮演着重要角色，尤其是在处理跨多个数据库或服务的数据一致性...

    Spring中使用atomikos+druid实现经典分布式事务的方法

    Spring 中使用 Atomikos+Druid 实现经典分布式事务的方法 在分布式系统中，经典分布式事务是相对互联网中的柔性分布式事务而言，其特性为 ACID 原则，包括原子性（Atomictiy）、一致性（Consistency）、隔离性...

    maven springboot jta mybatis 分布式事物

    综上所述，这个项目是一个利用 Maven 构建的 Spring Boot 应用，它整合了多数据源、JTA 来处理分布式事务，使用 MyBatis 作为持久层框架，并且集成了某种模板引擎来生成动态页面。这样的设计使得项目具备处理大规模...

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

    总之，这个压缩包提供的示例项目涵盖了Spring Boot、MyBatis、MySQL和JTA的集成，对于理解如何在分布式环境中处理多数据源事务是一个宝贵的参考。学习和理解这些知识点对于开发复杂的企业级应用至关重要。

    Spring-Boot-Game是基于SpringBoot+SpringCloud的开发系统

    5. 分布式事务：Seata或Atomikos等工具处理分布式环境下的事务一致性问题。 6. 日志管理：ELK（Elasticsearch、Logstash、Kibana）堆栈或Fluentd等日志收集和分析，便于故障排查。 7. Docker容器化：使用Docker和...

    spring4.3jar包

    此外，对于分布式事务的处理，Spring 4.3提供了更好的支持，如XAP（eXtreme Application Platform）和Atomikos等事务管理器的集成。 标签中的"jar"表示这是一个Java Archive文件，通常用于打包Java类库。"springmvc...

    乐优商城笔记.zip

    可能涉及到Seata或Atomikos这样的分布式事务管理框架，确保在多服务间的事务一致性。 9. **支付集成**：笔记可能涵盖第三方支付平台如支付宝或微信支付的集成，包括回调处理和异常情况的处理。 10. **微服务架构**...

    基于springboot火车票订票系统的设计与实现(论文+源码)_kaic.zip

    SpringBoot支持分布式事务管理，如Atomikos、Bitronix等，确保数据一致性。 7. **前端界面**：可能使用Thymeleaf、Freemarker等模板引擎配合HTML、CSS和JavaScript来构建用户友好的交互界面，实现动态数据展示和...

    基于sprignboot的电商书城源码.zip

    1. SpringBoot基础：SpringBoot是Spring框架的简化版，它内置了Tomcat服务器、自动配置、starter依赖等，极大地简化了项目构建过程。源码中可以看到如何通过@SpringBootApplication注解启动Spring Boot应用，并利用@...

    SpringBoot 25道面试题和答案.docx

    比如，如果你想在项目中使用MyBatis，只需添加mybatis-spring-boot-starter依赖，Starter就会自动配置好MyBatis的基本设置，包括数据源、事务管理器等，开发者无需手动编写大量配置代码。 SpringBoot JPA则是对Java...

Magicbox
Global site tag (gtag.js) - Google Analytics