本篇文章给大家带来的内容是关于spring事务隔离级别、传播行为以及spring+mybatis+atomikos实现分布式事务管理,有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助。
1.事务的定义:事务是指多个操作单元组成的合集,多个单元操作是整体不可分割的,要么都操作不成功,要么都成功。其必须遵循四个原则(acid)。原子性(atomicity):即事务是不可分割的最小工作单元,事务内的操作要么全做,要么全不做;
一致性(consistency):在事务执行前数据库的数据处于正确的状态,而事务执行完成后数据库的数据还是应该处于正确的状态,即数据完整性约束没有被破坏;如银行转帐,a转帐给b,必须保证a的钱一定转给b,一定不会出现a的钱转了但b没收到,否则数据库的数据就处于不一致(不正确)的状态。
隔离性(isolation):并发事务执行之间互不影响,在一个事务内部的操作对其他事务是不产生影响,这需要事务隔离级别来指定隔离性;
持久性(durability):事务一旦执行成功,它对数据库的数据的改变必须是永久的,不会因比如遇到系统故障或断电造成数据不一致或丢失。
2.事务的类型数据库分为本地事务跟全局事务
本地事务:普通事务,独立一个数据库,能保证在该数据库上操作的acid。
分布式事务:涉及两个或多个数据库源的事务,即跨越多台同类或异类数据库的事务(由每台数据库的本地事务组成的),分布式事务旨在保证这些本地事务的所有操作的acid,使事务可以跨越多台数据库;
java事务类型分为jdbc事务跟jta事务
jdbc事务:即为上面说的数据库事务中的本地事务,通过connection对象控制管理。
jta事务:jta指java事务api(java transaction api),是java ee数据库事务规范, jta只提供了事务管理接口,由应用程序服务器厂商(如websphere application server)提供实现,jta事务比jdbc更强大,支持分布式事务。
按是否通过编程分为声明式事务和编程式事务,参考http://blog.csdn.net/liaohaojian/article/details/70139151
声明式事务:通过xml配置或者注解实现。
编程式事务:通过编程代码在业务逻辑时需要时自行实现,粒度更小。
3.spring事务隔离级别:spring有五大隔离级别,其在transactiondefinition接口中定义。看源码可知,其默isolation_default(底层数据库默认级别),其他四个隔离级别跟数据库隔离级别一致。isolation_default:用底层数据库的默认隔离级别,数据库管理员设置什么就是什么
isolation_read_uncommitted(未提交读):最低隔离级别、事务未提交前,就可被其他事务读取(会出现幻读、脏读、不可重复读)
isolation_read_committed(提交读):一个事务提交后才能被其他事务读取到(该隔离级别禁止其他事务读取到未提交事务的数据、所以还是会造成幻读、不可重复读)、sql server默认级别
isolation_repeatable_read(可重复读):可重复读,保证多次读取同一个数据时,其值都和事务开始时候的内容是一致,禁止读取到别的事务未提交的数据(该隔离基本可防止脏读,不可重复读(重点在修改),但会出现幻读(重点在增加与删除))(mysql默认级别,更改可通过set transaction isolation level 级别)
isolation_serializable(序列化):代价最高最可靠的隔离级别(该隔离级别能防止脏读、不可重复读、幻读)
丢失更新:两个事务同时更新一行数据,最后一个事务的更新会覆盖掉第一个事务的更新,从而导致第一个事务更新的数据丢失,这是由于没有加锁造成的;
幻读:同样的事务操作过程中,不同时间段多次(不同事务)读取同一数据,读取到的内容不一致(一般是行数变多或变少)。
脏读:一个事务读取到另外一个未提及事务的内容,即为脏读。
不可重复读:同一事务中,多次读取内容不一致(一般行数不变,而内容变了)。
幻读与不可重复读的区别:幻读的重点在于插入与删除,即第二次查询会发现比第一次查询数据变少或者变多了,以至于给人一种幻象一样,而不可重复读重点在于修改,即第二次查询会发现查询结果比第一次查询结果不一致,即第一次结果已经不可重现了。
数据库隔离级别越高,执行代价越高,并发执行能力越差,因此在实际项目开发使用时要综合考虑,为了考虑并发性能一般使用提交读隔离级别,它能避免丢失更新和脏读,尽管不可重复读和幻读不能避免,但可以在可能出现的场合使用悲观锁或乐观锁来解决这些问题。
4.传播行为:有七大传播行为,也是在transactiondefinition接口中定义。propagation_required:支持当前事务,如当前没有事务,则新建一个。
propagation_supports:支持当前事务,如当前没有事务,则已非事务性执行(源码中提示有个注意点,看不太明白,留待后面考究)。
propagation_mandatory:支持当前事务,如当前没有事务,则抛出异常(强制一定要在一个已经存在的事务中执行,业务方法不可独自发起自己的事务)。
propagation_requires_new:始终新建一个事务,如当前原来有事务,则把原事务挂起。
propagation_not_supported:不支持当前事务,始终已非事务性方式执行,如当前事务存在,挂起该事务。
propagation_never:不支持当前事务;如果当前事务存在,则引发异常。
propagation_nested:如果当前事务存在,则在嵌套事务中执行,如果当前没有事务,则执行与 propagation_required 类似的操作(注意:当应用到jdbc时,只适用jdbc 3.0以上驱动)。
5.spring事务支持1.spring提供了很多内置事务管理器,支持不同数据源。常见的有三大类
datasourcetransactionmanager:org.springframework.jdbc.datasource包下,数据源事务管理类,提供对单个javax.sql.datasource数据源的事务管理,只要用于jdbc,mybatis框架事务管理。
hibernatetransactionmanager:org.springframework.orm.hibernate3包下,数据源事务管理类,提供对单个org.hibernate.sessionfactory事务支持,用于集成hibernate框架时的事务管理;注意:该事务管理器只支持hibernate3+版本,且spring3.0+版本只支持hibernate 3.2+版本;
jtatransactionmanager:位于org.springframework.transaction.jta包中,提供对分布式事务管理的支持,并将事务管理委托给java ee应用服务器,或者自定义一个本地jta事务管理器,嵌套到应用程序中。
内置事务管理器都继承了抽象类abstractplatformtransactionmanager,而abstractplatformtransactionmanager又继承了接口platformtransactionmanager
spring框架支持事务管理的核心是事务管理器抽象,对于不同的数据访问框架通过实现策略接口platformtransactionmanager,从而能支持多钟数据访问框架的事务管理。
platformtransactionmanager接口定义如下
transactionstatus接口定义如下:public interface transactionstatus extends savepointmanager {         boolean isnewtransaction();  //返回当前事务是否是新的事务       boolean hassavepoint();  //返回当前事务是否有保存点       void setrollbackonly();  //设置事务回滚       boolean isrollbackonly();  //设置当前事务是否应该回滚       void flush();  //用于刷新底层会话中的修改到数据库,一般用于刷新如hibernate/jpa的会话,可能对如jdbc类型的事务无任何影响;       boolean iscompleted();  //返回事务是否完成}
2.spring分布式事务配置
引用应用服务器(如tomcat)的jndi数据源,间接实现jta事务管理,依赖于应用服务器
直接集成jotm(官网:http://jotm.objectweb.org/)、atomikos(官网:https://www.atomikos.com/)提供jta事务管理(无应用服务器支持,常用于单元测试)
使用特定于应用服务器的事务管理器,使用jta事务的高级功能(weblogic,websphere)
1).引用应用服务器(如tomcat)的jndi数据源,间接实现jta事务管理,配置如下
<beans xmlns="http://www.springframework.org/schema/beans"    xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"    xmlns:jee="http://www.springframework.org/schema/jee"    xsi:schemalocation="       http://www.springframework.org/schema/beans       http://www.springframework.org/schema/beans/spring-beans-3.0.xsd       http://www.springframework.org/schema/jee       http://www.springframework.org/schema/jee/spring-jee-3.0.xsd"> <!-- jndi数据源 -->  <jee:jndi-lookup id="datasource" jndi-name="jdbc/test"/>    <!-- jta事务管理器  -->  	<bean id="txmanager" class="org.springframework.transaction.jta.jtatransactionmanager">  		<!--transactionmanagername指定jta事务管理器的jndi名字,从而将事务管理委托给该事务管理器  -->    	<property name="transactionmanagername" value="java:comp/transactionmanager"/>  	</bean></beans>
2)使用atomikos实现分布式事务管理,配置如下:
<?xml version="1.0" encoding="utf-8"?><beans xmlns="http://www.springframework.org/schema/beans"	xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" 	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:context="http://www.springframework.org/schema/context"    xmlns:task="http://www.springframework.org/schema/task"	xsi:schemalocation="http://www.springframework.org/schema/beans 	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd	http://www.springframework.org/schema/context 	http://www.springframework.org/schema/context/spring-context-3.0.xsd	http://www.springframework.org/schema/tx	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd	http://www.springframework.org/schema/task	http://www.springframework.org/schema/task/spring-task-3.0.xsd	http://www.springframework.org/schema/aop	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"	>  	<context:component-scan base-package="com.suicai.*.service.impl" />	<context:component-scan base-package="com.suicai.util" />    <!-- 此方法加载的配置文件仅仅在xml中使用,但是工具类都采用注解的方式 -->	<bean class="org.springframework.beans.factory.config.propertyplaceholderconfigurer">		<property name="location" value="classpath:conn.properties" />	</bean>	<!-- 仅仅支持注解不支持在xml配置中使用properties文件  在类中可以使用spel表达式来加载相应的值 -->	<bean id="temp" class="org.springframework.beans.factory.config.propertiesfactorybean">		<property name="locations">			<array>				<value>classpath:public.properties</value>			</array>		</property>	</bean>	<bean id="abstractxadatasource" class="com.atomikos.jdbc.atomikosdatasourcebean" init-method="init"  destroy-method="close" abstract="true">         <property name="borrowconnectiontimeout" value="60"/>  <!--获取连接失败重新获等待最大时间,在这个时间内如果有可用连接,将返回-->        <property name="reaptimeout" value="20"/> <!--最大获取数据时间,如果不设置这个值,atomikos使用默认的5分钟,那么在处理大批量数据读取的时候,一旦超过5分钟,就会抛出类似 resultset is close 的错误.-->                <property name="maintenanceinterval" value="60" />  <!--连接回收时间-->            <property name="logintimeout" value="60" />     <!--java数据库连接池,最大可等待获取datasouce的时间-->        <property name="logwriter" value="60"/>        <property name="minpoolsize" value="1" />  <!-- 连接池中保留的最小连接数   -->        <property name="maxpoolsize" value="3" />  <!-- 连接池中保留的最大连接数    -->        <property name="maxidletime" value="60" /> <!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。default: 0 -->    </bean>      <!-- 配置2个数据源 mysql -->     <bean id="ds_suicai" parent="abstractxadatasource">       	<!-- uniqueresourcename表示唯一资源名,如有多个数据源不可重复; -->     	<property name="uniqueresourcename" value="suicaifortest" />     	<!--  xadatasourceclassname是具体分布式数据源厂商实现; -->     	<property name="xadatasourceclassname" value="com.mysql.jdbc.jdbc2.optional.mysqlxadatasource"/>     	<!-- xaproperties属性指定具体厂商数据库属性 -->     	<property name="xaproperties">            <props>                <prop key="url">${db.jdbcurlone}</prop>                <prop key="user">${user}</prop>                <prop key="password">${password}</prop>            </props>        </property>    </bean>  	<bean id="ds_kaizhi"  parent="abstractxadatasource">  		<!-- uniqueresourcename表示唯一资源名,如有多个数据源不可重复; -->		<property name="uniqueresourcename" value="puildingpurchasefortest" />		<!-- xadatasourceclassname是具体分布式数据源厂商实现; -->		<property name="xadatasourceclassname" value="com.mysql.jdbc.jdbc2.optional.mysqlxadatasource"/>		<!-- xaproperties属性指定具体厂商数据库属性 -->		<property name="xaproperties">            <props>                <prop key="url">${db.jdbcurltwo}</prop>                <prop key="user">${user}</prop>                <prop key="password">${password}</prop>            </props>        </property>    </bean>      <!-- 动态配置数据源 -->     <bean id="datasource2" class="com.suicai.common.datasource.dynamicdatasource">          <property name="targetdatasources">              <map key-type ="java.lang.string">                  <entry value-ref ="ds_suicai" key="ds_suicai"></entry >                  <entry value-ref ="ds_kaizhi" key="ds_kaizhi"></entry >              </map >         </property>          <property name ="defaulttargetdatasource" ref="ds_suicai"></property>      </bean>    <bean id ="sqlsessionfactorybeana" class="org.mybatis.spring.sqlsessionfactorybean" >         <!-- 指定数据源 -->         <property name ="datasource" ref="ds_suicai" />         <!-- 指定mybatis 的配置文件 -->         <property name ="configlocation" value="classpath:mybatis.cfg.xml" />  	</bean>	<bean id ="sqlsessionfactorybeanb" class="org.mybatis.spring.sqlsessionfactorybean" >         <!-- 指定数据源 -->         <property name ="datasource" ref="ds_kaizhi" />         <!-- 指定mybatis 的配置文件 -->         <property name ="configlocation" value="classpath:mybatis.cfg.xml" />  	</bean>	<!--customsqlsessiontemplate继承sqlsessiontemplate重写getsqlsessionfactory方法,具体请下载查看--> 	<bean id="sqlsessiontemplate" class="com.suicai.util.customsqlsessiontemplate" scope="prototype">        <constructor-arg ref="sqlsessionfactorybeana" />        <property name="targetsqlsessionfactorys">            <map>                     <entry value-ref ="sqlsessionfactorybeana" key="ds_suicai1"></entry >                  <entry value-ref ="sqlsessionfactorybeanb" key="ds_kaizhi1"></entry >              </map>         </property>    </bean>  	<!-- 配置atomikos事务管理器 -->	<bean id="atomikostransactionmanager" class = "com.atomikos.icatch.jta.usertransactionmanager" init-method="init" destroy-method = "close">    	      <property name="forceshutdown" value="true"/>    	</bean>    	<bean id="atomikosusertransaction" class="com.atomikos.icatch.jta.usertransactionimp"></bean>	<!-- 配置spring事务管理器 -->	<bean id="transactionmanager" class="org.springframework.transaction.jta.jtatransactionmanager">    	    <property name="transactionmanager">    	        <ref bean="atomikostransactionmanager"/>    	    </property>    	    <property name="usertransaction">    	        <ref bean="atomikosusertransaction"/>    	    </property> 	    <!-- 必须设置,否则程序出现异常 jtatransactionmanager does not support custom isolation levels by default -->	    <property name="allowcustomisolationlevels" value="true"/>    	</bean>	<tx:advice id="advice" transaction-manager="transactionmanager">		<tx:attributes>		    <!-- required:必须要有事务, 如果没有就在上下文创建一个 -->			<tx:method name="save*" propagation="required"/>			<tx:method name="creat*" propagation="required"/>			<tx:method name="add*" propagation="required"/>			<tx:method name="update*" propagation="required"/>			<tx:method name="delete*" propagation="required"/>			<!-- 支持,如果有就有,没有就没有 -->			<tx:method name="*" propagation="supports"/>		</tx:attributes>	</tx:advice>	<aop:config>	    <aop:pointcut expression="execution(* com.suicai.*.service.impl.*.*(..))" id="pointcut"/>	    <!-- 吧 tx与aop的配置关联,才是完整的声明事务配置 -->	    <aop:advisor advice-ref="advice" pointcut-ref="pointcut"/>	</aop:config>	<!-- 采用包扫描机制,自动会把指定的包里面的所有dao注册 -->	<bean class="org.mybatis.spring.mapper.mapperscannerconfigurer">		<!-- 注意注入sqlsessiontemplate -->        <property name="sqlsessiontemplatebeanname" value="sqlsessiontemplate"/>		<property name="basepackage" value="com.suicai.*.dao" />	</bean>	<bean id="viewresolver" class="org.springframework.web.servlet.view.internalresourceviewresolver">		<property name="viewclass">			<value>org.springframework.web.servlet.view.internalresourceview</value>		</property>		<!--jsp存放的目录-->		<property name="prefix">			<value>/</value>		</property>		<!--jsp文件的后缀-->		<property name="suffix">			<value>.jsp</value>		</property>	</bean>	<!-- 验证码 -->	<bean id="captchaproducer" class="com.google.code.kaptcha.impl.defaultkaptcha">          <property name="config">              <bean class="com.google.code.kaptcha.util.config">                  <constructor-arg>                      <props>                          <prop key="kaptcha.border">no</prop>                          <prop key="kaptcha.border.color">105,179,90</prop>                          <prop key="kaptcha.textproducer.font.color">red</prop>                          <prop key="kaptcha.image.width">200</prop>                          <prop key="kaptcha.textproducer.font.size">60</prop>                          <prop key="kaptcha.image.height">80</prop>                          <prop key="kaptcha.session.key">code</prop>                          <prop key="kaptcha.textproducer.char.length">4</prop>                          <prop key="kaptcha.textproducer.font.names">宋体,楷体,微软雅黑</prop>                      </props>                  </constructor-arg>              </bean>          </property>      </bean>    <bean id="messagesource" class="org.springframework.context.support.reloadableresourcebundlemessagesource">          <property name="basename" value="classpath:messages"/>          <property name="fileencodings" value="utf-8"/>          <property name="cacheseconds" value="120"/>  	</bean></beans>
以上就是spring事务隔离级别、传播行为以及spring+mybatis+atomikos实现分布式事务管理的详细内容。
   
 
   