@DSTransactional 详细解释

DSTransactional详细解释DSTransactional是MyBatis-Plus 动态数据源框架dynamic-datasource-spring-boot-starter提供的专用事务注解位于com.baomidou.dynamic.datasource.annotation.DSTransactional专门用于解决多数据源场景下的事务管理问题。一、为什么需要它Transactional在多数据源下的致命缺陷Spring 原生的Transactional存在一个时间错位问题Transactional的切面先执行方法一进入就立即从连接池获取数据库连接并绑定到当前线程TransactionSynchronizationManagerDS的切面后执行在 SQL 执行前才尝试切换数据源结果就是事务连接已被锁死在默认数据源上DS的切换根本无法影响到已绑定的事务连接数据源切换完全失效。类比来说Transactional像列车长发车前就锁定了轨道DS像站台调度员想在中途切换轨道——但铁轨物理上不会动。二、DSTransactional的核心机制DSTransactional通过调整切面执行顺序解决这个问题先完成DS数据源切换再开启本地事务同时在多数据源写入场景下它的底层执行逻辑是方法执行时框架为每个用到的数据源单独开启独立本地事务所有 SQL 执行正常 → 按顺序依次提交全部事务任意数据源异常 →逆序回滚所有已开启事务遵循**“全部成功才提交任意失败全回滚”**的原则。注意这是一个应用层的尽力而为协议不依赖任何分布式事务中间件如 Seata没有全局事务日志、故障重试、持久化协调机制。三、与Transactional的对比特性维度Transactional(Spring 原生)DSTransactional设计目标单数据源事务管理多数据源切换 事务管理数据源感知无事务开始即锁定连接有先切换数据源再开启事务与DS协作切面顺序冲突DS易失效协作良好切面顺序正确跨库原子性不支持不支持真正的跨库原子事务能否混用—严禁与Transactional混用四、基本用法依赖引入dependencygroupIdcom.baomidou/groupIdartifactIddynamic-datasource-spring-boot-starter/artifactIdversion${version}/version/dependency典型场景一个方法调用多个 Service各 Service 使用不同数据源publicclassAService{DS(a)// AService 使用数据源 aDSTransactional// 在最外层方法添加此注解publicvoiddoSomething(){bService.doSomething();// 使用数据源 bcService.doSomething();// 使用数据源 c}}publicclassBService{DS(b)publicvoiddoSomething(){// 操作数据源 b}}publicclassCService{DS(c)publicvoiddoSomething(){// 操作数据源 c}}只要DSTransactional注解下任一环节异常则全局多数据源事务回滚。即使 BService / CService 上也有DSTransactional也不会互相影响。支持的事务属性与Transactional用法一致DS(order)DSTransactional(propagationPropagation.REQUIRES_NEW,rollbackForException.class)publicvoidbatchSave(ListOrderorders){orderMapper.insertBatch(orders);}五、核心限制与注意事项不是分布式事务DSTransactional仅是应用层的本地事务协调在网络抖动、服务宕机、提交中断等极端场景下可能出现部分库提交成功、部分库回滚失败的数据不一致问题。如需强一致性分布式事务应使用Seata等方案。严禁与Transactional混用两者不能同时出现在同一个方法上否则行为不可预期。严禁在主从读写分离架构中使用主从架构下不应出现跨数据源事务主从延迟问题也无法通过事务注解解决。主从架构强一致读应通过强制路由主库查询实现。适用场景仅适用于同一服务内多个独立业务库并行写入的场景如内部管理平台同时操作订单库、用户库、库存库。验证数据源切换是否生效DS(order)DSTransactionalpublicbooleansaveBatch(ListOrderorders){StringcurrentDsDynamicDataSourceContextHolder.peek();log.info(当前数据源: {},currentDs);returnorderMapper.insertBatch(orders);}六、底层原理简述整个动态数据源切换的核心链路DynamicDataSourceContextHolder基于ThreadLocalDequeString的栈结构管理当前线程的数据源名称支持嵌套切换push/peek/poll/clearDynamicDataSourceAnnotationInterceptorSpring AOPMethodInterceptor在方法执行前解析DS注解并push数据源名称执行后poll清理DynamicRoutingDataSource每次getConnection()时从ContextHolder的栈顶取数据源名称返回对应的DataSource实例DSTransactional的切面确保上述数据源切换在事务开启之前完成从而保证事务绑定的是正确数据源的连接总结DSTransactional是多数据源场景下替代Transactional的正确选择但它解决的是在正确数据源上开启本地事务的问题而非真正的分布式事务问题。参考资料Spring boot dynamic-datasource 读写分离原理、用法与设计边界 - 博客园使用 dynamic-datasource 组件实现 Java 多数据源事务控制 - 阿里云开发者社区用 DSTransactional 替代 Transactional 能解决多数据源事务切换失效的问题吗 - CSDN