前段時(shí)間公司的項(xiàng)目有個(gè)需求天试,一個(gè)特別耗時(shí)的讀方法希望能走從庫以減輕主庫壓力,所以就研究了下SpringBoot的解決方案,順便將寫好的工具也放到GitHub上了素挽,希望可以幫助到有同樣需求的小伙伴照卦,也歡迎大家多提提意見式矫,共同學(xué)習(xí)進(jìn)步。
一役耕、使用方法
項(xiàng)目地址:https://github.com/xtg20121013/dynamicDataSource
代碼很簡單采转,在test下有個(gè)簡單的web demo,可以參考瞬痘。
1. 在配置文件applicaiton.yml中加入數(shù)據(jù)源配置
a. 默認(rèn)數(shù)據(jù)源:同spring默認(rèn)配置故慈,例如:
spring:
mvc:
static-path-pattern: /static/**
datasource:
url: jdbc:mysql://localhost/db_master
username: root
password: 78451200
driver-class-name: com.mysql.jdbc.Driver
max-idle: 2
b. 其他數(shù)據(jù)源:可配置多個(gè),務(wù)必指定name框全,需在項(xiàng)目中指定察绷,db.datasources下其他配置同spring默認(rèn),例如:
db:
datasources:
- name: s1
url: jdbc:mysql://localhost/db_slave
username: root
password: 78451200
driver-class-name: com.mysql.jdbc.Driver
max-idle: 3
- name: s2
url: jdbc:mysql://localhost/db_slave
username: root
password: 78451200
driver-class-name: com.mysql.jdbc.Driver
max-idle: 4
2. 引入dynamicDataSource配置注冊類
在@Configuration標(biāo)注的配置類加上注解@import(DynamicDataSourceRegistrar.class)
3. 在相關(guān)使用的地方加上注解@TargetDataSource
如@Transactional的用法相似津辩,將@TargetDataSource("s1")標(biāo)注在對(duì)應(yīng)的類或者方法上即可指定相關(guān)方法內(nèi)的所有同線程的db查詢走指定的datasource
二拆撼、原理
- 讀取配置文件將配置中的所有配置的datasource(從庫必填name字段)注冊到routingDataSource的map中
- 僅影響同一線程,通過AOP(在標(biāo)注的方法前將所選擇的datasource name存在ThreadLocal中丹泉,在方法結(jié)束后重置ThreadLocal的datasource name)
- 通過routingDataSource替換原DataSource情萤,重寫getConnection方法,在該方法內(nèi)根據(jù)datasource name來分發(fā)找到對(duì)應(yīng)的datasource獲取connection返回
三摹恨、適用場景
- 同項(xiàng)目內(nèi)筋岛,多個(gè)業(yè)務(wù)(可能基于歷史原因,不太適合應(yīng)用拆分)涉及多個(gè)不同DB晒哄,需要在項(xiàng)目分發(fā)
- 個(gè)別耗時(shí)只讀服務(wù)睁宰,希望落到從庫中,這時(shí)建議標(biāo)注在該服務(wù)方法最上層寝凌,保證同一線程下的該服務(wù)內(nèi)的全部數(shù)據(jù)庫查詢都落在同一個(gè)db中柒傻,(不標(biāo)注在下層dao,因?yàn)榭梢宰屍渌?wù)調(diào)用時(shí)依然可以走主庫)
- 可做讀寫分離较木,將dao層的讀方法標(biāo)注走從庫(注意在qps較高時(shí)红符,主從同步延遲較高可能導(dǎo)致的數(shù)據(jù)不一致,延遲相關(guān)建議查閱http://www.cnblogs.com/olinux/p/6085405.html
四、弊端
- 必須在transactional事務(wù)之前調(diào)用预侯,事務(wù)中無法切換db致开,因?yàn)閟pring事務(wù)中的connection是從事先預(yù)存的ThreadLocal中取得
- 基于AOP,不適用于protect萎馅、private的方法(class.getMethod方法只能取到public的)双戳,不適用于同類中的方法調(diào)用
歡迎來我的個(gè)人博客逛逛: https://blog.52xtg.com