因爲細節內容實在太多啦,因此只把部分知識點截圖出來粗略的介紹,每一個小節點裏面都有更細化的內容!git
整理了一份Java核心知識點。覆蓋了JVM、鎖、併發、Java反射、Spring原理、微服務、Zookeeper、數據庫、數據結構等大量知識點。github
若是須要獲取到這個【資料】文檔的話能夠掃一掃下面數據庫
接下來開始分享啦
bash
前言數據結構
你們好,我是哪吒!最近在從新整理 Spring 事務相關的內容,在看 Spring 事務傳播行爲這塊內容的時候,發現了這篇優秀的文章,分享一下。併發
Spring 在 TransactionDefinition 接口中規定了 7 種類型的事務傳播行爲。事務傳播行爲是 Spring 框架獨有的事務加強特性,他不屬於的事務實際提供方數據庫行爲。app
這是 Spring 爲咱們提供的強大的工具箱,使用事務傳播行能夠爲咱們的開發工做提供許多便利。框架
可是人們對他的誤解也頗多,你必定也聽過「service 方法事務最好不要嵌套」的傳言。ide
要想正確的使用工具首先須要瞭解工具。本文對七種事務傳播行爲作詳細介紹,內容主要代碼示例的方式呈現。微服務
事務傳播行爲用來描述由某一個事務傳播行爲修飾的方法被嵌套進另外一個方法的時事務如何傳播。
用僞代碼說明:
public void methodA(){
methodB();
//doSomething
}
@Transaction(Propagation=XXX)
public void methodB(){
//doSomething
}複製代碼
代碼中methodA()方法嵌套調用了methodB()方法,methodB()的事務傳播行爲由@Transaction(Propagation=XXX)設置決定。這裏須要注意的是methodA()並無開啓事務,某一個事務傳播行爲修飾的方法並非必需要在開啓事務的外圍方法中調用。
定義很是簡單,也很好理解,下面咱們就進入代碼測試部分,驗證咱們的理解是否正確。
文中代碼以傳統三層結構中兩層呈現,即 Service 和 Dao 層,由 Spring 負責依賴注入和註解式事務管理,DAO 層由 Mybatis 實現,你也可使用任何喜歡的方式,例如,Hibernate,JPA,JDBCTemplate 等。數據庫使用的是 MySQL 數據庫,你也可使用任何支持事務的數據庫,並不會影響驗證結果。
首先咱們在數據庫中建立兩張表:
user1
CREATE TABLE `user1` (
`id` INTEGER UNSIGNED NOT NULL AUTO_INCREMENT,
`name` VARCHAR(45) NOT NULL DEFAULT '',
PRIMARY KEY(`id`)
)
ENGINE = InnoDB;複製代碼
user2
CREATE TABLE `user2` (
`id` INTEGER UNSIGNED NOT NULL AUTO_INCREMENT,
`name` VARCHAR(45) NOT NULL DEFAULT '',
PRIMARY KEY(`id`)
)
ENGINE = InnoDB;複製代碼
而後編寫相應的 Bean 和 DAO 層代碼:
User1
public class User1 {
private Integer id;
private String name;
//get和set方法省略...
}複製代碼
User2
public class User2 {
private Integer id;
private String name;
//get和set方法省略...
}複製代碼
User1Mapper
public interface User1Mapper {
int insert(User1 record);
User1 selectByPrimaryKey(Integer id);
//其餘方法省略...
}複製代碼
User2Mapper
public interface User2Mapper {
int insert(User2 record);
User2 selectByPrimaryKey(Integer id);
//其餘方法省略...
}複製代碼
最後也是具體驗證的代碼由 service 層實現,下面咱們分狀況列舉。
咱們爲 User1Service 和 User2Service 相應方法加上Propagation.REQUIRED屬性。
User1Service 方法:
@Service
public class User1ServiceImpl implements User1Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void addRequired(User1 user){
user1Mapper.insert(user);
}
}複製代碼
User2Service 方法:
@Service
public class User2ServiceImpl implements User2Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void addRequired(User2 user){
user2Mapper.insert(user);
}
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void addRequiredException(User2 user){
user2Mapper.insert(user);
throw new RuntimeException();
}
}複製代碼
此場景外圍方法沒有開啓事務。
驗證方法 1:
@Override
public void notransaction_exception_required_required(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequired(user2);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Override
public void notransaction_required_required_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiredException(user2);
}複製代碼
分別執行驗證方法,結果:
結論:經過這兩個方法咱們證實了在外圍方法未開啓事務的狀況下Propagation.REQUIRED修飾的內部方法會新開啓本身的事務,且開啓的事務相互獨立,互不干擾。
外圍方法開啓事務,這個是使用率比較高的場景。
驗證方法 1:
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void transaction_exception_required_required(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequired(user2);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void transaction_required_required_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiredException(user2);
}複製代碼
驗證方法 3:
@Transactional
@Override
public void transaction_required_required_exception_try(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
try {
user2Service.addRequiredException(user2);
} catch (Exception e) {
System.out.println("方法回滾");
}
}複製代碼
分別執行驗證方法,結果:
結論:以上試驗結果咱們證實在外圍方法開啓事務的狀況下Propagation.REQUIRED修飾的內部方法會加入到外圍方法的事務中,全部Propagation.REQUIRED修飾的內部方法和外圍方法均屬於同一事務,只要一個方法回滾,整個事務均回滾。
咱們爲 User1Service 和 User2Service 相應方法加上Propagation.REQUIRES_NEW屬性。User1Service 方法:
@Service
public class User1ServiceImpl implements User1Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void addRequiresNew(User1 user){
user1Mapper.insert(user);
}
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void addRequired(User1 user){
user1Mapper.insert(user);
}
}複製代碼
User2Service 方法:
@Service
public class User2ServiceImpl implements User2Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void addRequiresNew(User2 user){
user2Mapper.insert(user);
}
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void addRequiresNewException(User2 user){
user2Mapper.insert(user);
throw new RuntimeException();
}
}複製代碼
外圍方法沒有開啓事務。
驗證方法 1:
@Override
public void notransaction_exception_requiresNew_requiresNew(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequiresNew(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiresNew(user2);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Override
public void notransaction_requiresNew_requiresNew_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequiresNew(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiresNewException(user2);
}複製代碼
分別執行驗證方法,結果:
結論:經過這兩個方法咱們證實了在外圍方法未開啓事務的狀況下Propagation.REQUIRES_NEW修飾的內部方法會新開啓本身的事務,且開啓的事務相互獨立,互不干擾。
外圍方法開啓事務。
驗證方法 1:
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void transaction_exception_required_requiresNew_requiresNew(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiresNew(user2);
User2 user3=new User2();
user3.setName("王五");
user2Service.addRequiresNew(user3);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void transaction_required_requiresNew_requiresNew_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiresNew(user2);
User2 user3=new User2();
user3.setName("王五");
user2Service.addRequiresNewException(user3);
}複製代碼
驗證方法 3:
@Override
@Transactional(propagation = Propagation.REQUIRED)
public void transaction_required_requiresNew_requiresNew_exception_try(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addRequired(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addRequiresNew(user2);
User2 user3=new User2();
user3.setName("王五");
try {
user2Service.addRequiresNewException(user3);
} catch (Exception e) {
System.out.println("回滾");
}
}複製代碼
分別執行驗證方法,結果:
結論:在外圍方法開啓事務的狀況下Propagation.REQUIRES_NEW修飾的內部方法依然會單獨開啓獨立事務,且與外部方法事務也獨立,內部方法之間、內部方法和外部方法事務均相互獨立,互不干擾。
咱們爲 User1Service 和 User2Service 相應方法加上Propagation.NESTED屬性。User1Service 方法:
@Service
public class User1ServiceImpl implements User1Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.NESTED)
public void addNested(User1 user){
user1Mapper.insert(user);
}
}複製代碼
User2Service 方法:
@Service
public class User2ServiceImpl implements User2Service {
//省略其餘...
@Override
@Transactional(propagation = Propagation.NESTED)
public void addNested(User2 user){
user2Mapper.insert(user);
}
@Override
@Transactional(propagation = Propagation.NESTED)
public void addNestedException(User2 user){
user2Mapper.insert(user);
throw new RuntimeException();
}
}複製代碼
此場景外圍方法沒有開啓事務。
驗證方法 1:
@Override
public void notransaction_exception_nested_nested(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addNested(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addNested(user2);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Override
public void notransaction_nested_nested_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addNested(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addNestedException(user2);
}複製代碼
分別執行驗證方法,結果:
結論:經過這兩個方法咱們證實了在外圍方法未開啓事務的狀況下Propagation.NESTED和Propagation.REQUIRED做用相同,修飾的內部方法都會新開啓本身的事務,且開啓的事務相互獨立,互不干擾。
外圍方法開啓事務。
驗證方法 1:
@Transactional
@Override
public void transaction_exception_nested_nested(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addNested(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addNested(user2);
throw new RuntimeException();
}複製代碼
驗證方法 2:
@Transactional
@Override
public void transaction_nested_nested_exception(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addNested(user1);
User2 user2=new User2();
user2.setName("李四");
user2Service.addNestedException(user2);
}複製代碼
驗證方法 3:
@Transactional
@Override
public void transaction_nested_nested_exception_try(){
User1 user1=new User1();
user1.setName("張三");
user1Service.addNested(user1);
User2 user2=new User2();
user2.setName("李四");
try {
user2Service.addNestedException(user2);
} catch (Exception e) {
System.out.println("方法回滾");
}
}複製代碼
分別執行驗證方法,結果:
結論:以上試驗結果咱們證實在外圍方法開啓事務的狀況下Propagation.NESTED修飾的內部方法屬於外部事務的子事務,外圍主事務回滾,子事務必定回滾,而內部子事務能夠單獨回滾而不影響外圍主事務和其餘子事務
由「1.2 場景二」和「3.2 場景二」對比,咱們可知:NESTED 和 REQUIRED 修飾的內部方法都屬於外圍方法事務,若是外圍方法拋出異常,這兩種方法的事務都會被回滾。可是 REQUIRED 是加入外圍方法事務,因此和外圍事務同屬於一個事務,一旦 REQUIRED 事務拋出異常被回滾,外圍方法事務也將被回滾。而 NESTED 是外圍方法的子事務,有單獨的保存點,因此 NESTED 方法拋出異常被回滾,不會影響到外圍方法的事務。
由「2.2 場景二」和「3.2 場景二」對比,咱們可知:NESTED 和 REQUIRES_NEW 均可以作到內部方法事務回滾而不影響外圍方法事務。可是由於 NESTED 是嵌套事務,因此外圍方法回滾以後,做爲外圍方法事務的子事務也會被回滾。而 REQUIRES_NEW 是經過開啓新的事務實現的,內部事務和外圍事務是兩個事務,外圍事務回滾不會影響內部事務。
鑑於文章篇幅問題,其餘事務傳播行爲的測試就不在此一一描述了,感興趣的讀者能夠去源碼中本身尋找相應測試代碼和結果解釋。傳送門:https://github.com/TmTse/transaction-test
介紹了這麼多事務傳播行爲,咱們在實際工做中如何應用呢?下面我來舉一個示例:
假設咱們有一個註冊的方法,方法中調用添加積分的方法,若是咱們但願添加積分不會影響註冊流程(即添加積分執行失敗回滾不能使註冊方法也回滾),咱們會這樣寫:
@Service
public class UserServiceImpl implements UserService {
@Transactional
public void register(User user){
try {
membershipPointService.addPoint(Point point);
} catch (Exception e) {
//省略...
}
//省略...
}
//省略...
}複製代碼
咱們還規定註冊失敗要影響addPoint()方法(註冊方法回滾添加積分方法也須要回滾),那麼addPoint()方法就須要這樣實現:
@Service
public class MembershipPointServiceImpl implements MembershipPointService{
@Transactional(propagation = Propagation.NESTED)
public void addPoint(Point point){
try {
recordService.addRecord(Record record);
} catch (Exception e) {
//省略...
}
//省略...
}
//省略...
}複製代碼
咱們注意到了在addPoint()中還調用了addRecord()方法,這個方法用來記錄日誌。他的實現以下:
@Service
public class RecordServiceImpl implements RecordService{
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void addRecord(Record record){
//省略...
}
//省略...
}複製代碼
咱們注意到addRecord()方法中propagation = Propagation.NOT_SUPPORTED,由於對於日誌無所謂精確,能夠多一條也能夠少一條,因此addRecord()方法自己和外圍addPoint()方法拋出異常都不會使addRecord()方法回滾,而且addRecord()方法拋出異常也不會影響外圍addPoint()方法的執行。
經過這個例子相信你們對事務傳播行爲的使用有了更加直觀的認識,經過各類屬性的組合確實能讓咱們的業務實現更加靈活多樣。
經過上面的介紹,相信你們對 Spring 事務傳播行爲有了更加深刻的理解,但願你們平常開發工做有所幫助。
因爲細節內容實在太多啦,因此只把部分知識點截圖出來粗略的介紹,每一個小節點裏面都有更細化的內容!
整理了一份Java核心知識點。覆蓋了JVM、鎖、併發、Java反射、Spring原理、微服務、Zookeeper、數據庫、數據結構等大量知識點。
若是須要獲取到這個【資料】文檔的話能夠掃一掃下面