SpringBoot項(xiàng)目中如何動(dòng)態(tài)切換數(shù)據(jù)源、數(shù)據(jù)庫(kù)
前言
本文參考若依源碼,介紹了如何在SpringBoot項(xiàng)目中使用AOP和自定義注解實(shí)現(xiàn)MySQL主從數(shù)據(jù)庫(kù)的動(dòng)態(tài)切換,當(dāng)從庫(kù)故障時(shí),能自動(dòng)切換到主庫(kù),確保服務(wù)的高可用性。
實(shí)現(xiàn)效果:如果 服務(wù)器搭建的是一主多從多個(gè)mysql數(shù)據(jù)源,主服務(wù)器用來(lái)讀。從服務(wù)器用來(lái)寫(xiě)。此時(shí)你在代碼層面用注解指定了一個(gè)增刪改方法到從數(shù)據(jù)源,但是碰巧此時(shí)從數(shù)據(jù)源失效了,那么就會(huì)自動(dòng)的切換到其它服務(wù)器。
為什么要切換數(shù)據(jù)源,有哪些應(yīng)用場(chǎng)景?
動(dòng)態(tài)切換數(shù)據(jù)源通常是為了滿足以下需求:
- 讀寫(xiě)分離:在數(shù)據(jù)庫(kù)架構(gòu)中,為了提高性能和可用性,常常使用主從復(fù)制的方式。主數(shù)據(jù)庫(kù)處理寫(xiě)操作,而從數(shù)據(jù)庫(kù)處理讀操作。動(dòng)態(tài)切換數(shù)據(jù)源可以在不同的操作中使用不同的數(shù)據(jù)庫(kù),以達(dá)到優(yōu)化性能的目的。
- 多租戶架構(gòu):在SaaS(Software as a Service)應(yīng)用中,不同的租戶可能需要操作不同的數(shù)據(jù)庫(kù)。動(dòng)態(tài)數(shù)據(jù)源允許系統(tǒng)根據(jù)租戶的身份來(lái)切換到對(duì)應(yīng)的數(shù)據(jù)源。
- 分庫(kù)分表:在處理大規(guī)模數(shù)據(jù)時(shí),可能會(huì)采用分庫(kù)分表的策略來(lái)分散數(shù)據(jù)存儲(chǔ)的壓力。動(dòng)態(tài)切換數(shù)據(jù)源可以在執(zhí)行跨庫(kù)或跨表操作時(shí),根據(jù)需要切換到正確的數(shù)據(jù)源。
- 環(huán)境隔離:在開(kāi)發(fā)、測(cè)試和生產(chǎn)環(huán)境中,可能需要連接到不同的數(shù)據(jù)庫(kù)。動(dòng)態(tài)數(shù)據(jù)源可以在不同環(huán)境之間無(wú)縫切換,以確保數(shù)據(jù)的隔離和安全性。
- 靈活的數(shù)據(jù)庫(kù)管理:在復(fù)雜的業(yè)務(wù)場(chǎng)景下,可能需要根據(jù)不同的業(yè)務(wù)邏輯來(lái)選擇不同的數(shù)據(jù)源。動(dòng)態(tài)數(shù)據(jù)源提供了這種靈活性,允許開(kāi)發(fā)者根據(jù)運(yùn)行時(shí)的條件來(lái)選擇最合適的數(shù)據(jù)源。
- 故障轉(zhuǎn)移和高可用性:當(dāng)主數(shù)據(jù)庫(kù)不可用時(shí),動(dòng)態(tài)切換數(shù)據(jù)源可以自動(dòng)或手動(dòng)切換到備用數(shù)據(jù)庫(kù),以保證服務(wù)的連續(xù)性和數(shù)據(jù)的可用性。
如何切換數(shù)據(jù)源?
SpringBoot版本:3.0.4
jdk版本:JDK17
1.pom文件
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<!-- aop切面-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<!--druid連接池-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.20</version>
</dependency>
<!--mysql驅(qū)動(dòng)-->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!--MybatisPlus-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.3.1</version>
</dependency>2.配置文件:application.yml、application-druid.yml
application.yml配置文件:
#application.yml
server:
port: 8000
spring:
profiles:
active: druidapplication-druid.yml配置文件:
# 數(shù)據(jù)源配置
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.mysql.cj.jdbc.Driver
druid:
# 主庫(kù)數(shù)據(jù)源
master:
url: jdbc:mysql://localhost:3306/study?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
# 從庫(kù)數(shù)據(jù)源
slave:
# 從數(shù)據(jù)源開(kāi)關(guān)/默認(rèn)關(guān)閉
enabled: true
url: jdbc:mysql://localhost:3306/t_lyj?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
# 初始連接數(shù)
initialSize: 5
# 最小連接池?cái)?shù)量
minIdle: 10
# 最大連接池?cái)?shù)量
maxActive: 20
# 配置獲取連接等待超時(shí)的時(shí)間
maxWait: 60000
# 配置連接超時(shí)時(shí)間
connectTimeout: 30000
# 配置網(wǎng)絡(luò)超時(shí)時(shí)間
socketTimeout: 60000
# 配置間隔多久才進(jìn)行一次檢測(cè),檢測(cè)需要關(guān)閉的空閑連接,單位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一個(gè)連接在池中最小生存的時(shí)間,單位是毫秒
minEvictableIdleTimeMillis: 300000
# 配置一個(gè)連接在池中最大生存的時(shí)間,單位是毫秒
maxEvictableIdleTimeMillis: 9000003、數(shù)據(jù)源名稱(chēng)枚舉DataSourceType
/**
* 數(shù)據(jù)源
*
* @author ruoyi
*/
public enum DataSourceType
{
/**
* 主庫(kù)
*/
MASTER,
/**
* 從庫(kù)
*/
SLAVE
}4、Bean工具類(lèi)SpringUtils
@Component
public final class SpringUtils implements BeanFactoryPostProcessor, ApplicationContextAware
{
/** Spring應(yīng)用上下文環(huán)境 */
private static ConfigurableListableBeanFactory beanFactory;
private static ApplicationContext applicationContext;
@Override
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException
{
SpringUtils.beanFactory = beanFactory;
}
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
{
SpringUtils.applicationContext = applicationContext;
}
/**
* 獲取對(duì)象
*
* @param name
* @return Object 一個(gè)以所給名字注冊(cè)的bean的實(shí)例
* @throws BeansException
*
*/
@SuppressWarnings("unchecked")
public static <T> T getBean(String name) throws BeansException
{
return (T) beanFactory.getBean(name);
}
/**
* 獲取類(lèi)型為requiredType的對(duì)象
*
* @param clz
* @return
* @throws BeansException
*
*/
public static <T> T getBean(Class<T> clz) throws BeansException
{
T result = (T) beanFactory.getBean(clz);
return result;
}
/**
* 如果BeanFactory包含一個(gè)與所給名稱(chēng)匹配的bean定義,則返回true
*
* @param name
* @return boolean
*/
public static boolean containsBean(String name)
{
return beanFactory.containsBean(name);
}
/**
* 判斷以給定名字注冊(cè)的bean定義是一個(gè)singleton還是一個(gè)prototype。 如果與給定名字相應(yīng)的bean定義沒(méi)有被找到,將會(huì)拋出一個(gè)異常(NoSuchBeanDefinitionException)
*
* @param name
* @return boolean
* @throws NoSuchBeanDefinitionException
*
*/
public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException
{
return beanFactory.isSingleton(name);
}
/**
* @param name
* @return Class 注冊(cè)對(duì)象的類(lèi)型
* @throws NoSuchBeanDefinitionException
*
*/
public static Class<?> getType(String name) throws NoSuchBeanDefinitionException
{
return beanFactory.getType(name);
}
/**
* 如果給定的bean名字在bean定義中有別名,則返回這些別名
*
* @param name
* @return
* @throws NoSuchBeanDefinitionException
*
*/
public static String[] getAliases(String name) throws NoSuchBeanDefinitionException
{
return beanFactory.getAliases(name);
}
/**
* 獲取aop代理對(duì)象
*
* @param invoker
* @return
*/
@SuppressWarnings("unchecked")
public static <T> T getAopProxy(T invoker)
{
return (T) AopContext.currentProxy();
}
/**
* 獲取當(dāng)前的環(huán)境配置,無(wú)配置返回null
*
* @return 當(dāng)前的環(huán)境配置
*/
public static String[] getActiveProfiles()
{
return applicationContext.getEnvironment().getActiveProfiles();
}
/**
* 獲取當(dāng)前的環(huán)境配置,當(dāng)有多個(gè)環(huán)境配置時(shí),只獲取第一個(gè)
*
* @return 當(dāng)前的環(huán)境配置
*/
public static String getActiveProfile()
{
final String[] activeProfiles = getActiveProfiles();
return StringUtils.isNotEmpty(Arrays.toString(activeProfiles)) ? activeProfiles[0] : null;
}
/**
* 獲取配置文件中的值
*
* @param key 配置文件的key
* @return 當(dāng)前的配置文件的值
*
*/
public static String getRequiredProperty(String key)
{
return applicationContext.getEnvironment().getRequiredProperty(key);
}
}5、多數(shù)據(jù)源切換注解DataSource
/**
* 自定義多數(shù)據(jù)源切換注解
*
* 優(yōu)先級(jí):先方法,后類(lèi),如果方法覆蓋了類(lèi)上的數(shù)據(jù)源類(lèi)型,以方法的為準(zhǔn),否則以類(lèi)上的為準(zhǔn)
*
* @author lyj
*/
@Target({ ElementType.METHOD, ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface DataSource
{
/**
* 切換數(shù)據(jù)源名稱(chēng)
*/
public DataSourceType value() default DataSourceType.MASTER;
}6、數(shù)據(jù)源解析配置類(lèi)DruidConfig
@Configuration
public class DruidConfig {
@Bean
@ConfigurationProperties("spring.datasource.druid.master")
public DataSource masterDataSource(DruidProperties druidProperties){
DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
return druidProperties.dataSource(dataSource);
}
@Bean
@ConfigurationProperties("spring.datasource.druid.slave")
@ConditionalOnProperty(prefix = "spring.datasource.druid.slave", name = "enabled", havingValue = "true")
public DataSource slaveDataSource(DruidProperties druidProperties) {
DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
return druidProperties.dataSource(dataSource);
}
@Bean(name = "dynamicDataSource")
@Primary
public DynamicDataSource dataSource(DataSource masterDataSource) {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
setDataSource(targetDataSources, DataSourceType.SLAVE.name(), "slaveDataSource");
return new DynamicDataSource(masterDataSource, targetDataSources);
}
/**
* 設(shè)置數(shù)據(jù)源
*
* @param targetDataSources 備選數(shù)據(jù)源集合
* @param sourceName 數(shù)據(jù)源名稱(chēng)
* @param beanName bean名稱(chēng)
*/
public void setDataSource(Map<Object, Object> targetDataSources, String sourceName, String beanName) {
try {
DataSource dataSource = SpringUtils.getBean(beanName);
targetDataSources.put(sourceName, dataSource);
} catch (Exception e) {
}
}
}7、數(shù)據(jù)源注入核心類(lèi)DynamicDataSource
/**
* 動(dòng)態(tài)數(shù)據(jù)源
*
* @author lyj
*/
public class DynamicDataSource extends AbstractRoutingDataSource {
public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources)
{
//設(shè)置默認(rèn)數(shù)據(jù)源
super.setDefaultTargetDataSource(defaultTargetDataSource);
//設(shè)置目標(biāo)數(shù)據(jù)源的映射
super.setTargetDataSources(targetDataSources);
//初始化
super.afterPropertiesSet();
}
@Override
protected Object determineCurrentLookupKey()
{
return DynamicDataSourceContextHolder.getDataSourceType();
}
}8、數(shù)據(jù)源切換處理類(lèi)DynamicDataSourceContextHolder
/**
* 數(shù)據(jù)源切換處理
*
* @author lyj
*/
public class DynamicDataSourceContextHolder
{
public static final Logger log = LoggerFactory.getLogger(DynamicDataSourceContextHolder.class);
/**
* 使用ThreadLocal維護(hù)變量,ThreadLocal為每個(gè)使用該變量的線程提供獨(dú)立的變量副本,
* 所以每一個(gè)線程都可以獨(dú)立地改變自己的副本,而不會(huì)影響其它線程所對(duì)應(yīng)的副本。
*/
private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();
/**
* 設(shè)置數(shù)據(jù)源的變量
*/
public static void setDataSourceType(String dsType)
{
log.info("切換到{}數(shù)據(jù)源", dsType);
CONTEXT_HOLDER.set(dsType);
}
/**
* 獲得數(shù)據(jù)源的變量,默認(rèn)使用主數(shù)據(jù)源
*/
public static String getDataSourceType()
{
return CONTEXT_HOLDER.get() == null ? DataSourceType.MASTER.name() : CONTEXT_HOLDER.get();
}
/**
* 清空數(shù)據(jù)源變量
*/
public static void clearDataSourceType()
{
CONTEXT_HOLDER.remove();
}
}9、Aop切面類(lèi)
@Aspect
@Order(1)
@Component
public class DataSourceAspect {
@Pointcut("@annotation(com.LYJ.study.DynamicDataSource.annocation.DataSource)"
+ "|| @within(com.LYJ.study.DynamicDataSource.annocation.DataSource)")
public void dsPointCut(){}
@Around("dsPointCut()")
public Object around(ProceedingJoinPoint joinPoint) throws Throwable{
DataSource dataSource = getDataSource(joinPoint);
if (dataSource != null){
DynamicDataSourceContextHolder.setDataSourceType(dataSource.value().name());
}
try {
return joinPoint.proceed();
}
finally {
// 銷(xiāo)毀數(shù)據(jù)源 在執(zhí)行方法之后
DynamicDataSourceContextHolder.clearDataSourceType();
}
}
/**
* 獲取需要切換的數(shù)據(jù)源
*/
public DataSource getDataSource(ProceedingJoinPoint point)
{
MethodSignature signature = (MethodSignature) point.getSignature();
com.LYJ.study.DynamicDataSource.annocation.DataSource dataSource = AnnotationUtils.findAnnotation(signature.getMethod(), com.LYJ.study.DynamicDataSource.annocation.DataSource.class);
if (Objects.nonNull(dataSource)) {
return dataSource;
}
return AnnotationUtils.findAnnotation(signature.getDeclaringType(), DataSource.class);
}
}10、在業(yè)務(wù)中使用

@Service
@RequiredArgsConstructor
@DataSource(value=DataSourceType.MASTER)
//@DataSource(value=DataSourceType.SLAVE)
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
private final UserMapper userMapper;
@Override
@DataSource(value=DataSourceType.MASTER)
//@DataSource(value=DataSourceType.SLAVE)
public List<User> queryAll() {
return userMapper.selectList(null);
}
}我們?cè)趕ervice、mapper的類(lèi)和方法上使用都可以。
補(bǔ)充:有很多從數(shù)據(jù)源怎么辦?
我們上面已經(jīng)配置了一個(gè)從數(shù)據(jù)源了,接下來(lái)我們繼續(xù)配置多個(gè)從數(shù)據(jù)源
首先在application-druid.yml文件添加新的數(shù)據(jù)源

