怎么实现事务_Spring AOP 实现动态数据源（读写分离），底层原理是什么

矫情吗；* 2023-01-07 04:52 69阅读 0赞

spring集成mybatis实现mysql读写分离，简单介绍了通过 Spring AOP 从应用程序层面实现读写分离；读写分离效果是达到了，可我们知道为什么那么做就能实现读写分离吗 ？知道的请快点走开

![39a2b7aadba19fac18a5311a50bfd68e.gif][]

接下来请好好欣赏我的表演

# 原理解密 #

我们逐个讲解其中涉及的点，然后串起来理解读写分离的底层原理

# 　　Spring AOP #

AOP：Aspect Oriented Program

关于 Spring AOP，相信大家耳熟能详，它是对 OOP 的一种补充，OOP 是纵向的，AOP 则是横向的

![d83d3e1c298fd7fa21a0bdab674c6402.png][]

如上图所示，OOP 属于一种纵向拓展，AOP 则是一种横向拓展。AOP 依托于 OOP，将公共功能代码抽象出来作为一个切面，减少重复代码量，降低耦合

AOP 的底层实现是动态代理，具体的表现形式粗略如下

![8747c60100d88c283254fe5e73d37008.png][]

对 Spring AOP 有个大致了解了，我们就可以接着往下看了

# 　　Spring 数据源 #

无论是 Spring JDBC，还是 Hibernate，亦或是 MyBatis，其实都是对 JDBC 的封装；对于JDBC，我们不要太熟，大体流程如下

![384e38668e8a9cb0f53523b87fd1b983.png][]

然而，在实际应用中，我们往往不会直接使用 JDBC，而是使用 ORM，ORM 会封装上述的流程，也就说我们不再需要关注了；MyBatis 使用步骤大致如下

![d6c8625be3140ff06225d653c65465f2.png][]

我们以 SpringBoot + pagehelper + Druid(ssm) 为例，来看看具体是怎么获取 Connection 对象的

![eb31ba630a09d437af2d402659bbb9a1.gif][]

可以看到，如果事务管理器中存在 Connection 对象，则直接返回，否则从数据源中获取返回(同时也赋值给了事务管理器)；当取到 Connection 对象后，后续的流程大家就非常清楚了

然而我们不需要关注 Connection 对象，只需要关注数据源，为什么呢 ？ 因为我们的配置文件中配置的是数据源而不是 Connection，是不是很有道理 ？

# 　　ThreadLocal #

如果我们需要在各层之间进行参数的传递，实现方式有哪些 ？

最常见的方式可能就是方法参数，但还有一种容易忽略的方式：ThreadLocal，可以在当前线程内传递参数，减少方法的参数个数

关于 ThreadLocal，有兴趣的可以查看：结合ThreadLocal来看spring事务源码，感受下清泉般的洗涤！

当我们熟悉上面的三点后，后面的就好理解了，接着往下看

# 　　动态数据源 #

一个数据源只能对应一个数据库，如果我们有多个数据库(一主多从)，那么就需要配置多个数据源，类似如下

![788501467d0f1ddb5f199d7903b62fe5.gif][]

可是事务管理器中只有一个数据源的引用

![8217cfd6e43eb935933aaa15d391f5bb.png][]

那怎么对应我们配置文件中的多个数据源呢 ？其实，我们可以自定义一个类 DynamicDataSource 来实现 DataSource，DynamicDataSource 中存储我们配置的多数据源，然后将 DynamicDataSource 的实例配置给事务管理器；当从事务管理器获取 Connection 对象的时候，会从 DynamicDataSource 实例获取，然后再由 DynamicDataSource 根据 routeKey 路由到某个具体的数据源，从中获取 Connection；大体流程如下

![c384f4823738171b9c3d40d79b3185d6.png][]

Spring 也考虑到了这一点，提供了一个抽象类：AbstractRoutingDataSource，DynamicDataSource 继承它可以为我们省非常多的代码

![788501467d0f1ddb5f199d7903b62fe5.gif][]

配置文件中增加如下配置

![788501467d0f1ddb5f199d7903b62fe5.gif][]

但是问题又来了，这个 routeKey 怎么处理，也就说 DynamicDataSource 怎么知道用哪个数据源 ？ AbstractRoutingDataSource 提供了一个方法： determineCurrentLookupKey 我们只需要实现它，DynamicDataSource 就知道是使用哪个 lookupKey (routeKey 在 Spring 中的命名)了；determineCurrentLookupKey 具体该如何实现了，我们可以结合 ThreadLocal 来实现；整个流程大致如下

![2636451661194f962b596d1e059be2a5.png][]

一旦我们在切面中指定了 lookupKey，那么后续就会使用 lookupKey 对应的数据源来操作数据库了

自此，相信大家已经明白了动态数据源的底层原理

# 总结 #

Spring AOP → 将我们指定的 lookupKey 放入 ThreadLocal

ThreadLocal → 线程内共享 lookupKey

DynamicDataSource → 对多数据源进行封装，根据 ThreadLocal 中的 lookupKey 动态选择具体的数据源

如果我们对其中的某个环节不懂，可以试着删掉它，然后看这个流程能否正常串起来，这样就能明白各个环节的作用了

# 悬念 #

Spring AOP 实现多数据源，是否与 Spring 事务冲突 ，若冲突了该如何解决 ？

[39a2b7aadba19fac18a5311a50bfd68e.gif]: /images/20221119/128281db0ad946c2809cefa8dfe34ebe.png
[d83d3e1c298fd7fa21a0bdab674c6402.png]: /images/20221119/d24da8f988b84aec99e978e96ae02830.png
[8747c60100d88c283254fe5e73d37008.png]: /images/20221119/e3e4d7024ed446f09ad9da6d528df71d.png
[384e38668e8a9cb0f53523b87fd1b983.png]: /images/20221119/68ea003c1bb141ce92318f7b1a1a9d80.png
[d6c8625be3140ff06225d653c65465f2.png]: /images/20221119/1b04a7604f964480839128a147efac04.png
[eb31ba630a09d437af2d402659bbb9a1.gif]: /images/20221119/ddfcb4056c254e43817df40b836c5b4b.png
[788501467d0f1ddb5f199d7903b62fe5.gif]: /images/20221119/19a96b61afd640a9a0b5c485fffed6b5.png
[8217cfd6e43eb935933aaa15d391f5bb.png]: /images/20221119/591f850591f04c17a56b156dfca0d66a.png
[c384f4823738171b9c3d40d79b3185d6.png]: /images/20221119/9f9d88b573ad4a3a842a6d16fc70ead9.png
[2636451661194f962b596d1e059be2a5.png]: /images/20221119/76f8008e68c34bc6bcf11394e9fabe23.png