spring源码分析--Managing Transactions(事物管理配置)

 2019-11-23 11:08  阅读(741)
文章分类:Spring Cloud

1.前提

一直以来都是为了用而学,很少去分析底层原理,买了的书看了一本又一本,最后发现记住的没多少,后来发现最好的文档还是官方文档,所以打算开一个系列去写实例,方便以后查看。

1.1.事务说明

在Spring中,事务有两种实现方式,分别是编程式事务管理和声明式事务管理两种方式。
编程式事务管理: 编程式事务管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。对于编程式事务管理,spring推荐使用TransactionTemplate。
声明式事务管理: 建立在AOP之上的。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。
声明式事务管理不需要入侵代码,通过@Transactional就可以进行事务操作,更快捷而且简单。

1.2.@Transactional

springboot通过@Transactional,实现了事务操作,@Transactional可以作用于接口、接口方法、类以及类方法上。当作用于类上时,该类的所有 public 方法将都具有该类型的事务属性,同时,我们也可以在方法级别使用该标注来覆盖类级别的定义。因此可以在Service层和Controller层使用。
Spring的AOP即声明式事务管理默认是针对unchecked exception回滚。也就是默认对RuntimeException()异常或是其子类进行事务回滚;checked异常,即Exception可try{}捕获的不会回滚,因此对于我们自定义异常,通过rollbackFor进行设定,如果我们需要捕获异常后,同时进行回滚,通过TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();进行手动回滚操作。使用Object savePoint = 设置回滚点,使用
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);回滚到savePoint。

1.3.常用配置

20191123100221\_1.png

1.4. 事务属性

事务隔离级别
隔离级别是指若干个并发的事务之间的隔离程度。TransactionDefinition 接口中定义了五个表示隔离级别的常量:

TransactionDefinition.ISOLATION_DEFAULT:这是默认值,表示使用底层数据库的默认隔离级别。对大部分数据库而言,通常这值就是TransactionDefinition.ISOLATION_READ_COMMITTED。
TransactionDefinition.ISOLATION_READ_UNCOMMITTED:该隔离级别表示一个事务可以读取另一个事务修改但还没有提交的数据。该级别不能防止脏读,不可重复读和幻读,因此很少使用该隔离级别。比如PostgreSQL实际上并没有此级别。
TransactionDefinition.ISOLATION_READ_COMMITTED:该隔离级别表示一个事务只能读取另一个事务已经提交的数据。该级别可以防止脏读,这也是大多数情况下的推荐值。
TransactionDefinition.ISOLATION_REPEATABLE_READ:该隔离级别表示一个事务在整个过程中可以多次重复执行某个查询,并且每次返回的记录都相同。该级别可以防止脏读和不可重复读。
TransactionDefinition.ISOLATION_SERIALIZABLE:所有的事务依次逐个执行,这样事务之间就完全不可能产生干扰,也就是说,该级别可以防止脏读、不可重复读以及幻读。但是这将严重影响程序的性能。通常情况下也不会用到该级别。

事务传播行为
所谓事务的传播行为是指,如果在开始当前事务之前,一个事务上下文已经存在,此时有若干选项可以指定一个事务性方法的执行行为。在TransactionDefinition定义中包括了如下几个表示传播行为的常量:

TransactionDefinition.PROPAGATION_REQUIRED:如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务。这是默认值。
TransactionDefinition.PROPAGATION_REQUIRES_NEW:创建一个新的事务,如果当前存在事务,则把当前事务挂起。
TransactionDefinition.PROPAGATION_SUPPORTS:如果当前存在事务,则加入该事务;如果当前没有事务,则以非事务的方式继续运行。
TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以非事务方式运行,如果当前存在事务,则把当前事务挂起。
TransactionDefinition.PROPAGATION_NEVER:以非事务方式运行,如果当前存在事务,则抛出异常。
TransactionDefinition.PROPAGATION_MANDATORY:如果当前存在事务,则加入该事务;如果当前没有事务,则抛出异常。
TransactionDefinition.PROPAGATION_NESTED:如果当前存在事务,则创建一个事务作为当前事务的嵌套事务来运行;如果当前没有事务,则该取值等价于TransactionDefinition.PROPAGATION_REQUIRED。

事务超时
所谓事务超时,就是指一个事务所允许执行的最长时间,如果超过该时间限制但事务还没有完成,则自动回滚事务。在 TransactionDefinition 中以 int 的值来表示超时时间,其单位是秒。
默认设置为底层事务系统的超时值,如果底层数据库事务系统没有设置超时值,那么就是none,没有超时限制。

事务只读属性
只读事务用于客户代码只读但不修改数据的情形,只读事务用于特定情景下的优化,比如使用Hibernate的时候。
默认为读写事务。

2.建立项目

2.1.开发工具

intellijidea
jdk1.8
spring boot
maven
具体操作详见我以前介绍springboot的文章
https://blog.csdn.net/qiyeliuli/article/details/54767054

2.2.项目配置

包结构

└── src
        └── main
            └── java
                └── hello

maven的pom配置

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>

            <dependency>
                <groupId>com.h2database</groupId>
                <artifactId>h2</artifactId>
                <scope>runtime</scope>
            </dependency>

3.代码

3.1.Create a booking service

