Spring 事务从入门到精通：一篇搞定事务失效、传播行为、回滚规则（Spring系列10）

一、前言在日常开发中事务是保证数据一致性的核心手段。尤其是转账这类业务必须保证「A减钱」和「B加钱」两个操作同成功、同失败否则就会出现资金异常。Spring 提供了一套完整的声明式事务解决方案基于 AOP 实现让我们无需手动编写事务开启、提交、回滚代码只需通过注解就能轻松管理业务层事务。本文将从事务基础概念出发通过转账案例完整演示 Spring 事务的环境搭建、问题复现、解决方案再深入讲解事务属性、传播行为等核心知识点帮你彻底搞懂 Spring 事务管理。二、Spring事务基础概念2.1 事务的作用数据库层事务保障一系列数据库操作同成功同失败。Spring事务作用在业务层保障一系列数据库操作同成功同失败。举个转账的例子转账业务需要两次数据库操作A账户减钱、B账户加钱。如果事务放在数据库层减钱和加钱是两个独立事务无法保证同时成功/失败。必须将事务提升到业务层让两个操作在同一个事务中执行。2.2 Spring事务核心接口Spring 提供了统一的事务管理器接口PlatformTransactionManager定义了事务的核心操作public interface PlatformTransactionManager{ void commit(TransactionStatus status) throws TransactionException; void rollback(TransactionStatus status) throws TransactionException; }commit()提交事务rollback()回滚事务Spring 为其提供了具体实现DataSourceTransactionManager内部基于 JDBC 事务实现我们只需要给它注入DataSource就能在业务层管理事务这也是 Spring 整合 MyBatis 时的默认事务管理器。Transactional 只是声明 → 不干活transactionManager 才是真正干活的 → 处理事务Spring 的事务工作流程1.看到 Transactional2.去找容器中的 事务管理器 Bean3.用事务管理器开启 / 提交 / 回滚事务如果没有事务管理器 Bean → Transactional 直接失效三、转账案例从零搭建事务环境3.1 需求分析需求实现任意两个账户间的转账操作需求拆解A账户减钱outMoneyB账户加钱inMoney保证两个操作同成功同失败3.2 环境搭建步骤步骤1准备数据库表create database spring_db character set utf8; use spring_db; create table tbl_account( id int primary key auto_increment, name varchar(35), money double ); insert into tbl_account values(1,Tom,1000); insert into tbl_account values(2,Jerry,1000);步骤2项目pom.xml依赖dependencies dependency groupIdorg.springframework/groupId artifactIdspring-context/artifactId version5.2.10.RELEASE/version /dependency dependency groupIdcom.alibaba/groupId artifactIddruid/artifactId version1.1.16/version /dependency dependency groupIdorg.mybatis/groupId artifactIdmybatis/artifactId version3.5.6/version /dependency dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId version5.1.47/version /dependency dependency groupIdorg.springframework/groupId artifactIdspring-jdbc/artifactId version5.2.10.RELEASE/version /dependency dependency groupIdorg.mybatis/groupId artifactIdmybatis-spring/artifactId version1.3.0/version /dependency dependency groupIdjunit/groupId artifactIdjunit/artifactId version4.12/version scopetest/scope /dependency dependency groupIdorg.springframework/groupId artifactIdspring-test/artifactId version5.2.10.RELEASE/version /dependency /dependencies步骤3创建实体类Accountpublic class Account implements Serializable { private Integer id; private String name; private Double money; // setter、getter、toString 略 }步骤4创建Dao接口public interface AccountDao { Update(update tbl_account set money money #{money} where name #{name}) void inMoney(Param(name) String name, Param(money) Double money);Update(update tbl_account set money money - #{money} where name #{name}) void outMoney(Param(name) String name, Param(money) Double money); }补充MyBatis中Param注解的使用规则1. 方法参数是多个基本类型/String时必须加ParamMyBatis无法自动识别参数名需通过注解明确绑定SQL占位符。2. 方法参数是单个对象时无需加ParamMyBatis会自动通过对象属性名匹配SQL占位符。3. 其他场景集合/数组、动态SQL中也需要Param避免歧义。步骤5创建Service接口和实现类public interface AccountService { /** * 转账操作 * param out 传出方 * param in 转入方 * param money 金额 */ public void transfer(String out,String in ,Double money) ; }Service public class AccountServiceImpl implements AccountService { Autowired private AccountDao accountDao;public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); accountDao.inMoney(in,money); } }步骤6添加jdbc.properties配置文件jdbc.drivercom.mysql.jdbc.Driver jdbc.urljdbc:mysql://localhost:3306/spring_db?useSSLfalse jdbc.usernameroot jdbc.passwordroot步骤7创建JdbcConfig配置类public class JdbcConfig { Value(${jdbc.driver}) private String driver; Value(${jdbc.url}) private String url; Value(${jdbc.username}) private String userName; Value(${jdbc.password}) private String password;Bean public DataSource dataSource(){ DruidDataSource ds new DruidDataSource(); ds.setDriverClassName(driver); ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); return ds; } }步骤8创建MybatisConfig配置类public class MybatisConfig { Bean public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){ SqlSessionFactoryBean ssfb new SqlSessionFactoryBean(); ssfb.setTypeAliasesPackage(com.itheima.domain); ssfb.setDataSource(dataSource); return ssfb; }Bean public MapperScannerConfigurer mapperScannerConfigurer(){ MapperScannerConfigurer msc new MapperScannerConfigurer(); msc.setBasePackage(com.itheima.dao); return msc; } }步骤9创建SpringConfig配置类Configuration ComponentScan(com.itheima) PropertySource(classpath:jdbc.properties) Import({JdbcConfig.class,MybatisConfig.class}) public class SpringConfig { }步骤10编写测试类RunWith(SpringJUnit4ClassRunner.class) ContextConfiguration(classes SpringConfig.class) public class AccountServiceTest { Autowired private AccountService accountService;Test public void testTransfer() throws IOException { accountService.transfer(Tom,Jerry,100D); } }3.3 问题复现无事务的转账异常正常运行测试Tom账户减100Jerry账户加100数据正常。但如果在转账过程中出现异常比如Service public class AccountServiceImpl implements AccountService { Autowired private AccountDao accountDao;public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); // 模拟异常除零错误 int i 1/0; accountDao.inMoney(in,money); } }运行后会发现Tom账户已经减了100但Jerry账户没有加钱100块凭空消失了原因分析无事务时outMoney和inMoney是两个独立的数据库事务。outMoney执行成功后事务自动提交后续异常导致inMoney未执行最终数据不一致。四、Spring声明式事务解决转账异常4.1 事务配置步骤步骤1给业务方法添加Transactional注解public interface AccountService { public void transfer(String out,String in ,Double money) ; }Service public class AccountServiceImpl implements AccountService { Autowired private AccountDao accountDao;Transactional public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); int i 1/0; accountDao.inMoney(in,money); } }注解说明-Transactional可以写在接口、接口方法、实现类、实现类方法上。- 建议写在实现类/实现类方法上更直观可控。Transactional可以写在接口类上、接口方法上、实现类上和实现类方法上写在接口类上该接口的所有实现类的所有方法都会有事务写在接口方法上该接口的所有实现类的该方法都会有事务写在实现类上该类中的所有方法都会有事务写在实现类方法上该方法上有事务建议写在实现类或实现类的方法上步骤2在JdbcConfig中配置事务管理器public class JdbcConfig { // 省略DataSource配置...// 配置事务管理器MyBatis使用JDBC事务 Bean public PlatformTransactionManager transactionManager(DataSource dataSource){ DataSourceTransactionManager transactionManager new DataSourceTransactionManager(); transactionManager.setDataSource(dataSource); return transactionManager; } }注意-Transactional事务管理器要根据使用技术进行选择Mybatis框架使用的是JDBC事务可以直接使用DataSourceTransactionManager步骤3在SpringConfig中开启注解式事务驱动Configuration ComponentScan(com.itheima) PropertySource(classpath:jdbc.properties) Import({JdbcConfig.class,MybatisConfig.class}) // 开启注解式事务驱动 EnableTransactionManagement public class SpringConfig { }4.2 核心注解详解注解类型位置作用EnableTransactionManagement配置类注解配置类上方在Spring环境中开启注解式事务支持Transactional方法/类注解业务层接口/实现类方法上方为当前业务方法添加事务类上则类中所有方法生效4.3 事务生效原理事务管理员事务协调员未开启事务前outMoney和inMoney各自开启独立事务T1、T2。transfer方法无事务中间出现异常时T1已提交、T2未执行数据异常。开启事务后transfer方法加Transactional成为事务管理员开启全局事务T。outMoney和inMoney作为事务协调员将各自的事务T1、T2加入到全局事务T中。业务层出现异常时整个事务T回滚T1、T2全部回滚保证数据一致性。关键注意事务管理器和协调员必须使用同一个DataSource否则无法统一事务这是Bean单例默认保证的。补充两个核心疑问精准解答问题一outMoney(T1)、inMoney(T2) 是谁生成的事务答案它们是【数据层MyBatis/JDBC自动生成的事务】不是业务方法自己生成的。详细拆解1. 没有 Spring 事务时调用accountDao.outMoney()→ 执行一条 SQLJDBC/MyBatis 自动开启事务 T1 → 执行完自动提交再调用accountDao.inMoney()→ 自动开启事务 T2 → 自动提交结论T1、T2 都是数据层自动产生的独立事务2. 有 Spring 事务时业务方法transfer()加TransactionalSpring 提前开启一个大事务 T数据层 T1、T2 不再独立提交而是加入到大事务 T最终由 Spring 统一提交/回滚一句话总结outMoney / inMoney 的事务是数据层JDBC/MyBatis默认自动提交事务不是业务层方法创建的。问题二LogDao 接口为什么不用加 Mapper 注解答案完全不用加因为全局扫描已自动识别所有 Dao 为 Mapper。关键配置Bean public MapperScannerConfigurer mapperScannerConfigurer(){ MapperScannerConfigurer msc new MapperScannerConfigurer(); // 扫描该包下所有接口自动注册为 MyBatis Mapper msc.setBasePackage(com.itheima.dao); return msc; }两种写法等价写法1全局扫描企业推荐// 无需 Mapper正常生效 public interface LogDao { ... }写法2显式声明Mapper // 可加可不加仅显式标记 public interface LogDao { ... }最终结论只要配置了 MapperScannerConfigurer 扫描包所有 Dao 接口都不需要加 Mapper五、Spring事务属性详解Transactional注解支持多个属性配置用于精细化控制事务行为。5.1 核心属性表属性作用示例readOnly设置是否为只读事务readOnlytrue只读事务查询用false读写事务增删改用timeout设置事务超时时间秒timeout -1永不超时rollbackFor设置事务回滚异常Class类型rollbackFor {IOException.class}rollbackForClassName设置事务回滚异常String全类名同rollbackFor参数为字符串noRollbackFor设置事务不回滚异常Class类型noRollbackFor {NullPointerException.class}noRollbackForClassName设置事务不回滚异常String全类名同noRollbackFor参数为字符串isolation设置事务隔离级别isolation Isolation.DEFAULTpropagation设置事务传播行为propagation Propagation.REQUIRED默认5.2 关键属性深度解析1. rollbackFor自定义回滚异常Spring事务默认只对Error和RuntimeException及其子类回滚受检异常如IOException不会回滚。示例Service public class AccountServiceImpl implements AccountService { Autowired private AccountDao accountDao;Transactional public void transfer(String out,String in ,Double money) throws IOException{ accountDao.outMoney(out,money); // int i 1/0; // RuntimeException事务会回滚 if(true){ throw new IOException(); // 受检异常事务不会回滚 } accountDao.inMoney(in,money); } }解决方法用rollbackFor指定回滚异常Transactional(rollbackFor {IOException.class}) public void transfer(String out,String in ,Double money) throws IOException{ // 业务代码 }2. isolation事务隔离级别隔离级别说明DEFAULT默认级别使用数据库的隔离级别READ_UNCOMMITTED读未提交存在脏读、不可重复读、幻读READ_COMMITTED读已提交解决脏读存在不可重复读、幻读Oracle默认REPEATABLE_READ重复读解决脏读、不可重复读存在幻读MySQL默认SERIALIZABLE串行化解决所有问题性能差六、事务传播行为解决转账日志问题6.1 新需求转账后记录日志在转账案例基础上新增需求无论转账是否成功都要记录转账日志到数据库。需求实现步骤1. 创建日志表tbl_logcreate table tbl_log( id int primary key auto_increment, info varchar(255), createDate datetime )2. 创建LogDao、LogServicepublic interface LogDao { Insert(insert into tbl_log (info,createDate) values(#{info},now())) void log(String info); }public interface LogService { void log(String out, String in, Double money); }Service public class LogServiceImpl implements LogService { Autowired private LogDao logDao;Transactional public void log(String out,String in,Double money ) { logDao.log(转账操作由out到in,金额money); } }3. 在转账业务中添加日志记录Service public class AccountServiceImpl implements AccountService { Autowired private AccountDao accountDao; Autowired private LogService logService;Transactional public void transfer(String out,String in ,Double money) { try{ accountDao.outMoney(out,money); int i 1/0; accountDao.inMoney(in,money); }finally { logService.log(out,in,money); } } }问题复现转账出现异常时转账操作回滚了但日志也没有记录原因log()方法加了Transactional默认传播行为是REQUIRED会加入transfer的全局事务。当transfer事务回滚时log的事务也会一起回滚导致日志丢失。6.2 事务传播行为核心概念事务传播行为事务协调员对事务管理员所携带事务的处理态度即「是否加入管理员的事务还是开启新事务」。解决方案修改日志方法的传播行为将log()方法的传播行为设置为REQUIRES_NEW让它每次都开启新事务不加入外部事务Service public class LogServiceImpl implements LogService { Autowired private LogDao logDao;// propagation设置事务属性传播行为为当前操作需要新事务 Transactional(propagation Propagation.REQUIRES_NEW) public void log(String out,String in,Double money ) { logDao.log(转账操作由out到in,金额money); } }运行后无论转账是否成功日志都会正常记录完美满足需求。6.3 事务传播行为可选值七、事务生效三要素缺一不可很多同学会遇到「加了Transactional但事务不生效」的问题核心是没满足三个必要条件配置事务管理器Bean向Spring容器注册PlatformTransactionManager事务的真正执行者。添加Transactional注解给方法/类打标签声明需要事务。开启EnableTransactionManagement开启注解式事务驱动相当于接通电路。通俗类比-transactionManager 事务发动机-Transactional 点火钥匙-EnableTransactionManagement 电路接通三者缺一事务都无法启动八、总结本文从转账案例出发完整覆盖了Spring AOP事务管理的核心知识点基础概念事务的作用、Spring事务管理器的核心原理。实战案例从零搭建转账环境复现无事务异常通过声明式事务解决问题。事务属性readOnly、timeout、rollbackFor、isolation等属性的使用场景。传播行为通过日志案例理解REQUIRED和REQUIRES_NEW的核心区别解决实际开发中的常见问题。生效条件事务生效的三要素帮你排查事务不生效的问题。核心疑问数据层事务来源、Mapper注解省略原理面试高频必懂。Spring事务是后端开发的核心技能掌握这些知识点就能应对绝大多数业务场景的事务管理需求。九、常见问题排查Q1加了Transactional但事务不生效A检查三个点是否配置了PlatformTransactionManagerBean。是否加了EnableTransactionManagement。方法是否是publicTransactional对private方法不生效。是否是同类内部调用AOP代理不生效需通过ApplicationContext获取代理对象。Q2为什么受检异常不会回滚ASpring默认只对RuntimeException和Error回滚受检异常需通过rollbackFor手动指定。Q3日志方法为什么要设置REQUIRES_NEWA默认REQUIRED会加入外部事务外部事务回滚时日志也会回滚REQUIRES_NEW开启独立事务不受外部事务影响保证日志一定记录。