快捷導航

詳解Springboot事務(wù)管理

更新時間：2017年12月22日 08:38:03 作者：icecrea

本篇文章主要介紹了詳解Springboot事務(wù)管理，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

在Spring Boot事務(wù)管理中，實現(xiàn)自接口PlatformTransactionManager。

public interface PlatformTransactionManager {
  org.springframework.transaction.TransactionStatus getTransaction(org.springframework.transaction.TransactionDefinition transactionDefinition) throws org.springframework.transaction.TransactionException;

  void commit(org.springframework.transaction.TransactionStatus transactionStatus) throws org.springframework.transaction.TransactionException;

  void rollback(org.springframework.transaction.TransactionStatus transactionStatus) throws org.springframework.transaction.TransactionException;
}

當我們使用了spring-boot-starter-jdbc依賴的時候，框架會自動默認注入DataSourceTransactionManager。所以我們不需要任何額外配置就可以用@Transactional注解進行事務(wù)的使用。

jdbc事務(wù)管理器

在Service中，被 @Transactional 注解的方法，將支持事務(wù)。如果注解在類上，則整個類的所有方法都默認支持事務(wù)。

多事務(wù)管理器情況

一：可以通過實現(xiàn)TransactionManagementConfigurer接口，里面方法返回值是默認的事務(wù)管理器。

二：可以在具體執(zhí)行方法上設(shè)置value

如果Spring容器中存在多個 PlatformTransactionManager 實例，并且沒有實現(xiàn)接口TransactionManagementConfigurer 指定默認值，在我們在方法上使用注解 @Transactional 的時候，就必須要用value指定，如果不指定，則會拋出異常。

//@EnableTransactionManagement // 開啟注解事務(wù)管理，等同于xml配置文件中的 <tx:annotation-driven />
@SpringBootApplication
public class ProfiledemoApplication implements TransactionManagementConfigurer {
  @Resource(name="txManager2")
  private PlatformTransactionManager txManager2;
  // 手動創(chuàng)建事務(wù)管理器1 datasource框架會自動注入
  //在Spring容器中，我們手工注解@Bean 將被優(yōu)先加載，框架不會重新實例化其他的 PlatformTransactionManager 實現(xiàn)類。
  @Bean(name = "txManager1")
  public PlatformTransactionManager txManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  // 創(chuàng)建事務(wù)管理器2
  @Bean(name = "txManager2")
  public PlatformTransactionManager txManager2(EntityManagerFactory factory) {
    return new JpaTransactionManager(factory);
  }

  // 實現(xiàn)接口 TransactionManagementConfigurer 方法，其返回值代表在擁有多個事務(wù)管理器的情況下默認使用的事務(wù)管理器
  @Override
  public PlatformTransactionManager annotationDrivenTransactionManager() {
    return txManager2;
  }

  public static void main(String[] args) {
    SpringApplication.run(ProfiledemoApplication.class, args);
  }

}

具體實現(xiàn)

@Component
public class DevSendMessage implements SendMessage {
  // 使用value具體指定使用哪個事務(wù)管理器
  @Transactional(value="txManager1")
  @Override
  public void send() {
    System.out.println(">>>>>>>>Dev Send()<<<<<<<<");
    send2();
  }

  @Transactional
  public void send2() {
    System.out.println(">>>>>>>>Dev Send2()<<<<<<<<");
  }
}

隔離級別

public enum Isolation {
  DEFAULT(TransactionDefinition.ISOLATION_DEFAULT),
  READ_UNCOMMITTED(TransactionDefinition.ISOLATION_READ_UNCOMMITTED),
  READ_COMMITTED(TransactionDefinition.ISOLATION_READ_COMMITTED),
  REPEATABLE_READ(TransactionDefinition.ISOLATION_REPEATABLE_READ),
  SERIALIZABLE(TransactionDefinition.ISOLATION_SERIALIZABLE);
  private final int value;
  Isolation(int value) { this.value = value; }
  public int value() { return this.value; }

}