首先创建一个jdbc的service

package hello;

    import java.util.List;

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Component;
    import org.springframework.transaction.annotation.Transactional;

    @Component
    public class BookingService {

        private final static Logger logger = LoggerFactory.getLogger(BookingService.class);

        private final JdbcTemplate jdbcTemplate;

        public BookingService(JdbcTemplate jdbcTemplate) {
            this.jdbcTemplate = jdbcTemplate;
        }

        @Transactional
        public void book(String... persons) {
            for (String person : persons) {
                logger.info("Booking " + person + " in a seat...");
                jdbcTemplate.update("insert into BOOKINGS(FIRST_NAME) values (?)", person);
            }
        }

        public List<String> findAllBookings() {
            return jdbcTemplate.query("select FIRST_NAME from BOOKINGS",
                    (rs, rowNum) -> rs.getString("FIRST_NAME"));
        }

    }

The code has an autowired JdbcTemplate, a handy template class that does all the database interactions needed by the code below.
引入JdbcTemplate操作数据库,book方法用来操作人和书的预定关系,用@Transactional管理事物,一旦失败将回滚所有数据库操作。findAllBookings是一个获取数据库数据的列表查询(将String转换为List)。

3.2.Build an application

package com.example.demo;

    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;

    @SpringBootApplication
    public class SpringTransactionApplication {

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

该方法是服务启动的入口,下面介绍一下@SpringBootApplication注解,相当于添加
@Configuration 标签,这个是作为上下文定义
@EnableAutoConfiguration 说明 Spring Boot 是基于 classpath settings, other beans, and various property settings启动的。
你也可以添加@EnableWebMvc作为springMVC应用, 但是but Spring Boot 在类路径上看到 Spring -webmvc时会自动添加它,比如设置DispatcherServlet
@ComponentScan 用来在hello包中查找其他组件、配置和服务,允许它找到控制器

main()方法用来启动一个应用程序,而不需要web.xml配置和一些其他额外配置。另外该实例是spring-jdbc在类路径上处理JdbcTemplate ,h2 将自动创建一个数据库资源, DataSourceTransactionManager 将通过 @Transactional 创建。

3.3.数据库创建

schema.sql

drop table BOOKINGS if exists;
    create table BOOKINGS(ID serial, FIRST_NAME varchar(5) NOT NULL);

3.4.初始化数据

用CommandLineRunner初始化数据,springboot如果想在程序启动时,运行指定代码,可实现 ApplicationRunner or CommandLineRunner 接口,它们的区别可以从spring-boot官方文档查看,本实例采用CommandLineRunner

package hello;

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.stereotype.Component;
    import org.springframework.util.Assert;

    @Component
    public class AppRunner implements CommandLineRunner {

        private final static Logger logger = LoggerFactory.getLogger(AppRunner.class);

        private final BookingService bookingService;

        public AppRunner(BookingService bookingService) {
            this.bookingService = bookingService;
        }

        @Override
        public void run(String... args) throws Exception {
            bookingService.book("Alice", "Bob", "Carol");
            Assert.isTrue(bookingService.findAllBookings().size() == 3,
                    "First booking should work with no problem");
            logger.info("Alice, Bob and Carol have been booked");
            try {
                bookingService.book("Chris", "Samuel");
            } catch (RuntimeException e) {
                logger.info("v--- The following exception is expect because 'Samuel' is too " +
                        "big for the DB ---v");
                logger.error(e.getMessage());
            }

            for (String person : bookingService.findAllBookings()) {
                logger.info("So far, " + person + " is booked.");
            }
            logger.info("You shouldn't see Chris or Samuel. Samuel violated DB constraints, " +
                    "and Chris was rolled back in the same TX");
            Assert.isTrue(bookingService.findAllBookings().size() == 3,
                    "'Samuel' should have triggered a rollback");

            try {
                bookingService.book("Buddy", null);
            } catch (RuntimeException e) {
                logger.info("v--- The following exception is expect because null is not " +
                        "valid for the DB ---v");
                logger.error(e.getMessage());
            }

            for (String person : bookingService.findAllBookings()) {
                logger.info("So far, " + person + " is booked.");
            }
            logger.info("You shouldn't see Buddy or null. null violated DB constraints, and " +
                    "Buddy was rolled back in the same TX");
            Assert.isTrue(bookingService.findAllBookings().size() == 3,
                    "'null' should have triggered a rollback");
        }

    }

3.4.配置logg4j

pom.xml

<!-- 使用log4j2 -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-logging</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-log4j2</artifactId>
            </dependency>

application.properties

logging.level.org.springframework.web=INFO
    logging.level.org.hibernate=ERROR

3.5.h2配置

application.properties

spring.datasource.url=jdbc:h2:file:~/schema.sql
    spring.datasource.username=sa
    spring.datasource.password=
    spring.datasource.driver-class-name=org.h2.Driver

4.运行结果

20191123100221\_2.png

5.程序结构图

20191123100221\_3.png

6.备注

后续会单独介绍事物的各个属性


来源:http://ddrv.cn/a/88268

点赞(0)
版权归原创作者所有,任何形式转载请联系作者; Java 技术驿站 >> spring源码分析--Managing Transactions(事物管理配置)

相关推荐