Spring MVC系列-(6) 聲明式事務

時間  2020-12-08
標籤 mysql git github 面試 spring sql 數據庫 後端 併發 app 欄目 Spring 简体版
原文   原文鏈接

Spring.png

6 聲明式事務

6.1 Spring中事務的使用

在進行數據操做事，一般會將多條SQL語句做爲總體進行操做，這一條或者多條SQL語句就稱爲數據庫事務。數據庫事務能夠確保該事務範圍內的全部操做均可以所有成功或者所有失敗。若是事務失敗，那麼效果就和沒有執行這些SQL同樣，不會對數據庫數據有任何改動。mysql

事務是恢復和併發控制的基本單位。git

事務應該具備4個屬性：原子性、一致性、隔離性、持久性。這四個屬性一般稱爲ACID特性。github

  • 原子性（atomicity）。一個事務是一個不可分割的工做單位，事務中包括的操做要麼都作，要麼都不作。
  • 一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另外一個一致性狀態。一致性與原子性是密切相關的。
  • 隔離性（isolation）。一個事務的執行不能被其餘事務干擾。即一個事務內部的操做及使用的數據對併發的其餘事務是隔離的，併發執行的各個事務之間不能互相干擾。
  • 持久性（durability）。持久性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其餘操做或故障不該該對其有任何影響。

Spring中能夠經過@Transactional註解，實現了對事務的支持。面試

首先定義配置類，配置類中建立了數據源，封裝了jdbcTemplate和事務管理器。spring

@Configuration
@ComponentScan("com.enjoy.cap11")
@EnableTransactionManagement  //開啓事務管理功能，對@Transactional起做用
public class Cap11MainConfig {
	//建立數據源
	@Bean
	public DataSource dataSource() throws PropertyVetoException{
		//這個c3p0封裝了JDBC, dataSource接口的實現
		ComboPooledDataSource dataSource = new ComboPooledDataSource();
		dataSource.setUser("root");
		dataSource.setPassword("xxxxx");
		dataSource.setDriverClass("com.mysql.jdbc.Driver");
		dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/Spring?useSSL=false");
		return dataSource;
	}
	
	//jdbcTemplate能簡化增刪改查的操做
	@Bean
	public JdbcTemplate jdbcTemplate() throws PropertyVetoException{
		return new JdbcTemplate(dataSource());
	}
	//註冊事務管理器
	@Bean
	public PlatformTransactionManager platformTransactionManager() throws PropertyVetoException{
		return new DataSourceTransactionManager(dataSource());
	}
}

新建Order測試表：sql

