多數(shù)據(jù)源使用DynamicDatasource，再用@Transactiona注解，造成數(shù)據(jù)源會(huì)切換的BUG：

• 方法上寫了 @DS("slave")
• 執(zhí)行 SQL 時(shí)卻仍然走了 master

情景浮現(xiàn)：

@DS("master")
public class DB1Service{
	public list<?> queryDB1()
}

@DS("slaver")
public class DB2Service{
	public list<?> queryDB2()
}

public class Main{

	@Transactional(rollbackFor = Exception.class)
	public void sync(){
		// 預(yù)期會(huì)走slaver庫(kù)，?? 但實(shí)際還是會(huì)查詢 master DB
		var list2 = DB2Service.queryDB2()
		
		// .....
		var list1 = DB1Service.queryDB1()
	}
}

1 為什么？

先說(shuō)結(jié)論 ：
在同一個(gè)本地事務(wù)里，第一次拿到的連接會(huì)綁定到當(dāng)前線程。后續(xù)再切 @DS，通常只會(huì)改路由標(biāo)識(shí)，不會(huì)替換已經(jīng)綁定的連接。

調(diào)用 sync() 時(shí)，大致發(fā)生下面幾步：

1. 進(jìn)入 @Transactional 代理，事務(wù)開始
2. 事務(wù)管理器通過(guò) DataSourceUtils.getConnection(...) 拿連接
3. 連接綁定到 TransactionSynchronizationManager（ThreadLocal）
4. 執(zhí)行業(yè)務(wù)代碼，進(jìn)入 db2Service.queryDB2()
5. @DS("slave") 把當(dāng)前線程的數(shù)據(jù)源 key 改成 slave
6. 但取連接時(shí)發(fā)現(xiàn)線程里已經(jīng)有事務(wù)連接，于是直接復(fù)用
7. SQL 繼續(xù)走原連接（常見是 master）

這里最重要的一點(diǎn)： @DS 決定的是 “下一次新建連接時(shí)選哪個(gè)數(shù)據(jù)源”，不是“把當(dāng)前事務(wù)里的連接熱切換”。

如果連接已經(jīng)在事務(wù)里綁定好了，它不會(huì)換連接。

2 擴(kuò)展：Dynamic-Datasource實(shí)現(xiàn)多數(shù)據(jù)源原理

1. 啟動(dòng)階段裝配
   • DynamicDataSourceAutoConfiguration 注冊(cè) DynamicRoutingDataSource 作為主 DataSource。
   • 把你配置的 spring.datasource.dynamic.datasource.* 加載成數(shù)據(jù)源池，維護(hù)在內(nèi)部 dataSourceMap/groupDataSources 里。

2. AOP 攔截 @DS
   • DynamicDataSourceAopConfiguration 裝配 DynamicDataSourceAnnotationAdvisor + Interceptor。
   • 方法進(jìn)入時(shí)，DynamicDataSourceAnnotationInterceptor 解析 @DS 值（DataSourceClassResolver，支持方法/類、接口、繼承等）。
   • 解析出的 key（如 master/doris）被 push 到
   DynamicDataSourceContextHolder（ThreadLocal，棧結(jié)構(gòu)，支持嵌套調(diào)用）。
   • 方法退出后 poll，恢復(fù)上一個(gè)數(shù)據(jù)源上下文。

3. 真正路由發(fā)生在“取連接” • JdbcTemplate/MyBatis 最終都會(huì)走到當(dāng)前主數(shù)據(jù)源取連接。
   • 主數(shù)據(jù)源是 DynamicRoutingDataSource，它在 determineDataSource() 里 peek 當(dāng)前線程 key。
   • 然后 getDataSource(key)：
   • key 為空 -> 用 primary（默認(rèn) master）
   • key 是具體庫(kù)名 -> 直連該庫(kù)
   • key 是組名 -> 按策略（默認(rèn)負(fù)載均衡）選組內(nèi)某個(gè)庫(kù)
   • 未命中時(shí)：strict=true 拋異常，strict=false 回退 primary

總結(jié)：

• @DS 只是改“路由上下文”

• DynamicRoutingDataSource 在取連接時(shí)按上下文選庫(kù)

• 不是直接“切換已拿到的連接”

到此這篇關(guān)于多數(shù)據(jù)源下@transactiona事務(wù)踩坑實(shí)戰(zhàn)指南的文章就介紹到這了,更多相關(guān)多數(shù)據(jù)源下@transactiona事務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論