[置顶] 【分布式事务】使用atomikos+jta解决分布式事务问题
2018-01-22 17:26
871 查看
一、前言
分布式事务,这个问题困惑了小编很久,在3个月之前,就间断性的研究分布式事务。从MQ方面,数据库事务方面,jta方面。近期终于成功了,使用JTA解决了分布式事务问题。先写一下心得,后面的二级提交也会在研究。二、介绍
分布式事务说到分布式事务,可以理解为,由于分布式而引起的事务不一致的问题。随着项目做大,模块拆分,数据库拆分。一次包含增删改操作数据库涉及到了更新两个不同物理节点的数据库,这样的数据库事务只能保证自己处理的部分的事务,但是整个的事务就不能保证一致性。
网上针对分布式事务常见的例子有:转账
我从农行转账100元到建设银行。首先,农行和建行的数据库是分开的,其次要在农行数据库中-100,在建行数据库+100。分布式事务就是要保障建行+100出错了,使得农行回滚为原来的数目。
JTA
JTA(java Transaction API)是JavaEE 13 个开发规范之一。java 事务API,允许应用程序执行分布式事务处理——在两个或多个网络计算机资源上访问并且更新数据。JDBC驱动程序的JTA支持极大地增强了数据访问能力。事务最简单最直接的目的就是保证数据的有效性,数据的一致性。
atomikos
实现JTA事务管理第三方管理工具 ,一个是JOTM,一个是Atomikos。在其他的博客中看到了JOTM最后更新日期是2010年,然后果断研究是Atomikos。
Atomikos TransactionsEssentials 是一个为Java平台提供增值服务的并且开源类事务管理器,以下是包括在这个开源版本中的一些功能:
全面崩溃 / 重启恢复 兼容标准的SUN公司JTA API 嵌套事务 为XA和非XA提供内置的JDBC适配器
三、解决分布式事务
3.1 业务说明
业务有两个数据库,分别在192.168.22.58和192.168.22.58上,分别有
t_allusers表和
t_student表,业务是要想两个表中添加一条记录,如果后一条失败了,那么前一条要回滚:
3.1 环境说明
SSM框架Mysql
Maven
3.2 引入依赖
<!--分布式事务相关Atomikos+jta--> <dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-jdbc</artifactId> <version>4.0.6</version> </dependency> <dependency> <groupId>javax.transaction</groupId> <artifactId>jta</artifactId> <version>1.1</version> </dependency>
3.3 配置数据源
在spring配置文件applicationContext-dao.xml配置文件中,添加分布式事务相关的配置:jta事务管理器,不同数据库的数据源配置。<!-- 分布式事务 --> <!-- jta事务管理器 --> <bean id="jtaTransactionManager" 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 name="transactionTimeout" value="300" /> </bean> </property> </bean> <!-- 配置数据源 --> <bean id="jtaDataSource1" 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://192.168.22.58:3306/db?useUnicode=true&characterEncoding=UTF-8 </prop> <prop key="user">root</prop> <prop key="password">root</prop> <prop key="pinGlobalTxToPhysicalConnection">true</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> <!-- 配置数据源 --> <bean id="jtaDataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> <property name="uniqueResourceName" value="ds2" /> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" /> <property name="xaProperties"> <props> <prop key="url">jdbc:mysql://192.168.22.59:3306/db?useUnicode=true&characterEncoding=UTF-8 </prop> <prop key="user">root</prop> <prop key="password">root</prop> <prop key="pinGlobalTxToPhysicalConnection">true</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.4 与mybatis整合
项目开发使用ssm框架,所以还要配置spring和mybatis整合:首先通过逆向工程,生成两个数据库中两个表的mapper和实体,这里小编把两个数据库生成的mapper放置到了连个不同的路径下:
spring和mybatis结合,建立两个sqlsessionfactory ,分别管理两个数据库:
<!-- 让spring管理sqlsessionfactory 使用mybatis和spring整合包中的 --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <!-- 数据库连接池 --> <property name="dataSource" ref="jtaDataSource1" /> <!-- 加载mybatis的全局配置文件 --> <property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml"/> </bean> <bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean"> <!-- 数据库连接池 --> <property name="dataSource" ref="jtaDataSource2" /> <!-- 加载mybatis的全局配置文件 --> <property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml"/> </bean> <!--指定mybatis的mapper文件的位置--> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="com.dmsd.studentdao" /> <property name="sqlSessionFactory" ref="sqlSessionFactory"></property> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="com.dmsd.dao" /> <property name="sqlSessionFactory" ref="sqlSessionFactory2"></property> </bean>
3.5 使用Spring AOP 添加事务
这里需要注意的是:通知的事务管理器是jtaTransactionManager,在前面配置Bean的时候配置的。要使用jta的 事务管理器。<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd"> <!-- 数据源 --> <property name="dataSource" ref="dataSource"/> </bean> <!-- 通知 --> <tx:advice id="txAdvice" transaction-manager="jtaTransactionManager"> <tx:attributes> <!-- 传播行为 --> <tx:method name="save*" propagation="REQUIRED" /> <tx:method name="insert*" propagation="REQUIRED" /> <tx:method name="add*" propagation="REQUIRED" /> <tx:method name="create*" propagation="REQUIRED" /> <tx:method name="delete*" propagation="REQUIRED" /> <tx:method name="update*" propagation="REQUIRED" /> <tx:method name="find*" propagation="SUPPORTS" read-only="true" /> <tx:method name="select*" propagation="SUPPORTS" read-only="true" /> <tx:method name="get*" propagation="SUPPORTS" read-only="true" /> </tx:attributes> </tx:advice> <!-- 切面 --> <aop:config> <aop:advisor advice-ref="txAdvice" pointcut="execution(* com.dmsd.api..*.*(..))" /> </aop:config> </beans>
3.6 实现service
package com.dmsd.service; import com.dmsd.api.UserService; import com.dmsd.dao.TAllusersMapper; import com.dmsd.pojo.TAllusers; import com.dmsd.pojo.TStudent; import com.dmsd.pojo.TUser; import com.dmsd.studentdao.TStudentMapper; import com.sun.org.apache.bcel.internal.generic.NEW; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Service; import javax.sql.DataSource; import java.util.List; import java.util.Map; /** * Created by Ares on 2017/10/24. */ @Service public class UserServiceImpl implements UserService { @Autowired TAllusersMapper tAllusersMapper; @Autowired TStudentMapper tStudentMapper; @Override public void addStudent2() { TAllusers tAllusers1 = tAllusersMapper.selectByPrimaryKey(1); System.out.println(tAllusers1); TStudent tStudent = new TStudent(); tStudent.setAddress("langfang"); tStudent.setName("AresCCCC"); tStudentMapper.insert(tStudent); TAllusers tAllusers2 =new TAllusers(); tAllusers2.setAddress("shagnhai"); tAllusers2.setName("AresDDDD"); tAllusersMapper.insert(tAllusers2); // int a =1/0; } }
3.7 实现Controller
package com.dmsd.controller; import com.dmsd.api.UserService; import com.dmsd.pojo.TUser; import com.dmsd.tool.JacksonJsonUntil; import com.fasterxml.jackson.core.JsonProcessingException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; /** * Created by Ares on 2017/10/24. */ @Controller public class UserController { //注入api @Autowired private UserService userService; @RequestMapping("/addStudent2") @ResponseBody public void addStudent2() { userService.addStudent2(); } }
3.8 运行
在浏览器中输入http://localhost:8080/addStudent2,查看数据库:
当没有报错的时候,数据都插入进来:
当service中的int a =1/0;代码解开注释的时候,就会报错,这样两个库都插入不进去。
四、小结
分布式事务,系统分布式后,必然会出现的技术问题。小编就分布式事务来说,小编使用分布式事务的解决机制后,必然会造成性能的消耗。在项目建立的时候,要避免分布式事务,如果实在避免不了,可以采取下面的几个方案:
同一个web服务器,多个数据库,可以使用Atomikos
跨越多个web服务器的事务,如果远程调用支持事务传播,那么使用JTA就可以;如果不支持事务传播,进尽量转化为一个weib服务器的情况。
自己开发事务逻辑的事务管理器
采用业务补偿回滚机制,比如使用mq
重新设计规划
相关文章推荐
- 使用Atomikos Transactions Essentials实现多数据源JTA分布式事务
- Spring3.0+Hibernate+Atomikos集成构建JTA的分布式事务--解决多数据源跨库事务
- Spring+Hibernate+Atomikos集成构建JTA的分布式事务--解决多数据源跨库事务
- 使用nhmicro提供的micro-datasource嵌入式的解决微服务架构中分布式事务问题
- Spring3.0+Hibernate+Atomikos集成构建JTA的分布式事务--解决多数据源跨库事务
- 使用Atomikos Transactions Essentials实现多数据源JTA分布式事务--转载
- Spring+Hibernate+Atomikos集成构建JTA的分布式事务--解决多数据源跨库事务
- 使用Atomikos Transactions Essentials实现多数据源JTA分布式事务
- 使用Atomikos Transactions Essentials实现多数据源JTA分布式事务
- 解决“COM+ 无法与 Microsoft 分布式事务协调程序交谈”的问题
- 使用复制存储过程执行解决“事务复制中的表大量更新导致无法及时同步”的问题
- 使用TableDiff实用工具解决事务复制中的问题
- 分布式事务入门例子(Spring+JTA+Atomikos+Hibernate+JMS)
- 使用TableDiff实用工具解决事务复制中的问题
- ORA-14450: 试图访问已经在使用的事务处理临时表,根据网上文章提供的方法,问题是解决了
- [置顶] 64位Win2008_VS2012使用ODP.NET遭遇问题和解决办法
- Java事务处理全解析(八)——分布式事务入门例子(Spring+JTA+Atomikos+Hibernate+JMS)
- 使用TableDiff实用工具解决事务复制中的问题
- 使用TableDiff实用工具解决事务复制中的问题
- 使用复制存储过程执行解决“事务复制中的表大量更新导致无法及时同步”的问题