SpringBoot2 综合案例（09）：基于转账案例，演示事务管理

Spring Boot 2 基础案例篇

包含：入门、日志管理、定时器、事务、AOP、数据库、缓存、NoSQL、监控、打包。

Spring Boot 2 高级案例篇

包含：整合常用中间件：分库分表、权限管理、Redis 集群、Dubbo、消息队列、定时器、搜索引擎、文件管理、邮件等

事务管理简介 事务基本概念

一组业务操作 ABCD，要么全部成功，要么全部不成功。

特性：ACID

原子性：整体一致性：完成隔离性：并发持久性：结果

隔离问题

脏读：一个事务读到另一个事务没有提交的数据不可重复读：一个事务读到另一个事务已提交的数据（update）虚读(幻读)：一个事务读到另一个事务已提交的数据（insert）

隔离级别

read uncommitted：读未提交。read committed：读已提交。解决脏读。repeatable read：可重复读。解决：脏读、不可重复读。serializable ：串行化。都解决，单事务。

Spring 管理事务 顶级接口

1）PlatformTransactionManager

平台事务管理器，spring 要管理事务，必须使用事务管理器进行事务配置时，必须配置事务管理器。

2）TransactionDefinition

事务详情（事务定义、事务属性），spring 用于确定事务具体详情， 例如：隔离级别、是否只读、超时时间 等 进行事务配置时，必须配置详情。spring 将配置项封装到该对象实例。

3）TransactionStatus

事务状态，spring 用于记录当前事务运行状态。例如：是否有保存点，事务是否完成。 spring 底层根据状态进行相应操作。

事务状态

事务定义

PROPAGATION_REQUIRED , required , 必须  【默认值】    支持当前事务，A 如果有事务，B 将使用该事务。    如果 A 没有事务，B 将创建一个新的事务。PROPAGATION_SUPPORTS ，supports ，支持    支持当前事务，A 如果有事务，B 将使用该事务。    如果 A 没有事务，B 将以非事务执行。PROPAGATION_MANDATORY，mandatory ，强制    支持当前事务，A 如果有事务，B 将使用该事务。    如果 A 没有事务，B 将抛异常。PROPAGATION_REQUIRES_NEW ， requires_new ，必须新的    如果 A 有事务，将 A 的事务挂起，B 创建一个新的事务    如果 A 没有事务，B 创建一个新的事务PROPAGATION_NOT_SUPPORTED ，not_supported ,不支持    如果 A 有事务，将 A 的事务挂起，B 将以非事务执行    如果 A 没有事务，B 将以非事务执行PROPAGATION_NEVER ，never，从不    如果 A 有事务，B 将抛异常    如果 A 没有事务，B 将以非事务执行PROPAGATION_NESTED ，nested ，嵌套    A 和 B 底层采用保存点机制，形成嵌套事务。掌握：PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED

SpringBoot2.0 管理事务 新建转账表

CREATE TABLE account(  id INT PRIMARY KEY AUTO_INCREMENT,  username VARCHAR(50),  money INT)ENGINE=InnoDB DEFAULT CHARSET=utf8;INSERT INTO account(username,money) VALUES('jack','10000');INSERT INTO account(username,money) VALUES('rose','10000');SELECT * FROM account;

基于事务手动管理器

该配置用于测试事务的手动管理。

/** * 事物管理器 */@Bean(name = "transactionManager")public PlatformTransactionManager transactionManager (DruidDataSource dataSource){    LOGGER.info("【transactionManager 初始化...】");    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();    transactionManager.setDataSource(dataSource);    return transactionManager;}/** * 创建事物手动管理模板 */@Bean(name = "transactionTemplate")public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager)    LOGGER.info("【transactionTemplate 初始化...】");    TransactionTemplate transactionTemplate = new TransactionTemplate() ;    transactionTemplate.setTransactionManager(transactionManager);    return transactionTemplate;}

封装转账接口

• 接口方法

public interface AccountService {    /**     * 汇款     */    void out (String outer , Integer money);    /**     * 收款     */    void in (String inner , Integer money);}

• 接口实现

@Servicepublic class AccountServiceImpl implements AccountService {    @Resource    private JdbcTemplate jdbcTemplate ;    public void out(String outer, Integer money) {        String sql = "update account set money = money - ? where username = ?";        jdbcTemplate.update(sql, money,outer);    }    public void in(String inner, Integer money) {        String sql = "update account set money = money + ? where username = ?";        jdbcTemplate.update(sql, money,inner);    }}

封装三个测试接口

• 测试接口

public interface TradeService {    /**     * 转账交易：没有事务管理     */    void trade1(String outer ,String inner ,Integer money);    /**     * 转账交易：手动管理事务     */    void trade2(String outer ,String inner ,Integer money);    /**     * 转账交易：注解管理事务     */    void trade3(String outer ,String inner ,Integer money);}

• 接口实现

@Servicepublic class TradeServiceImpl implements TradeService {    @Resource    private AccountService accountService ;    @Resource    private TransactionTemplate transactionTemplate ;    @Override    public void trade1(String outer, String inner, Integer money) {        accountService.out(outer, money);        // 抛出异常        int i = 1/0;        accountService.in(inner, money);    }    @Override    public void trade2(String outer, String inner, Integer money) {        transactionTemplate.execute(new TransactionCallbackWithoutResult() {            public void doInTransactionWithoutResult(TransactionStatus arg0) {                accountService.out(outer, money);                // 抛出异常                int i = 1/0;                accountService.in(inner, money);            }        });    }    @Transactional(value="transactionManager",propagation= Propagation.REQUIRED)    @Override    public void trade3(String outer, String inner, Integer money) {        accountService.out(outer, money);        // 抛出异常        int i = 1/0;        accountService.in(inner, money);    }}

编写测试类

@RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = TransactionApplication.class)public class TradeTest {    @Resource    private TradeService tradeService ;    /**     * 没有事务管理     * jack 减少了 1000 块钱，但是 rose 得到 1000 块钱     * 1    jack    9000     * 2    rose    10000     */    @Test    public void testTrade1 (){        tradeService.trade1("jack", "rose", 1000);    }    /**     * 手动管理事务     * 1    jack    10000     * 2    rose    10000     */    @Test    public void testTrade2 (){        tradeService.trade2("jack", "rose", 1000);    }    /**     * 注解管理事务     * 1    jack    10000     * 2    rose    10000     */    @Test    public void testTrade3 (){        tradeService.trade3("jack", "rose", 1000);    }}

源代码地址

GitHub·地址https://github.com/cicadasmile/spring-boot-baseGitEE·地址https://gitee.com/cicadasmile/spring-boot-base

本文首发于 GitChat，未经授权不得转载，转载需与 GitChat 联系。

阅读全文: http://gitbook.cn/gitchat/activity/5d765fa15875c8739a0eafd3

您还可以下载 CSDN 旗下精品原创内容社区 GitChat App ，阅读更多 GitChat 专享技术内容哦。