ARTICLE DETAIL

资讯详情

深耕编程入门与网站建设的一线实战洞察。

Java:事务管理全景梳理/解决业务系统数据一致性问题

Java:事务管理全景梳理/解决业务系统数据一致性问题 事务核心目标保证一组数据库操作要么全部成功要么全部失败回滚。Java事务分为JDBC原生事务、JTA分布式事务、Spring声明式/编程式事务包含传播行为、隔离级别、回滚规则、失效场景全部以表格结构化整理。本质数据库原生有事务能力但裸用 JDBC 写事务代码极其繁琐Java 事务管理尤其 Spring 事务是对数据库事务的高层封装解决业务系统数据一致性问题。Java事务管理是对数据库事务能力的高层封装核心是保障一组数据库操作原子执行要么全部成功提交要么失败整体回滚维护数据ACID特性。原生JDBC需手动编写提交、回滚样板代码开发繁琐易出错。Spring事务通过AOP与Transactional注解简化开发提供传播行为、隔离级别、异常回滚、超时等能力自动管理数据库连接资源。区分本地事务与分布式事务解决方法嵌套调用、并发业务的数据一致性避免出现扣钱不加账这类脏数据是业务系统保障数据可靠的基础组件。一、事务基础概念ACID四大特性特性全称说明AAtomicity 原子性事务内操作不可分割全部成功或全部回滚CConsistency 一致性事务前后业务数据状态合法由原子隔离持久共同保障IIsolation 隔离性多个事务并发互相之间数据不可见防止脏读、不可重复读、幻读DDurability 持久性事务提交后修改永久落地数据库宕机不丢失并发事务3大问题问题描述脏读A事务读到B事务未提交的数据如果B回滚读到脏无效数据不可重复读同一事务内同一行数据两次查询结果不一样被其他事务提交修改幻读同一事务同样条件查询前后返回行数变化其他事务插入/删除数据数据库隔离级别MySQL InnoDB隔离级别脏读不可重复读幻读MySQL默认READ UNCOMMITTED 读未提交✅发生✅发生✅发生极少使用READ COMMITTED 读已提交(RC)❌避免✅发生✅发生Oracle默认REPEATABLE READ 可重复读(RR)❌避免❌避免✅InnoDB MVCC规避✅MySQL InnoDB默认SERIALIZABLE 串行化❌避免❌避免❌避免性能极低几乎不用InnoDB 在 RR级别通过MVCC解决幻读快照读当前读select ... for update会通过临键锁解决幻读。二、Java 三套事务体系对比事务体系适用场景API入口是否依赖容器特点JDBC原生事务单库本地事务Connection否纯JDBC底层原始手动编码关闭自动提交setAutoCommit(false)JTAJava Transaction API分布式多数据源事务UserTransaction需要容器(Tomcat/JBoss)或Atomikos等第三方XA二阶段提交性能差开发繁琐Spring事务绝大多数业务单库为主也可集成JTATransactional/TransactionTemplateSpring环境封装JDBC/JTA分为编程式、声明式开发主流2.1 JDBC原生事务核心代码要点Connection关键方法方法作用connection.setAutoCommit(false)关闭自动提交开启事务connection.commit()手动提交事务connection.rollback()回滚事务connection.setSavepoint()设置保存点支持局部回滚缺陷每个业务都要写try‑catch‑commit‑rollback样板代码多数据源无法支持没有传播行为。2.2 JTA 分布式事务JTAJava规范定义事务接口底层实现XA协议2PC角色事务管理器TM、资源管理器RM各个数据库对象作用javax.transaction.UserTransaction用户操作事务begin/commit/rollbackjavax.transaction.TransactionManager底层事务管理器XAResource每个数据库资源参与分布式事务接口缺点性能损耗大部分数据库驱动对XA支持一般现在业务更多用Seata替代JTA。三、Spring事务两大模式编程式 vs 声明式模式实现方式核心API优点缺点编程式事务硬编码写在业务代码TransactionTemplate/PlatformTransactionManager细粒度控制灵活不受AOP限制侵入业务代码重复样板代码声明式事务AOP代理注解TransactionalTransactional注解无侵入业务简洁开发主流依赖SpringAOP代理存在大量失效坑Spring事务底层依然是封装JDBC Connection或者JTA。Spring核心事务管理器接口PlatformTransactionManager顶层接口实现类场景DataSourceTransactionManagerJDBC/MyBatis单数据源本地事务最常用JpaTransactionManagerJPA/HibernateJtaTransactionManagerJTA分布式XA事务接口方法// 获取事务状态 TransactionStatus getTransaction(TransactionDefinition definition); // 提交 void commit(TransactionStatus status); // 回滚 void rollback(TransactionStatus status);TransactionDefinition事务定义信息包含传播行为、隔离级别、超时时间、是否只读。四、Spring 7种事务传播行为重点传播行为一个已经存在事务的方法调用另一个带事务的方法事务如何共用/新建。传播行为常量名称说明REQUIREDPROPAGATION_REQUIRED✅默认。有事务就加入当前事务没有就新建事务。SUPPORTSPROPAGATION_SUPPORTS有事务就加入没有就非事务执行。MANDATORYPROPAGATION_MANDATORY必须已有事务没有则抛异常。REQUIRES_NEWPROPAGATION_REQUIRES_NEW总是新建独立事务挂起外层事务内层回滚不影响外层。NOT_SUPPORTEDPROPAGATION_NOT_SUPPORTED挂起当前事务以非事务运行。NEVERPROPAGATION_NEVER禁止存在事务已有事务直接抛异常。NESTEDPROPAGATION_NESTED嵌套事务底层数据库保存点外层回滚内层跟着回滚内层回滚不影响外层。仅DataSourceTransactionManager支持。面试高频区分REQUIRES_NEWvsNESTEDREQUIRES_NEW完全独立两个事务NESTED同一个事务依靠savepoint保存点实现嵌套。五、Transactional注解完整属性表属性作用取值说明propagation传播行为Propagation.REQUIRED / REQUIRES_NEW等7种isolation隔离级别Isolation.READ_COMMITTED、REPEATABLE_READ…timeout事务超时秒数默认‑1不超时超时自动回滚readOnly是否只读true优化禁止写操作不是强制校验给数据库提示rollbackFor指定异常触发回滚Class数组rollbackFor Exception.classrollbackForClassName异常全限定名字符串形式用于注解配置无法直接引入类noRollbackFor指定异常不回滚发生该异常事务依然提交noRollbackForClassName字符串版本noRollbackFor⚠️ 默认规则Spring声明式事务仅对RuntimeException、Error才回滚普通受检Exception不会回滚捕获异常不抛出也不会回滚。六、Spring事务常见失效场景高频面试失效场景现象原因1.非public方法上加Transactional事务不生效SpringAOP只能拦截publicprivate/protected/default无法生成代理2.同类内部方法调用this.xxx()调用本类注解方法事务失效this是原始对象不走AOP代理对象AOP只有外部调用代理对象才生效3.异常被try‑catch捕获没有抛出异常吞掉事务不会回滚SpringAOP通过捕获方法抛出异常触发回滚catch住不抛出感知不到异常4.数据库引擎不支持事务MyISAM完全没有事务能力MyISAM不支持事务要InnoDB5.传播行为配置错误内层异常外层不回滚或者不开启事务例如SUPPORTS/NOT_SUPPORTED等6.多数据源使用普通DataSourceTransactionManager只能单库生效跨库不具备原子性本地事务只绑定一个Connection跨库需要分布式事务JTA/Seata7.多线程环境调用事务方法子线程无法继承主线程事务Spring事务绑定ThreadLocal不同线程ThreadLocal隔离子线程会新建事务8.手动设置readOnlytrue却做写操作部分数据库抛异常部分数据库仅提示readOnly只是优化hint不是强制拦截写SQL9.自己new对象不用Spring容器获取Bean注解完全无效没有被SpringAOP代理是原生对象同类调用解决方案1.注入自身代理2.拆分到不同Service3.通过AopContext获取代理对象。七、Spring事务底层原理1、Spring启动扫描Transactional生成AOP代理对象JDK动态代理 / CGLIB2、调用代理对象方法进入TransactionInterceptor拦截器3、TransactionDefinition解析注解配置交给PlatformTransactionManager4、从ThreadLocal获取/创建数据库Connection关闭autoCommit5、执行业务逻辑方法抛出异常执行rollback正常结束执行commit6、Connection归还连接池。关键点Connection绑定到当前线程ThreadLocal同一个线程内多个事务方法拿到同一个数据库连接。关键点说明Connection绑定TransactionSynchronizationManagerThreadLocal保存Connection资源代理方式实现接口用JDK动态代理类无接口使用CGLIB代理回滚标记TransactionStatus.setRollbackOnly()标记回滚即使不抛异常也回滚手动触发回滚编程式TransactionStatus status TransactionAspectSupport.currentTransactionStatus(); status.setRollbackOnly();八、本地事务 vs 分布式事务对比维度Spring本地事务DataSourceTransactionManager分布式事务JTA/Seata数据库数量单数据源一个数据库连接多个数据库、多个微服务底层原理JDBC Connection事务XA‑2PC / TCC / AT / SAGA性能几乎无额外损耗开销大AT模式存在undo_log日志实现难度简单Transactional直接使用复杂需要额外组件数据一致性强一致性AT模式最终一致性XA强一致企业现状JTA XA性能差新项目一般不用微服务分布式事务主流使用Seata AT模式。九、最佳实践总结表格实践建议注解位置Transactional写在public方法推荐写在Service层不要写Controller回滚配置业务上建议rollbackFor Exception.class避免受检异常不回滚坑避免同类内部调用业务拆分不同Service不要this调用大事务尽量缩小事务范围避免把RPC、大查询放入事务防止长事务锁表、数据库连接耗尽多线程不要在子线程执行数据库事务子线程无法继承父线程事务只读查询查询方法设置readOnlytrue给底层驱动优化提示异常处理如果需要catch部分异常catch后手动设置回滚标记或者抛出异常常见坑速记Transactional不是万能依赖AOP代理public抛出异常Spring默认只回滚RuntimeException/ErrorThreadLocal绑定Connection跨线程事务失效单库用DataSourceTransactionManager跨库微服务不要指望Transactional解决要用分布式事务方案。
返回列表