看到關于spring事物比較好的兩篇文章,轉載過來。
1.事務的定義:事務是指多個操作單元組成的合集,多個單元操作是整體不可分割的,要么都操作不成功,要么都成功。其必須遵循四個原則(ACID)。
- 原子性(Atomicity):即事務是不可分割的最小工作單元,事務內的操作要么全做,要么全不做;
- 一致性(Consistency):在事務執(zhí)行前數據庫的數據處于正確的狀態(tài),而事務執(zhí)行完成后數據庫的數據還是應該處于正確的狀態(tài),即數據完整性約束沒有被破壞;如銀行轉帳,A轉帳給B,必須保證A的錢一定轉給B,一定不會出現A的錢轉了但B沒收到,否則數據庫的數據就處于不一致(不正確)的狀態(tài)。
- 隔離性(Isolation):并發(fā)事務執(zhí)行之間互不影響,在一個事務內部的操作對其他事務是不產生影響,這需要事務隔離級別來指定隔離性;
- 持久性(Durability):事務一旦執(zhí)行成功,它對數據庫的數據的改變必須是永久的,不會因比如遇到系統故障或斷電造成數據不一致或丟失。
2.事務的類型
- 數據庫分為本地事務跟全局事務
- 本地事務:普通事務,獨立一個數據庫,能保證在該數據庫上操作的ACID。
- 分布式事務:涉及兩個或多個數據庫源的事務,即跨越多臺同類或異類數據庫的事務(由每臺數據庫的本地事務組成的),分布式事務旨在保證這些本地事務的所有操作的ACID,使事務可以跨越多臺數據庫;
- Java事務類型分為JDBC事務跟JTA事務
- JDBC事務:即為上面說的數據庫事務中的本地事務,通過connection對象控制管理。
- JTA事務:JTA指Java事務API(Java Transaction API),是Java EE數據庫事務規(guī)范, JTA只提供了事務管理接口,由應用程序服務器廠商(如WebSphere Application Server)提供實現,JTA事務比JDBC更強大,支持分布式事務。
- 按是否通過編程分為聲明式事務和編程式事務,參考http://blog.csdn.net/liaohaojian/article/details/70139151
- 聲明式事務:通過XML配置或者注解實現。
- 編程式事務:通過編程代碼在業(yè)務邏輯時需要時自行實現,粒度更小。
3.Spring事務隔離級別:spring有五大隔離級別,其在TransactionDefinition接口中定義??丛创a可知,其默isolation_default(底層數據庫默認級別),其他四個隔離級別跟數據庫隔離級別一致。
- ISOLATION_DEFAULT:用底層數據庫的默認隔離級別,數據庫管理員設置什么就是什么
- ISOLATION_READ_UNCOMMITTED(未提交讀):最低隔離級別、事務未提交前,就可被其他事務讀?。〞霈F幻讀、臟讀、不可重復讀)
- ISOLATION_READ_COMMITTED(提交讀):一個事務提交后才能被其他事務讀取到(該隔離級別禁止其他事務讀取到未提交事務的數據、所以還是會造成幻讀、不可重復讀)、sql server默認級別
- ISOLATION_REPEATABLE_READ(可重復讀):可重復讀,保證多次讀取同一個數據時,其值都和事務開始時候的內容是一致,禁止讀取到別的事務未提交的數據(該隔離基本可防止臟讀,不可重復讀(重點在修改),但會出現幻讀(重點在增加與刪除))(MySql默認級別,更改可通過set transaction isolation level 級別)
- ISOLATION_SERIALIZABLE(序列化):代價最高最可靠的隔離級別(該隔離級別能防止臟讀、不可重復讀、幻讀)
- 丟失更新:兩個事務同時更新一行數據,最后一個事務的更新會覆蓋掉第一個事務的更新,從而導致第一個事務更新的數據丟失,這是由于沒有加鎖造成的;
- 幻讀:同樣的事務操作過程中,不同時間段多次(不同事務)讀取同一數據,讀取到的內容不一致(一般是行數變多或變少)。
- 臟讀:一個事務讀取到另外一個未提及事務的內容,即為臟讀。
- 不可重復讀:同一事務中,多次讀取內容不一致(一般行數不變,而內容變了)。
幻讀與不可重復讀的區(qū)別:幻讀的重點在于插入與刪除,即第二次查詢會發(fā)現比第一次查詢數據變少或者變多了,以至于給人一種幻象一樣,而不可重復讀重點在于修改,即第二次查詢會發(fā)現查詢結果比第一次查詢結果不一致,即第一次結果已經不可重現了。
數據庫隔離級別越高,執(zhí)行代價越高,并發(fā)執(zhí)行能力越差,因此在實際項目開發(fā)使用時要綜合考慮,為了考慮并發(fā)性能一般使用提交讀隔離級別,它能避免丟失更新和臟讀,盡管不可重復讀和幻讀不能避免,但可以在可能出現的場合使用悲觀鎖或樂觀鎖來解決這些問題。
悲觀鎖與樂觀鎖可參考:http://blog.csdn.net/liaohaojian/article/details/62416972
4.傳播行為:有七大傳播行為,也是在TransactionDefinition接口中定義。
PROPAGATION_REQUIRED:支持當前事務,如當前沒有事務,則新建一個。
PROPAGATION_SUPPORTS:支持當前事務,如當前沒有事務,則已非事務性執(zhí)行(源碼中提示有個注意點,看不太明白,留待后面考究)。
PROPAGATION_MANDATORY:支持當前事務,如當前沒有事務,則拋出異常(強制一定要在一個已經存在的事務中執(zhí)行,業(yè)務方法不可獨自發(fā)起自己的事務)。
PROPAGATION_REQUIRES_NEW:始終新建一個事務,如當前原來有事務,則把原事務掛起。
PROPAGATION_NOT_SUPPORTED:不支持當前事務,始終已非事務性方式執(zhí)行,如當前事務存在,掛起該事務。
PROPAGATION_NEVER:不支持當前事務;如果當前事務存在,則引發(fā)異常。
PROPAGATION_NESTED:如果當前事務存在,則在嵌套事務中執(zhí)行,如果當前沒有事務,則執(zhí)行與 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接口定義如下
public interface PlatformTransactionManager {
//返回一個已經激活的事務或創(chuàng)建一個新的事務(具體由TransactionDefinition參數定義的事務屬性決定),
// 返回的TransactionStatus對象代表了當前事務的狀態(tài),
// 其中該方法拋出TransactionException(未檢查異常)表示事務由于某種原因失敗。
TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
//用于提交TransactionStatus參數代表的事務。
void commit(TransactionStatus status) throws TransactionException;
//用于回滾TransactionStatus參數代表的事務。
void rollback(TransactionStatus status) throws TransactionException;
}
TransactionDefinition接口定義如下:
public interface TransactionDefinition {
int getPropagationBehavior(); //返回定義的事務傳播行為
int getIsolationLevel(); //返回事務隔離級別
int getTimeout(); //返回定義的事務超時時間
boolean isReadOnly(); //返回定義的事務是否是只讀的
String getName(); //返回事務名稱
}
TransactionStatus接口定義如下:
public interface TransactionStatus extends SavepointManager {
boolean isNewTransaction(); //返回當前事務是否是新的事務
boolean hasSavepoint(); //返回當前事務是否有保存點
void setRollbackOnly(); //設置事務回滾
boolean isRollbackOnly(); //設置當前事務是否應該回滾
//用于刷新底層會話中的修改到數據庫,一般用于刷新如Hibernate/JPA的會話,
// 可能對如JDBC類型的事務無任何影響;
void flush();
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>
<!-- 動態(tài)配置數據源 -->
<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:必須要有事務, 如果沒有就在上下文創(chuàng)建一個 -->
<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>
atomikos所需包及相關配置文件下載路徑:http://download.csdn.net/detail/liaohaojian/9813868,其中文件jta.properties文件放到classpath根目錄下。