动态数据源-SpringManagedTransaction&&AbstractRoutingDataSource 源码解析过程

墨蓝 2022-09-12 04:44 159阅读 0赞

# 动态数据源-源码解析过程 #

这其中需要mybatis的一些知识，进行一次debug调试，来查看过程。  
![在这里插入图片描述][01212e0d88324465afb56937ccc33ddf.png]  
在我们需要决定的地方打上断点，发送一次请求，我们先不要着急查看往下执行，先看一下调用栈已经调用了哪些方法并处于哪些类中。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_15_color_FFFFFF_t_70_g_se_x_16]  
如果看过mybatis源码，那么对上面的流程其实有一定的了解。接着进行断点的执行：![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16]  
这里回到了DynamicDataSource ，因为我们的 DynamicDataSource 是继承AbstractRoutingDataSource 的，并重写了AbstractRoutingDataSource 的钩子方法。这里我们的resolvedDataSources是在spring启动的时候初始化放进去的我们自定义的一些数据源，现在通过这个注解上的key拿到。感兴趣可以在DynamicDataSourceConfig中打断点在spring启动的时候去查看一次初始化过程。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
接下来就回到我们的getConnection方法：  
![在这里插入图片描述][86d1205aeeac49b7becaea07c85e7bb3.png]  
由于决定了使用哪一个数据源那么就从返回的数据源中调用getConnection方法，这里我使用的是com.zaxxer.hikari.HikariDataSource\#getConnection()方法。接着执行：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
这里是一个静态方法调用的是fetchConnection(DataSource dataSource)，通过传入的DataSource参数去获取connection，这个dataSource其实就是我们配置的DynamicDataSource，那么问题来了这个dataSource是从哪里传过来的？我们需要找到他的源头，这里留个疑问。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
上面的TransactionSynchronizationManager是一个事务同步器，在这里忽略不用管它，我们可以看到，dataSource仍然是由方法传进来的参数，并且类型仍然是我们自己配置的数据源DynamicDataSource。那我们接着往下看。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 4]  
dataSource类型仍然没有变，继续往下执行。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 5]  
现在我们可以看到SpringManagedTransaction传入了我们的DynamicDataSource，可以看到DynamicDataSource已经初始化到SpringManagedTransaction，那么SpringManagedTransaction是怎么找到我们的DynamicDataSource呢？留个疑问，我们看看SpringManagedTransaction的注解：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_17_color_FFFFFF_t_70_g_se_x_16]  
大概意思是SpringManagedTransaction处理JDBC的连接的生命周期，它从Spring的事务管理器中获取连接，并在不再需要时将连接返回给它。

如果Spring的事务处理是开启的，它将不对所有提交/回滚/关闭调用进行操作，将有Spring的事务管理器来处理。如果不是，它就仅仅为为普通的JdbcTransaction。

我们再来看看openConnection的注解：  
![在这里插入图片描述][4882ff8c43594d1d8391cde20079c18a.png]  
从Spring事务管理器获取连接，并发现该事务是否应该管理连接或让连接到Spring。

它还读取autocommit设置，因为当使用Spring Transaction时，MyBatis认为autocommit总是false，并且总是调用commit/rollback，所以我们需要对调用进行无操作。我们接着往下看：  
![在这里插入图片描述][efad95f579c4485d94215ab5993de5f1.png]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 6]

基本上下面的内容就是mybatis的内容了。所有我们基本上可以有个大致的了解：SpringManagedTransaction是一个关键，那我们回到初始化，看看我们的DynamicDataSource是如何注入到SpringManagedTransaction的。

## SpringManagedTransaction ##

在SpringManagedTransaction有一个构造方法，我们在此打下断点，启动项目。但是启动后，并没有触发断点，我意识到可能这个是在请求中触发的。尝试一次结果如下：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 7]  
这一步并不能看出什么，我们接着往下走一步:  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 8]  
终于我们看到了一个很熟悉的名字：DefaultSqlSessionFactory并且获取我们的Environment内配置好的DataSource，其实就对应上了：  
![在这里插入图片描述][9302f9ac31de4bf4a3e42d6e4f83773a.png]  
在这里我们看一下调用栈：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_18_color_FFFFFF_t_70_g_se_x_16]  
其实就对应上了，在开启Session的时候，会去读取配置，这样我们的配置就会生效了。

既然都到这里了那么我们再往下走一走，一直走到我们的方法生效。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 9]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 10]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 11]  
进入invoke后，就走到了我们之前的：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 12]  
所以呢？我们其实可以很容易的看出，这里代理的方法其实是走了我们的自定义配置里的方法，这样就和前文对应上了。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 13]  
我们这里result其实就已经从连接里面查出数据了，被代理的方法是如下：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 14]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 15]

[01212e0d88324465afb56937ccc33ddf.png]: /images/20220828/32231ee35a924908912d5fc76bdbda58.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_15_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/517548aa682547c99cdd82005a550c7b.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/cddeb8cf5016472aa1ae56ab592b0c79.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/fcbd4be780de4636adb7298cb71f5641.png
[86d1205aeeac49b7becaea07c85e7bb3.png]: /images/20220828/a5e7363965d3428d82b7770731aed2ec.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/a329b278b4f346ff87ac7b4b14ba60ff.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/dba82cc33a2f4d9f95071383f3f6b018.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220828/e5514e7545454e4194abde370bd16aaa.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220828/3acdebbf81b8476c8d839bbee2ddaa77.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_17_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/8683781d69f24e41834c1fcf4cf992e3.png
[4882ff8c43594d1d8391cde20079c18a.png]: /images/20220828/8948796fa2b44c309cf817d7da1b49e1.png
[efad95f579c4485d94215ab5993de5f1.png]: /images/20220828/17deab9248e74a59bab873ac6e75e289.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220828/5fe3deb5d0ee4d5dbceff0e347d4206e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220828/62c81848fb1d4c4e8193f91c703c7ed4.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 8]: /images/20220828/b0fcf3e629a149489dd290d6a69a9b4f.png
[9302f9ac31de4bf4a3e42d6e4f83773a.png]: /images/20220828/eda09b14776b4ff5a3f0f1d1207b597b.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_18_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/6e9ff3260e82445ab123079521d54368.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 9]: /images/20220828/603a5e6ae8ec4a4ba89be1b0747ab56c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 10]: /images/20220828/a79d40c8797149049f2b6eb9c3a5ae74.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 11]: /images/20220828/97e397a741ae46158bdb8f713ff4f6c8.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 12]: /images/20220828/23fa4a345d4c4dcdb27fb8d2c7e7a2d0.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 13]: /images/20220828/8592d2d7c8624f70877e54eddf23ff05.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 14]: /images/20220828/121807495ed141568273e2a92260ea40.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZXZlcnlEX3N0cnVnZ2xl_size_20_color_FFFFFF_t_70_g_se_x_16 15]: /images/20220828/95f54c875e8148b1b38d100bd01b2063.png