CREATE TABLE `order` (
  `orderid` int(11) DEFAULT NULL,
  `ordertime` datetime DEFAULT NULL,
  `ordermoney` decimal(20,0) DEFAULT NULL,
  `orderstatus` char(1) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8

新建OrderDao操做數據庫，數據庫

@Repository
public class OrderDao {
	@Autowired
	private JdbcTemplate jdbcTemplate;
	//操做數據的方法
	public void insert(){
		String sql = "insert into `order` (ordertime, ordermoney, orderstatus) values(?,?,?)";
		jdbcTemplate.update(sql,new Date(),20,0);
	}
}

新建 OrderService類，將orderDao注入進來後端

@Service
public class OrderService {
    @Autowired
	private OrderDao orderDao;
    @Transactional
    public void addOrder(){
    	orderDao.insert();
    	System.out.println("操做完成.........");
    	
    	//int a = 1/0;
    }
}

在下面的測試用例中，正常的向數據庫中插入一條數據，查詢數據庫能夠發現插入正常。併發

public class Cap11Test {
	@Test
	public void test01(){
		AnnotationConfigApplicationContext app = new AnnotationConfigApplicationContext(Cap11MainConfig.class);
		
		OrderService bean = app.getBean(OrderService.class);
		bean.addOrder();
		
		app.close();
	}
}

可是接着測試，在addOrder方法中手動設置一個異常，下面的代碼中，在運行時會拋出除數爲0的異常。從運行結果能夠看到，這種狀況下數據庫的插入操做沒有成功，說明Spring對insert操做進行了回滾，保證了事務的一致性。app

@Service
public class OrderService {
    @Autowired
	private OrderDao orderDao;
    @Transactional
    public void addOrder(){
    	orderDao.insert();
    	System.out.println("操做完成.........");
    	
    	int a = 1/0;
    }
}

6.2 Spring事務原理分析

在上面的例子中，爲了使事務可以生效，須要加上@EnableTransactionManagement註解，整個源碼實現和AOP原理一致，在註冊Bean時對對象進行包裝，生成加強的Bean，返回代理對象。在執行階段，利用事務攔截器來運行有事務註解的代碼，當出現異常時進行回滾。

經過@EnableTransactionManagement引入的class能夠看到，默認PROXY模式下，會引入AutoProxyRegistrar.class和ProxyTransactionManagementConfiguration.class，下面分析這兩個組件的功能。

Screen Shot 2020-02-17 at 10.14.19 PM.png

AutoProxyRegistrar.class

從下面的代碼能夠看到，和AOP相似，該組件會往容器中註冊InfrastructureAdvisorAutoProxyCreator，利用後置處理器機制在對象建立之後，包裝對象，返回一個代理對象（加強器），代理對象執行方法利用攔截器鏈進行調用。

Screen Shot 2020-02-17 at 10.25.28 PM.png

ProxyTransactionManagementConfiguration.class

事務加強器要用事務註解的信息，AnnotationTransactionAttributeSource解析事務註解。

Screen Shot 2020-02-17 at 11.27.29 PM.png

攔截執行流程

和AOP相似，在攔截執行的時候，首先會獲取攔截鏈，而後依次執行攔截器的proceed方法。

事務攔截器是TransactionInterceptor，它也是MethodInterceptor的子類，下面是其執行時的主要邏輯，概括能夠分爲以下幾步：

  1. 先獲取事務相關的屬性
  2. 再獲取PlatformTransactionManager，若是事先沒有添加指定任何transactionmanger
    最終會從容器中按照類型獲取一個PlatformTransactionManager；
  3. 執行目標方法
  • 若是異常，獲取到事務管理器，利用事務管理回滾操做；
  • 若是正常，利用事務管理器，提交事務。

Screen Shot 2020-02-17 at 11.25.32 PM.png

6.3 Spring的事務隔離級別與傳播性

隔離級別

隔離性（Isolation）做爲事務特性的一個關鍵特性，它要求每一個讀寫事務的對象對其餘事務的操做對象能相互分離，即該事務提交前對其餘事務都不可見，在數據庫層面都是使用鎖來實現。

在辨析不一樣的隔離級別以前，引入幾個基本概念：

1. 髒讀 ：髒讀就是指當一個事務正在訪問數據，而且對數據進行了修改，而這種修改尚未提交到數據庫中，這時，另一個事務也訪問這個數據，而後使用了這個數據。

2. 不可重複讀 ：是指在一個事務內，屢次讀同一數據。在這個事務尚未結束時，另一個事務也訪問該同一數據。那麼，在第一個事務中的兩次讀數據之間，因爲第二個事務的修改，那麼第一個事務兩次讀到的的數據多是不同的。這樣就發生了在一個事務內兩次讀到的數據是不同的，所以稱爲是不可重複讀。簡單來說就是，事務 A 讀取了事務 B 已提交的更改數據。

3. 幻讀 : 是指當事務不是獨立執行時發生的一種現象，例如第一個事務對一個表中的數據進行了修改，這種修改涉及到表中的所有數據行。 同時，第二個事務也修改這個表中的數據，這種修改是向表中插入一行新數據。那麼，之後就會發生操做第一個事務的用戶發現表中還有沒有修改的數據行，就好象 發生了幻覺同樣。簡單來說就是，事務 A 讀取了事務 B 已提交的新增數據。

事務的隔離級別從低到高有如下四種：

  • READ UNCOMMITTED（未提交讀）：這是最低的隔離級別，其含義是容許一個事務讀取另一個事務沒有提交的數據。READ UNCOMMITTED是一種危險的隔離級別，在實際開發中基本不會使用，主要是因爲它會帶來髒讀問題。

髒讀對於要求數據一致性的應用來講是致命的，目前主流的數據庫的隔離級別都不會設置成READ UNCOMMITTED。不過髒讀雖然看起來毫無用處，可是它主要優勢是併發能力高，適合那些對數據一致性沒有要求而追求高併發的場景。

  • READ COMMITTED（讀寫提交）: 它是指一個事務只能讀取另一個事務已經提交的數據，不能讀取未提交的數據。READ COMMITTED會帶來不可重複讀的問題。

通常來講，不可重複讀的問題是能夠接受的，由於其讀到的是已經提交的數據，自己並不會帶來很大的問題。所以，不少數據庫如（ORACLE，SQL SERVER）將其默認隔離級別設置爲READ COMMITTED，容許不可重複讀的現象。

  • REPEATABLE READ （可重複讀）：對相同字段的屢次讀取的結果是一致的，除非數據被當前事務自己改變。可防止髒讀和不可重複讀，但幻影讀仍可能發生。

  • SERIALIZABLE（串行化）：數據庫最高的隔離級別，它要求全部的SQL都會按照順序執行，這樣能夠克服上述全部隔離出現的各類問題，可以徹底包住數據的一致性。

Spring中能夠配置5種隔離級別：

DEFAULT(-1),  ## 數據庫默認級別
READ_UNCOMMITTED(1),
READ_COMMITTED(2),
REPEATABLE_READ(4),
SERIALIZABLE(8);

可使用相似下面的註解，很方便的配置隔離級別：

@Transactional(isolation = Isolation.SERIALIZABLE)
public int insertUser(User user){
    return userDao.insertUser(user);
}

上面的代碼中咱們使用了串行化的隔離級別來包住數據的一致性，這使它將阻塞其餘的事務進行併發，因此它只能運用在那些低併發而又須要保證數據一致性的場景下。

傳播行爲

在Spring中，當一個方法調用另一個方法時，可讓事務採起不一樣的策略工做，如新建事務或者掛起當前事務等，這即是事務的傳播行爲。

在Spring的事務機制中對數據庫存在7種傳播行爲，經過枚舉類Propagation定義。

public enum Propagation {
    /**
     * 須要事務，默認傳播性行爲。
     * 若是當前存在事務，就沿用當前事務，不然新建一個事務運行子方法
     */
    REQUIRED(0),
    /**
     * 支持事務，若是當前存在事務，就沿用當前事務，
     * 若是不存在，則繼續採用無事務的方式運行子方法
     */
    SUPPORTS(1),
    /**
     * 必須使用事務，若是當前沒有事務，拋出異常
     * 若是存在當前事務,就沿用當前事務
     */
    MANDATORY(2),
    /**
     * 不管當前事務是否存在，都會建立新事務容許方法
     * 這樣新事務就能夠擁有新的鎖和隔離級別等特性，與當前事務相互獨立
     */
    REQUIRES_NEW(3),
    /**
     * 不支持事務，當前存在事務時，將掛起事務，運行方法
     */
    NOT_SUPPORTED(4),
    /**
     * 不支持事務，若是當前方法存在事務，將拋出異常，不然繼續使用無事務機制運行
     */
    NEVER(5),
    /**
     * 在當前方法調用子方法時，若是子方法發生異常
     * 只回滾子方法執行過的SQL，而不回滾當前方法的事務
     */
    NESTED(6);
}

平常開發中基本只會使用到REQUIRED(0),REQUIRES_NEW(3),NESTED(6)三種。

NESTED和REQUIRES_NEW是有區別的。NESTED傳播行爲會沿用當前事務的隔離級別和鎖等特性，而REQUIRES_NEW則能夠擁有本身獨立的隔離級別和鎖等特性。

NESTED的實現主要依賴於數據庫的保存點（SAVEPOINT）技術，SAVEPOINT記錄了一個保存點，能夠經過ROLLBACK TO SAVEPOINT來回滾到某個保存點。若是數據庫支持保存點技術時就啓用保存點技術；若是不支持就會新建一個事務去執行代碼，也就至關於REQUIRES_NEW。

Transactional自調用失效

若是一個類中自身方法的調用，咱們稱之爲自調用。如一個訂單業務實現類OrderServiceImpl中有methodA方法調用了自身類的methodB方法就是自調用，如：

@Transactional
public void methodA(){
    for (int i = 0; i < 10; i++) {
        methodB();
    }
}
    
@Transactional(isolation = Isolation.READ_COMMITTED,propagation = Propagation.REQUIRES_NEW)
public int methodB(){
    ......
}

在上面方法中無論methodB如何設置隔離級別和傳播行爲都是不生效的。即自調用失效。

這主要是因爲@Transactional的底層實現原理是基於AOP實現，而AOP的原理是動態代理，在自調用的過程當中是類自身的調用，而不是代理對象去調用，那麼就不會產生AOP，因而就發生了自調用失敗的現象。

要克服這個問題，有2種方法：

  • 編寫兩個Service,用一個Service的methodA去調用另一個Service的methodB方法，這樣就是代理對象的調用，不會有問題；
  • 在同一個Service中，methodA不直接調用methodB，而是先從Spring IOC容器中從新獲取代理對象OrderServiceImpl,獲取到後再去調用methodB。提及來有點亂，仍是show you the code。
public class OrderServiceImpl implements OrderService,ApplicationContextAware {
    private ApplicationContext applicationContext = null;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) {
        this.applicationContext = applicationContext;
    }

    @Transactional
    public void methodA(){
        OrderService orderService = applicationContext.getBean(OrderService.class);
        for (int i = 0; i < 10; i++) {
            orderService.methodB();
        }
    }

    @Transactional(isolation = Isolation.READ_COMMITTED,propagation = Propagation.REQUIRES_NEW)
    public int methodB(){
        ......
    }
}

上面代碼中咱們先實現了ApplicationContextAware接口，而後經過applicationContext.getBean()獲取了OrderService的接口對象。這個時候獲取到的是一個代理對象，也就能正常使用AOP的動態代理了。

參考：

本文由『後端精進之路』原創，首發於博客 http://teckee.github.io/ , 轉載請註明出處

搜索『後端精進之路』關注公衆號，馬上獲取最新文章和價值2000元的BATJ精品面試課程。

後端精進之路.png

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程