淺談SpringBoot之事務處理機制

2024-07-13 10:16:18

字體：大中小

來源：轉載

供稿：網友

一、Spring的事務機制

所有的數據訪問技術都有事務處理機制，這些技術提供了API用來開啟事務、提交事務來完成數據操作，或者在發生錯誤的時候回滾數據。

而Spring的事務機制是用統一的機制來處理不同數據訪問技術的事務處理。Spring的事務機制提供了一個PlatformTransactionManager接口，不同的數據訪問技術的事務使用不同的接口實現：

SpringBoot,事務處理機制,事務

在程序中定義事務管理器的代碼如下：

@Bean public PlatformTransactionManager transactionManager() {  JpaTransactionManager transactionManager = new JpaTransactionManager();  transactionManager.setDataSource(dataSource());  return transactionManager; }

二、聲明式事務

Spring支持聲明式事務，即使用注解來選擇需要使用事務的方法，它使用@Transactional注解在方法上表明該方法需要事務支持。

@Transactional public void saveSomething(Long id, String name) {  //數據庫操作 }

在此處需要特別注意的是，此@Transactional注解來自org.springframework.transaction.annotation包，而不是javax.transaction。

Spring提供了一個@EnableTransactionManagement注解在配置類上來開啟聲明式事務的支持。使用了@EnableTransactionManagement后，Spring容器會自動掃描注解@Transactional的方法和類。@EnableTransactionManagement的使用方式如下：

@Configuration @EnableTransactionManagement public class AppConfig {  }

三、類級別使用@Transactional

@Transactional不僅可以注解在方法上，也可以注解在類上。當注解在類上的時候意味著此類的所有public方法都是開啟事務的。如果類級別和方法級別同時使用了@Transactional注解，則使用在類級別的注解會重載方法級別的注解。

四、Spring Data JPA的事務支持

Spring Data JPA對所有的默認方法都開啟了事務支持，且查詢類事務默認啟用readOnly=true屬性。

這個從源碼SimpleJpaRepository中可以看出，SimpleJpaRepository在類級別定義了@Transactional（readOnly=true），而在和save、delete相關的操作重寫了@Transactional屬性，此時readOnly屬性是false，其余查詢操作readOnly仍然為false。

五、Spring Boot的事務支持

1.自動配置的事務管理器

在使用JDBC作為數據訪問技術的時候，SpringBoot為我們定義了PlatformTransactionManager的實現DataSourceTransactionManager的Bean；配置見org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration類中的定義：

@Bean @ConditionalOnMissingBean @ConditionalOnBean(DataSource.class) public PlatformTransactionManager transactionManager() {  return new DataSourceTransactionManager(this.dataSource); }

在使用JPA作為數據訪問技術的時候，Spring Boot為我們了定義一個PlatformTransactionManager的實現JpaTransactionManager的Bean；配置見org.springframework.boot.autoconfigure.orm.jpa.JpaBaseConfiguration.class類中的定義：

@Bean @ConditionalOnMissingBean(PlatformTransactionManager.class) public PlatformTransactionManager transactionManager() {  return new JpaTransactionManager(); }

2.自動開啟注解事務的支持

Spring Boot專門用于配置事務的類為：org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration，此配置類依賴于JpaBaseConfiguration和DataSourceTransactionManagerAutoConfiguration。

而在DataSourceTransactionManagerAutoConfiguration配置里還開啟了對聲明式事務的支持，代碼如下：

@ConditionalOnMissingBean(AbstractTransactionManagementConfiguration.class) @Configuration @EnableTransactionManagement protected static class TransactionManagementConfiguration {  }

所以在Spring Boot中，無須顯示開啟使用@EnableTransactionManagement注解。

六、實例（Springboot）

1.pom.xml：

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-rest</artifactId> </dependency> <dependency>  <groupId>mysql</groupId>  <artifactId>mysql-connector-java</artifactId>  <scope>runtime</scope> </dependency>

2.application.yml：

server:  port: 5000  spring:  datasource:  driver-class-name: com.mysql.jdbc.Driver  url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8  username: root  password: password   jpa:  hibernate:  ddl-auto: update # 第一次簡表create 后面用update  show-sql: true

3.實體類Staff：

@Entity public class Staff {  @Id  @GeneratedValue  private Long id;  private String name;  private Integer age;  private String address;   public Staff() {  super();  }   public Staff(Long id, String name, Integer age, String address) {  super();  this.id = id;  this.name = name;  this.age = age;  this.address = address;  }  //省略get、set方法 }

4.Staff的Repository：

public interface StaffRepository extends JpaRepository<Staff, Long> {  }

5.服務接口：

public interface StaffService {  public Staff saveStaffWithRollBack(Staff staff);//回滾  public Staff saveStaffWithoutRollBack(Staff staff);//不回滾 }

6.服務實現：

@Service public class StaffServiceImpl implements StaffService {   @Autowired  StaffRepository staffRepository; //可以直接注入我們的RersonRepository的Bean。   @Override  //使用@Transactional注解的rollbackFor屬性，指定特定異常時，數據回滾。  @Transactional(rollbackFor = {IllegalArgumentException.class})  public Staff saveStaffWithRollBack(Staff staff) {  Staff s = staffRepository.save(staff);  if (staff.getName().equals("張三")) {   throw new IllegalArgumentException("張三已經存在了，rollback");  }  return s;  }   @Override  public Staff saveStaffWithoutRollBack(Staff staff) {  Staff s = staffRepository.save(staff);  if (staff.getName().equals("張三")) {   throw new IllegalArgumentException("張三已經存在了，數據不回滾");  }  return s;  } }

7.Controller：

@RestController @RequestMapping("/staff") public class StaffController {  @Autowired  StaffService staffService;   //測試回滾情況  @RequestMapping("/rollback")  public Staff rollback(Staff staff) {  return staffService.saveStaffWithRollBack(staff);  }   //測試不回滾情況  @RequestMapping("/notrollback")  public Staff noRollBack(Staff staff) {  return staffService.saveStaffWithoutRollBack(staff);  } }

8.運行測試：

（1）回滾：http://localhost:5000/staff/rollback?name=張三&age=18

SpringBoot,事務處理機制,事務