DEFAULT ：這是默認值，表示使用底層數(shù)據(jù)庫的默認隔離級別。對大部分數(shù)據(jù)庫而言，通常這值就是： READ_COMMITTED 。
READ_UNCOMMITTED ：該隔離級別表示一個事務(wù)可以讀取另一個事務(wù)修改但還沒有提交的數(shù)據(jù)。該級別不能防止臟讀和不可重復(fù)讀，因此很少使用該隔離級別。
READ_COMMITTED ：該隔離級別表示一個事務(wù)只能讀取另一個事務(wù)已經(jīng)提交的數(shù)據(jù)。該級別可以防止臟讀，這也是大多數(shù)情況下的推薦值。
REPEATABLE_READ ：該隔離級別表示一個事務(wù)在整個過程中可以多次重復(fù)執(zhí)行某個查詢，并且每次返回的記錄都相同。即使在多次查詢之間有新增的數(shù)據(jù)滿足該查詢，這些新增的記錄也會被忽略。該級別可以防止臟讀和不可重復(fù)讀。
SERIALIZABLE ：所有的事務(wù)依次逐個執(zhí)行，這樣事務(wù)之間就完全不可能產(chǎn)生干擾，也就是說，該級別可以防止臟讀、不可重復(fù)讀以及幻讀。但是這將嚴重影響程序的性能。通常情況下也不會用到該級別。

指定方法：通過使用 isolation 屬性設(shè)置，例如：

@Transactional(isolation = Isolation.DEFAULT)

傳播行為

所謂事務(wù)的傳播行為是指，如果在開始當前事務(wù)之前，一個事務(wù)上下文已經(jīng)存在，此時有若干選項可以指定一個事務(wù)性方法的執(zhí)行行為。

我們可以看 org.springframework.transaction.annotation.Propagation 枚舉類中定義了6個表示傳播行為的枚舉值：

public enum Propagation {
  REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),
  SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),
  MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),
  REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),
  NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),
  NEVER(TransactionDefinition.PROPAGATION_NEVER),
  NESTED(TransactionDefinition.PROPAGATION_NESTED);
  private final int value;
  Propagation(int value) { this.value = value; }
  public int value() { return this.value; }
}

REQUIRED ：如果當前存在事務(wù)，則加入該事務(wù)；如果當前沒有事務(wù)，則創(chuàng)建一個新的事務(wù)。默認值。

SUPPORTS ：如果當前存在事務(wù)，則加入該事務(wù)；如果當前沒有事務(wù)，則以非事務(wù)的方式繼續(xù)運行。

MANDATORY ：如果當前存在事務(wù)，則加入該事務(wù)；如果當前沒有事務(wù)，則拋出異常。（強制放入事務(wù)中）

REQUIRES_NEW ：創(chuàng)建一個新的事務(wù)，如果當前存在事務(wù)，則把當前事務(wù)掛起。（打印日志常用，即使前面回滾，該事務(wù)也會執(zhí)行，記錄報錯信息）

NOT_SUPPORTED ：以非事務(wù)方式運行，如果當前存在事務(wù)，則把當前事務(wù)掛起。

NEVER ：以非事務(wù)方式運行，如果當前存在事務(wù)，則拋出異常。

NESTED ：如果當前存在事務(wù)，則創(chuàng)建一個事務(wù)作為當前事務(wù)的嵌套事務(wù)來運行；如果當前沒有事務(wù)，則該取值等價于 REQUIRED 。

指定方法：通過使用 propagation 屬性設(shè)置，例如：

@Transactional(propagation = Propagation.REQUIRED)

事務(wù)不回滾情況

只在發(fā)生未被捕獲的 RuntimeException 時才回滾

catch拋出的異常，兩次插入都會成功

@Override
  @Transactional
  public void insertandinsert(Staff staff) {
    staffDao.insert(staff);
    try {
      int i = 1 / 0;
    }catch (Exception e){
      e.printStackTrace();
    }
    staffDao.insert(staff);
  }

在service層方法的catch語句中增加：TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();語句，手動回滾不會插入數(shù)據(jù)

@Override
  @Transactional
  public void insertandinsert(Staff staff) throws Exception {
    try {
      staffDao.insert(staff);
      int i=1/0;
      staffDao.insert(staff);
    }catch (Exception e){
      TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    }
  }

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: