Spring事務管理詳細講解

更新時間：2022年10月17日 09:07:49 作者：一根頭發(fā)學一年

事務的作用就是為了保證用戶的每一個操作都是可靠的，事務中的每一步操作都必須成功執(zhí)行，只要有發(fā)生異常就?回退到事務開始未進行操作的狀態(tài)。事務管理是Spring框架中最為常用的功能之一，我們在使用Spring?Boot開發(fā)應用時，大部分情況下也都需要使用事務

事務回顧

事務是邏輯上的一組數(shù)據(jù)庫操作，要么都執(zhí)行，要么都不執(zhí)行。

假如，張三給李四轉(zhuǎn)賬100元，轉(zhuǎn)賬行為歐兩個關(guān)鍵操作：將張三的余額減200元，將李四的余額增加200元。如果兩個操作之間突然出現(xiàn)錯誤，例如銀行系統(tǒng)崩潰導致張三余額減少，而李四的余額沒有增加，這樣的系統(tǒng)是有問題的。事務就是保證這兩個關(guān)鍵操作要么都成功，要么都要失敗。

事務的特性：

事務是最小的執(zhí)行單位，不允許分割。事務的原子性確保動作要么全部完成，要么完全不起作用；
一致性：確保從一個正確的狀態(tài)轉(zhuǎn)換到另外一個正確的狀態(tài)，這就是一致性；
并發(fā)訪問數(shù)據(jù)庫時，一個用戶的事務不被其他事務所干擾，各并發(fā)事務之間數(shù)據(jù)庫是獨立的；
持久性：一個事務被提交之后，對數(shù)據(jù)庫中數(shù)據(jù)的改變是持久的，即使數(shù)據(jù)庫發(fā)生故障也不應該對其有任何影響。

spring事務操作

在 Spring 進行事務管理操作，編程式事務管理和聲明式事務管理。編程式事務管理一般是代碼手動控制，比較繁瑣，所以一般推薦使用聲明式事務管理。

為了講解事務的機制，以銀行在那個轉(zhuǎn)賬為例，創(chuàng)建服務類、dao類，如下：

dao接口：

package com.example.dao;
public interface UserDao {
    /**
     * 取錢
     */
    void reduceMoney();
    /**
     * 存錢
     */
    void addMoney();
}

dao接口實現(xiàn)類

package com.example.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
@Repository
public class UserDaoImpl implements UserDao{
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public void reduceMoney() {
        String sql = "update t_account set money=money-? where username=?";
        jdbcTemplate.update(sql,100,"lucy");
    }
    @Override
    public void addMoney() {
        String sql = "update t_account set money=money+? where username=?";
        jdbcTemplate.update(sql,100,"mary");
    }
}

service類

package com.example.service;
import com.example.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserService {
    @Autowired
    private UserDao userDao;
    /**
     * 模擬轉(zhuǎn)賬操作
     */
    public void accountMoney() {
        //lucy 少 100
        userDao.reduceMoney();
        //mary 多 100
        userDao.addMoney();
    }
}

其中accountMoney方法模擬了轉(zhuǎn)賬操作。

基于注解聲明事務

在 Spring 進行聲明式事務管理，使用注解@Transactional注解，底層使用 AOP 原理。其本質(zhì)是對方法前后進行攔截，然后在目標方法開始之前創(chuàng)建或者加入一個事務，執(zhí)行完目標方法之后根據(jù)執(zhí)行的情況提交或者回滾。

@Transactional注解使用

下面使用注解@Transactional來模擬銀行轉(zhuǎn)賬開啟事務。

1.配置事務管理器

配置文件如下：

<bean id="transactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數(shù)據(jù)源--> 
    <property name="dataSource" ref="dataSource"></property>
</bean>

2.在 spring 配置文件引入名稱空間 tx

<?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:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd">
</beans>

3.配置文件中開啟事務注解

<!--開啟事務注解--> 
<tx:annotation-driven transactionmanager="transactionManager"></tx:annotation-driven>

整體的配置文件如下：

<?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:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!-- 開啟注解掃描 -->
    <context:component-scan base-package="com.example"></context:component-scan>
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close"> <property name="url" value="jdbc:mysql://localhost:3306/cys-test" />
        <property name="username" value="root" />
        <property name="password" value="123456" />
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
    </bean>
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入 dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <bean id="transactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入數(shù)據(jù)源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--開啟事務-->
    <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
</beans>

4.在 service 類上面添加事務注解

或者 service 類里面方法上面添加事務注解（@Transactional）。

如果把這個注解添加類上面，這個類里面所有的方法都添加事務，如果把這個注解添加方法上面，為這個方法添加事務。

package com.example.service;
import com.example.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
@Transactional
public class UserService {
    @Autowired
    private UserDao userDao;
    /**
     * 模擬轉(zhuǎn)賬操作
     */
    public void accountMoney() {
        System.out.println("開始轉(zhuǎn)賬");
        //lucy 少 100
        userDao.reduceMoney();
        // 模擬中間異常
        int i = 10/0;
        //mary 多 100
        userDao.addMoney();
        System.out.println("轉(zhuǎn)賬結(jié)束");
    }
}

其中再轉(zhuǎn)賬的過程中使用除數(shù)為0的異常來模擬一同出現(xiàn)異常。

5.測試類

package com.example.test;
import com.example.service.UserService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test01 {
    @Test
    public void testAccount() {
        ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("bean1.xml");
        UserService userService = app.getBean(UserService.class);
        userService.accountMoney();
    }
}

經(jīng)過測試結(jié)果就是：如果不開啟事務，中間出現(xiàn)異常，前面已經(jīng)執(zhí)行的操作就會提交到數(shù)據(jù)庫，這樣上面的案例的結(jié)果就是lucy的錢少了100，但是mary的錢并沒有增多。如果開啟事務，則lucy的錢少了100和mary的錢加100是一個原子操作，中間出現(xiàn)異常就會把全部操作回滾。

事務傳播機制

當事務方法被另外一個事務方法調(diào)用時，必須指定事務應該如何傳播，例如，方法可能繼續(xù)在當前事務中執(zhí)行，也可以開啟一個新的事務，在自己的事務中執(zhí)行。

聲明式事務的傳播行為可以通過 @Transactional 注解中的 propagation 屬性來定義，格式如下：

@Service
@Transactional(propagation = Propagation.REQUIRED)
public class UserService {
}

Propagation屬性有如下幾個值，其中PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW 兩種傳播行為是比較常用。

傳播行為	描述
PROPAGATION_REQUIRED	默認的Spring事物傳播級別，若當前存在事務，則加入該事務，若不存在事務，則新建一個事務
PROPAGATION_REQUIRE_NEW	若當前沒有事務，則新建一個事務。若當前存在事務，則新建一個事務，新老事務相互獨立。外部事務拋出異?；貪L不會影響內(nèi)部事務的正常提交
PROPAGATION_NESTED	如果當前存在事務，則嵌套在當前事務中執(zhí)行。如果當前沒有事務，則新建一個事務，類似于REQUIRE_NEW
PROPAGATION_SUPPORTS	支持當前事務，若當前不存在事務，以非事務的方式執(zhí)行
PROPAGATION_NOT_SUPPORTED	以非事務的方式執(zhí)行，若當前存在事務，則把當前事務掛起
PROPAGATION_MANDATORY	強制事務執(zhí)行，若當前不存在事務，則拋出異常
PROPAGATION_NEVER	以非事務的方式執(zhí)行，如果當前存在事務，則拋出異常

事務隔離級別

@Transactional 注解中的 isolation 屬性來定義事務的隔離級別，有以下五種隔離級別：

ISOLATION_DEFAULT，使用數(shù)據(jù)庫默認的隔離級別，MySql 默認采用的是REPEATABLE_READ，也就是可重復讀。
ISOLATION_READ_UNCOMMITTED，最低的隔離級別，可能會出現(xiàn)臟讀、幻讀或者不可重復讀。
ISOLATION_READ_COMMITTED，允許讀取并發(fā)事務提交的數(shù)據(jù)，可以防止臟讀，但幻讀和不可重復讀仍然有可能發(fā)生。
ISOLATION_REPEATABLE_READ，對同一字段的多次讀取結(jié)果都是一致的，除非數(shù)據(jù)是被自身事務所修改的，可以阻止臟讀和不可重復讀，但幻讀仍有可能發(fā)生。
ISOLATION_SERIALIZABLE，最高的隔離級別，雖然可以阻止臟讀、幻讀和不可重復讀，但會嚴重影響程序性能。

通常情況下，采用默認的隔離級別 ISOLATION_DEFAULT 就可以了，也就是交給數(shù)據(jù)庫來決定。

@Transactional其他屬性

1、timeout：超時時間

（1）事務需要在一定時間內(nèi)進行提交，如果不提交進行回滾

（2）默認值是 -1 ，設(shè)置時間以秒單位進行計算

2、readOnly：是否只讀

（1）讀：查詢操作，寫：添加修改刪除操作

（2）readOnly 默認值 false，表示可以查詢，可以添加修改刪除操作

（3）設(shè)置 readOnly 值是 true，設(shè)置成 true 之后，只能查詢

3、rollbackFor：回滾

（1）設(shè)置出現(xiàn)哪些異常進行事務回滾

4、noRollbackFor：不回滾

（1）設(shè)置出現(xiàn)哪些異常不進行事務回滾

基于XML 聲明式事務

步驟：

第一步配置事務管理器

第二步配置通知

第三步配置切入點和切面

xml文件如下：

<?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:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!-- 開啟注解掃描 -->
    <context:component-scan base-package="com.example"></context:component-scan>
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close"> <property name="url" value="jdbc:mysql://localhost:3306/cys-test" />
        <property name="username" value="root" />
        <property name="password" value="123456" />
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
    </bean>
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入 dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--創(chuàng)建事務管理器-->
    <bean id="transactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入數(shù)據(jù)源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--2 配置通知-->
    <tx:advice id="txadvice">
    <!--配置事務參數(shù)-->
        <tx:attributes>
        <!--指定哪種規(guī)則的方法上面添加事務-->
            <tx:method name="accountMoney" propagation="REQUIRED"/>
    <!--<tx:method name="account*"/>-->
        </tx:attributes>
    </tx:advice>
    <!--3 配置切入點和切面-->
    <aop:config>
        <!--配置切入點-->
        <aop:pointcut id="pt" expression="execution(*com.atguigu.spring5.service.UserService.*(..))"/>
        <!--配置切面-->
        <aop:advisor advice-ref="txadvice" pointcut-ref="pt"/>
    </aop:config>
</beans>

完全注解開發(fā)

創(chuàng)建配置類，使用配置類替代 xml 配置文件

package com.example.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
@Configuration //配置類
@ComponentScan(basePackages = "com.example") //組件掃描
@EnableTransactionManagement //開啟事務
public class TxConfig {
    //創(chuàng)建數(shù)據(jù)庫連接池
    @Bean
    public DruidDataSource getDruidDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///user_db");
        dataSource.setUsername("root");
        dataSource.setPassword("root");
        return dataSource;
    }
    //創(chuàng)建 JdbcTemplate 對象
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource dataSource) {
        //到 ioc 容器中根據(jù)類型找到 dataSource
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        //注入 dataSource
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }
    //創(chuàng)建事務管理器
    @Bean
    public DataSourceTransactionManager
    getDataSourceTransactionManager(DataSource dataSource) {
        DataSourceTransactionManager transactionManager = new
                DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    } }

到此這篇關(guān)于Spring事務管理詳細講解的文章就介紹到這了,更多相關(guān)Spring事務管理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: