DynamicDataSource怎样解决多数据源的事务问题
多数据源的真面目DynamicRoutingDataSource
DynamicRoutingDataSource是什么?
该类实现了DataSource接口并在内部维护了一个map，其中存放了多个真实的DataSource,而key则是不同数据源的名称，本质上就是基于静态代理模式代理了多个真实的数据源对象。
在用多数据源时可以使用@DS来切换不同的数据源，这依赖于DynamicRoutingDataSource。
要完成这个功能需要
@DS+DSProcessor+ThreadLocal+AopMethodInterceptor+DynamicRoutingDataSource#getConnection
相互配合才能成功切换数据源。
多数据源下的事务会有什么问题？
在没有多数据源时，系统中一般只会存在一个Datasource，所谓的HikariDataSource,DruidDatasource，CommonsDbcp2PoolDataSource都是DataSource的实现,但是在系统中总是唯一存在的。因为SqlSessionTemplateFactory中只能存在一个DataSource,SqlSessionTemplate又是通过SqlSessionTemplateFactory生成的,并且SqlSessionTemplate在容器中又只能存在一个，所以事务时不会出现混乱的。而DynamicRoutingDataSource同样也是系统中的唯一的Datasource,只不过它内部代理了多个DataSource。
再来说说spring的事务管理器TransactionSynchronizationManager，内部使用ThreadLocal保存当前事务信息。当程序执行到@Transactional的AOP拦截器时，会在ThreadLocal中保存当前的事务信息，其中就包含了与数据库的Connection对象。在程序执行sql时，spring的SqlSessionTemplate#getSession方法会从事务管理器中获取到与当前线程绑定的connection对象。
综上所述，当使用@DS切换数据源时，没有事务的情况下还好，会使用DynamicRoutingDataSource获取一个新的connection并使用，但是如果是在事务的情况下，会使用事务管理器中获取与当前线程绑定的Connection，而这个connection则是事务被创建时获取的connection，就造成了虽然指定了数据源，但是还是原本的那个connection。导致切换数据源失败。
@Ds与@DsTransactional
通过观察DynamicDataSourceAutoConfiguration自动配置类可以发现，DynamicDataSource默认自动配置了@Ds注解及@DsTransactional注解的切面。
分别是dynamicDatasourceAnnotationAdvisor及dynamicTransactionAdvisor。
@Ds的原理
其切面方法拦截器会将指定的ds名称存入DynamicDataSourceContextHolder中的ThreadLocal<Deque<String>>中，因为指定了ThreadLocalMap的泛型为Deque，而Deque的作用更准确的说是栈的作用，所以支持方法嵌套调用时使用不同的ds名称。
@DsTransactional的原理
通过源码可以发现在没有使用seta分布式事务控制的情况下，多数据源的事务是通过dynamicDatasourceAnnotationAdvisor管理的。
dynamicDatasourceAnnotationAdvisor的核心切面拦截器就是DynamicLocalTransactionInterceptor
DynamicLocalTransactionInterceptor多数据源本地事务拦截器
内部实现原理非常简单，其实就是借助于ThreadLocal。
看到这里，你可能已经猜到了，面纱下面的真面目就是这个ConnectionFactory类了。
我们再来看看他张了一幅什么面貌。
我们已经知道了notify方法是@DsTransactional切面环绕通知结束时会被调用的，本着追溯本源的好奇心，你可能开始好奇了，putConnection又是什么时候被调用的呢？
我们继续跟进就来到了AbstractRoutingDataSource。
好!又回到了DynamicRoutingDataSource中， AbstractRoutingDataSource就是DynamicRoutingDataSource父类。
在本地事务结束时，TransactionContext会清空本地事物的状态标识，然后分别结束每一个connection的事务状态。
然后清除ConnectionFactory中保存的与本次本地事物有关的所有connection对象的引用。
至此本地事物的创建和结束就完成了闭环。
总结一下
多数据源事务的控制中，参与的核心职责类有哪些
DynamicRoutingDataSource: DataSource接口的实现，也是一个DataSource，本质是多个DataSource的静态代理类。自定义了getConnection方法的实现逻辑，使其与多数据源的事务管理紧密配合。TransactionContext：使用ThreadLocal实现。本地事物上下文。负责管理本地事物的状态。ConnectionFactory: 使用ThreadLocal实现。connection连接的静态代理类,也是一个委派者设计模式。负责管理当前本地事务中的所有Connection。ConnectionProxy: 封装了真实的Connection。 目的是将ds数据源名称和connection对应起来，这样可以通过ds数据源名称拿到对应的connection。@Ds:用于指定接下来要使用的数据源名称。@DsTransactional: 多数据源事务的开启注解，用法同@Transactional相同。但是不能指定事务的一些属性，因为其实现的原理，也不需要任何其他的事务的配置。当发生任何Exception时都会执行回滚
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
所谓的配置文件问题，是指我们在开发时，经常需要读取和修改一些配置信息，比如数据库、消息队列、Nginx、Web服务器等的配置，为了便于修改这些信息，我们可以采用Properties配置类，本文给大家讲一下Properties配置类是怎么回事，以及怎么使用2023-06-06
类和对象是两种以计算机为载体的计算机语言的合称。对象是对客观事物的抽象，类是对对象的抽象。类是一种抽象的数据类型；变量就是可以变化的量，存储在内存中—个可以拥有在某个范围内的可变存储区域2022-05-05
这篇文章主要介绍了idea 多模块项目依赖父工程class找不到问题的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-01-01
这篇文章主要介绍了JAVA maven项目使用钉钉SDK获取token、用户，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-06-06
本文介绍了多种压缩算法及其在Java中的实现,包括LZ4、BZip2、Deflate、Gzip和7z等,LZ4以其高效的压缩和解压缩速度而受到青睐,特别是在大数据处理场景中,通过对比不同压缩算法的性能和压缩率,我们选择了最适合当前项目需求的压缩工具2025-02-02
SpringCloud可视化链路追踪系统Zipkin部署过程
这篇文章主要介绍了SpringCloud可视化链路追踪系统Zipkin部署过程,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-03-03
Sleuth是一个分布式跟踪系统，用于跟踪应用程序中的请求和操作，在本文中，我们将探讨SpringBoot中的Sleuth是什么，以及如何使用它来跟踪应用程序中的请求和操作，感兴趣的小伙伴跟着小编一起来探讨吧2023-07-07
这篇文章主要介绍了Java使用Redis的方法,接合实例形式分析了相关redis驱动包安装、java连接redis服务器、数据存储、读取等相关操作技巧,需要的朋友可以参考下2018-05-05
这篇文章主要介绍了Java多线程的其他知识,需要的朋友可以参考下2017-05-05
在网络编程中,动态IP代理可以帮助用户隐藏真实IP以及提高数据抓取的效率,本文将介绍如何在Java中实现动态IP代理,包括设置代理、发送请求以及处理响应,需要的朋友可以参考下2025-02-02
最新评论