在枚舉添加數(shù)據(jù)源名稱(chēng)
//如果配置多數(shù)據(jù)源,繼續(xù)添加即可
public enum DataSourceType
{
/**
* 主庫(kù)
*/
MASTER,
/**
* 從庫(kù)
*/
SLAVE,
/**
* 從庫(kù)2
*/
SLAVE2
}
如何切換數(shù)據(jù)庫(kù)?
我們就以O(shè)racle為例
<!--oracle驅(qū)動(dòng)-->
<dependency>
<groupId>com.oracle</groupId>
<artifactId>ojdbc6</artifactId>
<version>11.2.0.3</version>
</dependency>在application-druid.yml添加
slave3:
# 從數(shù)據(jù)源開(kāi)關(guān)/默認(rèn)關(guān)閉
enabled: true
url: jdbc:oracle:thin:@127.0.0.1:1521:oracle
username: root
password: password然后刪除指定的mysql驅(qū)動(dòng),默認(rèn)會(huì)自動(dòng)尋找驅(qū)動(dòng)

添加數(shù)據(jù)源和用法參考上面即可,都是一樣的。
注意:在切換數(shù)據(jù)庫(kù)時(shí),因?yàn)閙ysql跟Oracle的sql語(yǔ)法有差別,啟動(dòng)時(shí)可能報(bào)錯(cuò)。
到此這篇關(guān)于SpringBoot項(xiàng)目中如何動(dòng)態(tài)切換數(shù)據(jù)源、數(shù)據(jù)庫(kù)的文章就介紹到這了,更多相關(guān)SpringBoot動(dòng)態(tài)切換數(shù)據(jù)源內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- 在SpringBoot項(xiàng)目中動(dòng)態(tài)切換數(shù)據(jù)源和數(shù)據(jù)庫(kù)的詳細(xì)步驟
- SpringBoot實(shí)現(xiàn)數(shù)據(jù)源動(dòng)態(tài)切換的最佳姿勢(shì)
- SpringBoot實(shí)現(xiàn)動(dòng)態(tài)數(shù)據(jù)源切換的項(xiàng)目實(shí)踐
- SpringBoot實(shí)現(xiàn)動(dòng)態(tài)數(shù)據(jù)源切換的方法總結(jié)
- 使用SpringBoot動(dòng)態(tài)切換數(shù)據(jù)源的實(shí)現(xiàn)方式
- Springboot實(shí)現(xiàn)多數(shù)據(jù)源切換詳情
- SpringBoot多數(shù)據(jù)源切換實(shí)現(xiàn)代碼(Mybaitis)
- SpringBoot實(shí)現(xiàn)動(dòng)態(tài)切換數(shù)據(jù)源的示例代碼
相關(guān)文章
Spring框架中ImportBeanDefinitionRegistrar的應(yīng)用詳解
這篇文章主要介紹了Spring框架中ImportBeanDefinitionRegistrar的應(yīng)用詳解,如果實(shí)現(xiàn)了ImportSelector接口,在配置類(lèi)中被@Import加入到Spring容器中以后,Spring容器就會(huì)把ImportSelector接口方法返回的字符串?dāng)?shù)組中的類(lèi)new出來(lái)對(duì)象然后放到工廠中去,需要的朋友可以參考下2024-01-01
Jedis零基礎(chǔ)入門(mén)及操作Redis中的數(shù)據(jù)結(jié)構(gòu)詳解
Jedis 的 API 方法跟 Redis 的命令基本上完全一致,熟悉 Redis 的操作命令,自然就很容易使用 Jedis,因此官方也推薦 Java 使用 Jedis 來(lái)連接和操作 Redis2022-09-09
Java實(shí)現(xiàn)的計(jì)時(shí)器【秒表】功能示例
這篇文章主要介紹了Java實(shí)現(xiàn)的計(jì)時(shí)器【秒表】功能,結(jié)合實(shí)例形式分析了Java結(jié)合JFrame框架的計(jì)時(shí)器功能相關(guān)操作技巧,需要的朋友可以參考下2019-02-02
Java中時(shí)間處理API全解析(從JDK7到JDK8)
在 Java 開(kāi)發(fā)領(lǐng)域,時(shí)間處理是一項(xiàng)極為常見(jiàn)且關(guān)鍵的需求,本文圍繞 JDK7 與 JDK8 中的時(shí)間處理類(lèi),詳細(xì)梳理時(shí)間類(lèi)的使用與演進(jìn),希望對(duì)大家有所幫助2025-07-07
基于Redis實(shí)現(xiàn)分布式應(yīng)用限流的方法
本篇文章主要介紹了基于 Redis 實(shí)現(xiàn)分布式應(yīng)用限流的方法,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-12-12
JavaMail入門(mén)教程之創(chuàng)建郵件(2)
這篇文章主要介紹了JavaMail入門(mén)教程之創(chuàng)建郵件的相關(guān)資料,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2016-11-11

