阅读源码解析dynamic-datasource-spring-boot-starter中是如何动态切换数据源的

本文主要是介绍阅读源码解析dynamic-datasource-spring-boot-starter中是如何动态切换数据源的,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

dynamic-datasource-spring-boot-starter是苞米豆提供的一个动态切换数据源的工具,可以帮助企业或者个人实现多数据源的切换,这里通过阅读源码的方式解析是如何动态的切换数据源的,采用的版本是3.5.1

源码解析

通过官方文档可以看到,如果想要动态的切换数据源,就需要在类或者方法上加上@DS注解

img

加上这个注解以后通过aop就可以拦截且识别到dsName究竟是什么,然后将其存储在ThreadLocal中
在这里插入图片描述
这个ThreadLocal中存储的是一个队列,我认为存储队列的目的是对应官方文档中的“就近原则”
在这里插入图片描述

再来看到DynamicRoutingDataSource这个实现类,找到determineDataSource这个方法,可以看到实际上他是实现方法,点击左边的绿色小图标

在这里插入图片描述

看完以后就知道了,实际上这个就是数据库连接,根据这个数据源获取相应的数据库连接然后进行相应的操作

在这里插入图片描述

再回到determineDataSource这个方法上,可以看到他是获取到队列中的第一个元素,然后再去map中获取相应的数据源,那么再去看看这个getDataSource方法

在这里插入图片描述

点开以后看到实际上这个是有一个dataSourceMap的map,里面存储着各种数据源,那么疑问来了,这些数据源是什么时候被put进这个map里面的

在这里插入图片描述

如果仔细观察可以发现实际上DynamicRoutingDataSource这个类实现了InitializingBean这个接口(具体什么作用可以自己搜索)然后调用了afterPropertiesSet这个方法,在bean被创建完了以后就会调用这个方法,于是数据源是什么时候被put进这个map了

在这里插入图片描述

我们知道实际上,动态切换数据源是通过yaml文件的相关配置进行加载数据源的,那么加载数据源的这一步实际上也在afterPropertiesSet这个方法里面

在这里插入图片描述

点进去以后发现这是一个接口有两个实现类,选择yml这个实现类来看下

在这里插入图片描述

进来以后发现loadDataSources这个方法就是用于加载数据源的,可以看到他在这个方法里面传入了一个Map<String, DataSourceProperty> dataSourcePropertiesMap,点进这个方法里面

在这里插入图片描述

这while循环里面的内容就是用于加载数据源了,根据传入进来的存储着数据源配置类的map,遍历map里面的数据源配置类然后加载数据源

在这里插入图片描述

这个map里面的数据源配置类又是根据依赖注入注入进来的

在这里插入图片描述
最后,在获取完了数据源以后不要忘了aop里面的方法是环绕方法,由于遵循就近原则,最后会将队列里面的内容弹出,获取下一个数据源

完整流程

最后贴上一张完整的流程图,如果有不正确的地方还请各位指正
在这里插入图片描述

这篇关于阅读源码解析dynamic-datasource-spring-boot-starter中是如何动态切换数据源的的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1052824

相关文章

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Apache Ignite 与 Spring Boot 集成详细指南

《ApacheIgnite与SpringBoot集成详细指南》ApacheIgnite官方指南详解如何通过SpringBootStarter扩展实现自动配置,支持厚/轻客户端模式,简化Ign... 目录 一、背景:为什么需要这个集成? 二、两种集成方式(对应两种客户端模型) 三、方式一:自动配置 Thick

全面解析Golang 中的 Gorilla CORS 中间件正确用法

《全面解析Golang中的GorillaCORS中间件正确用法》Golang中使用gorilla/mux路由器配合rs/cors中间件库可以优雅地解决这个问题,然而,很多人刚开始使用时会遇到配... 目录如何让 golang 中的 Gorilla CORS 中间件正确工作一、基础依赖二、错误用法(很多人一开

Spring WebClient从入门到精通

《SpringWebClient从入门到精通》本文详解SpringWebClient非阻塞响应式特性及优势,涵盖核心API、实战应用与性能优化,对比RestTemplate,为微服务通信提供高效解决... 目录一、WebClient 概述1.1 为什么选择 WebClient?1.2 WebClient 与

Java.lang.InterruptedException被中止异常的原因及解决方案

《Java.lang.InterruptedException被中止异常的原因及解决方案》Java.lang.InterruptedException是线程被中断时抛出的异常,用于协作停止执行,常见于... 目录报错问题报错原因解决方法Java.lang.InterruptedException 是 Jav

深入浅出SpringBoot WebSocket构建实时应用全面指南

《深入浅出SpringBootWebSocket构建实时应用全面指南》WebSocket是一种在单个TCP连接上进行全双工通信的协议,这篇文章主要为大家详细介绍了SpringBoot如何集成WebS... 目录前言为什么需要 WebSocketWebSocket 是什么Spring Boot 如何简化 We

java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)

《java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)》:本文主要介绍java中pdf模版填充表单踩坑的相关资料,OpenPDF、iText、PDFBox是三... 目录准备Pdf模版方法1:itextpdf7填充表单(1)加入依赖(2)代码(3)遇到的问题方法2:pd

Java Stream流之GroupBy的用法及应用场景

《JavaStream流之GroupBy的用法及应用场景》本教程将详细介绍如何在Java中使用Stream流的groupby方法,包括基本用法和一些常见的实际应用场景,感兴趣的朋友一起看看吧... 目录Java Stream流之GroupBy的用法1. 前言2. 基础概念什么是 GroupBy?Stream

Mysql中设计数据表的过程解析

《Mysql中设计数据表的过程解析》数据库约束通过NOTNULL、UNIQUE、DEFAULT、主键和外键等规则保障数据完整性,自动校验数据,减少人工错误,提升数据一致性和业务逻辑严谨性,本文介绍My... 目录1.引言2.NOT NULL——制定某列不可以存储NULL值2.UNIQUE——保证某一列的每一

深度解析Nginx日志分析与499状态码问题解决

《深度解析Nginx日志分析与499状态码问题解决》在Web服务器运维和性能优化过程中,Nginx日志是排查问题的重要依据,本文将围绕Nginx日志分析、499状态码的成因、排查方法及解决方案展开讨论... 目录前言1. Nginx日志基础1.1 Nginx日志存放位置1.2 Nginx日志格式2. 499