同一個項目有時會涉及到多個數據庫，也就是多數據源。多數據源又可以分為兩種情況：
1）兩個或多個數據庫沒有相關性，各自獨立，其實這種可以作為兩個項目來開發。比如在遊戲開發中一個數據庫是平台數據庫，其它還有平台下的遊戲對應的數據庫；
2）兩個或多個數據庫是master-slave的關係，比如有mysql搭建一個master-master，其後又帶有多個slave；或者採用MHA搭建的master-slave複製；
目前我所知道的Spring 多數據源的搭建大概有兩種方式，可以根據多數據源的情況進行選擇。
1. 採用spring配置文件直接配置多個數據源
比如針對兩個數據庫沒有相關性的情況，可以採用直接在spring的配置文件中配置多個數據源，然後分別進行事務的配置，如下所示：
<context:component-scan base-package="net.aazj.service,net.aazj.aop" /><context:component-scan base-package="net.aazj.aop" /><!-- 引入屬性文件--><context:property-placeholder location="classpath:config/db.properties" /> <!-- 配置數據源--><bean name="dataSource" init-method="init" destroy-method="close"> <property name="url" value="${jdbc_url}" /> <property name="username" value="${jdbc_username}" /> <property name="password" value="${jdbc_password}" /> <!-- 初始化連接大小--> <property name="initialSize" value="0" /> <!-- 連接池最大使用連接數量--> <property name="maxActive" value="20" /> <!-- 連接池最大空閒--> <property name="maxIdle" value="20" /> <!-- 連接池最小空閒--> <property name="minIdle" value="0" /> <!-- 獲取連接最大等待時間--> <property name="maxWait" value="60000" /></bean> <bean id="sqlSessionFactory"> <property name="dataSource" ref="dataSource" /> <property name="configLocation" value="classpath:config/mybatis-config.xml" /> <property name="mapperLocations" value="classpath*:config/mappers/**/*.xml" /></bean> <!-- Transaction manager for a single JDBC DataSource --><bean id="transactionManager"> <property name="dataSource" ref="dataSource" /></bean> <!-- 使用annotation定義事務--><tx:annotation-driven transaction-manager="transactionManager" /> <bean> <property name="basePackage" value="net.aazj.mapper" /> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/></bean> <!-- Enables the use of the @AspectJ style of Spring AOP --><aop:aspectj-autoproxy/>第二個數據源的配置
<bean name="dataSource_2" init-method="init" destroy-method="close"> <property name="url" value="${jdbc_url_2}" /> <property name="username" value="${jdbc_username_2}" /> <property name="password" value="${jdbc_password_2}" /> <!-- 初始化連接大小--> <property name="initialSize" value="0" /> <!-- 連接池最大使用連接數量--> <property name="maxActive" value="20" /> <!-- 連接池最大空閒--> <property name="maxIdle" value="20" /> <!-- 連接池最小空閒--> <property name="minIdle" value="0" /> <!-- 獲取連接最大等待時間--> <property name="maxWait" value="60000" /></bean> <bean id="sqlSessionFactory_slave"> <property name="dataSource" ref="dataSource_2" /> <property name="configLocation" value="classpath:config/mybatis-config-2.xml" /> <property name="mapperLocations" value="classpath*:config/mappers2/**/*.xml" /></bean> <!-- Transaction manager for a single JDBC DataSource --><bean id="transactionManager_2"> <property name="dataSource" ref="dataSource_2" /></bean> <!-- 使用annotation定義事務--><tx:annotation-driven transaction-manager="transactionManager_2" /> <bean> <property name="basePackage" value="net.aazj.mapper2" /> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory_2"/></bean>如上所示，我們分別配置了兩個dataSource，兩個sqlSessionFactory，兩個transactionManager，以及關鍵的地方在於MapperScannerConfigurer 的配置――使用sqlSessionFactoryBeanName屬性，注入不同的sqlSessionFactory的名稱，這樣的話，就為不同的數據庫對應的mapper 接口注入了對應的sqlSessionFactory。
需要注意的是，多個數據庫的這種配置是不支持分佈式事務的，也就是同一個事務中，不能操作多個數據庫。這種配置方式的優點是很簡單，但是卻不靈活。對於master-slave類型的多數據源配置而言不太適應，master-slave性的多數據源的配置，需要特別靈活，需要根據業務的類型進行細緻的配置。比如對於一些耗時特別大的select語句，我們希望放到slave上執行，而對於update,delete等操作肯定是只能在master上執行的，另外對於一些實時性要求很高的select語句，我們也可能需要放到master上執行――比如一個場景是我去商城購買一件兵器， 購買操作的很定是master，同時購買完成之後，需要重新查詢出我所擁有的兵器和金幣，那麼這個查詢可能也需要防止master上執行，而不能放在slave上去執行，因為slave上可能存在延時，我們可不希望玩家發現購買成功之後，在背包中卻找不到兵器的情況出現。
所以對於master-slave類型的多數據源的配置，需要根據業務來進行靈活的配置，哪些select可以放到slave上，哪些select不能放到slave上。所以上面的那種所數據源的配置就不太適應了。
2. 基於AbstractRoutingDataSource 和AOP 的多數據源的配置
基本原理是，我們自己定義一個DataSource類ThreadLocalRountingDataSource，來繼承AbstractRoutingDataSource，然後在配置文件中向ThreadLocalRountingDataSource注入master 和slave 的數據源，然後通過AOP 來靈活配置，在哪些地方選擇master 數據源，在哪些地方需要選擇slave數據源。下面看代碼實現：
1）先定義一個enum來表示不同的數據源：
package net.aazj.enums; /** * 數據源的類別：master/slave */public enum DataSources { MASTER, SLAVE} 2）通過TheadLocal 來保存每個線程選擇哪個數據源的標誌(key)：
package net.aazj.util; import net.aazj.enums.DataSources; public class DataSourceTypeManager { private static final ThreadLocal<DataSources> dataSourceTypes = new ThreadLocal<DataSources>(){ @Override protected DataSources initialValue(){ return DataSources.MASTER; } }; public static DataSources get(){ return dataSourceTypes.get(); } public static void set(DataSources dataSourceType){ dataSourceTypes.set(dataSourceType); } public static void reset(){ dataSourceTypes.set(DataSources.MASTER0); }} 3）定義ThreadLocalRountingDataSource，繼承AbstractRoutingDataSource：
package net.aazj.util; import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; public class ThreadLocalRountingDataSource extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() { return DataSourceTypeManager.get(); }}4）在配置文件中向ThreadLocalRountingDataSource 注入master 和slave 的數據源：
<context:component-scan base-package="net.aazj.service,net.aazj.aop" /><context:component-scan base-package="net.aazj.aop" /><!-- 引入屬性文件--><context:property-placeholder location="classpath:config/db.properties" /> <!-- 配置數據源Master --><bean name="dataSourceMaster" init-method="init" destroy-method="close"> <property name="url" value="${jdbc_url}" /> <property name="username" value="${jdbc_username}" /> <property name="password" value="${jdbc_password}" /> <!-- 初始化連接大小--> <property name="initialSize" value="0" /> <!-- 連接池最大使用連接數量--> <property name="maxActive" value="20" /> <!-- 連接池最大空閒--> <property name="maxIdle" value="20" /> <!-- 連接池最小空閒--> <property name="minIdle" value="0" /> <!-- 獲取連接最大等待時間--> <property name="maxWait" value="60000" /></bean> <!-- 配置數據源Slave --><bean name="dataSourceSlave" init-method="init" destroy-method="close"> <property name="url" value="${jdbc_url_slave}" /> <property name="username" value="${jdbc_username_slave}" /> <property name="password" value="${jdbc_password_slave}" /> <!-- 初始化連接大小--> <property name="initialSize" value="0" /> <!-- 連接池最大使用連接數量--> <property name="maxActive" value="20" /> <!-- 連接池最大空閒--> <property name="maxIdle" value="20" /> <!-- 連接池最小空閒--> <property name="minIdle" value="0" /> <!-- 獲取連接最大等待時間--> <property name="maxWait" value="60000" /></bean> <bean id="dataSource"> <property name="defaultTargetDataSource" ref="dataSourceMaster" /> <property name="targetDataSources"> <map key-type="net.aazj.enums.DataSources"> <entry key="MASTER" value-ref="dataSourceMaster"/> <entry key="SLAVE" value-ref="dataSourceSlave"/> <!-- 這裡還可以加多個dataSource --> </map> </property></bean> <bean id="sqlSessionFactory"> <property name="dataSource" ref="dataSource" /> <property name="configLocation" value="classpath:config/mybatis-config.xml" /> <property name="mapperLocations" value="classpath*:config/mappers/**/*.xml" /></bean> <!-- Transaction manager for a single JDBC DataSource --><bean id="transactionManager"> <property name="dataSource" ref="dataSource" /></bean> <!-- 使用annotation定義事務--><tx:annotation-driven transaction-manager="transactionManager" /> <bean> <property name="basePackage" value="net.aazj.mapper" /> <!-- <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> --></bean>上面spring的配置文件中，我們針對master數據庫和slave數據庫分別定義了dataSourceMaster和dataSourceSlave兩個dataSource，然後注入到<bean id="dataSource"> 中，這樣我們的dataSource就可以來根據key 的不同來選擇dataSourceMaster和dataSourceSlave了。
5）使用Spring AOP 來指定dataSource 的key ，從而dataSource會根據key選擇dataSourceMaster 和dataSourceSlave：
package net.aazj.aop; import net.aazj.enums.DataSources;import net.aazj.util.DataSourceTypeManager; import org.aspectj.lang.JoinPoint;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.annotation.Before;import org.aspectj.lang.annotation.Pointcut;import org.springframework.stereotype.Component; @Aspect // for aop@Component // for auto scanpublic class DataSourceInterceptor { @Pointcut("execution(public * net.aazj.service..*.getUser(..))") public void dataSourceSlave(){}; @Before("dataSourceSlave()") public void before(JoinPoint jp) { DataSourceTypeManager.set(DataSources.SLAVE); } // ... ...}這裡我們定義了一個Aspect 類，我們使用@Before 來在符合@Pointcut("execution(public * net.aazj.service..*.getUser(..))") 中的方法被調用之前，調用DataSourceTypeManager.set(DataSources.SLAVE) 設置了key 的類型為DataSources.SLAVE，所以dataSource 會根據key=DataSources.SLAVE 選擇dataSourceSlave 這個dataSource。所以該方法對於的sql語句會在slave數據庫上執行。
我們可以不斷的擴充DataSourceInterceptor 這個Aspect，在中進行各種各樣的定義，來為某個service的某個方法指定合適的數據源對應的dataSource。
這樣我們就可以使用Spring AOP 的強大功能來，十分靈活進行配置了。
6）AbstractRoutingDataSource原理剖析
ThreadLocalRountingDataSource 繼承了AbstractRoutingDataSource， 實現其抽象方法protected abstract Object determineCurrentLookupKey(); 從而實現對不同數據源的路由功能。我們從源碼入手分析下其中原理：
public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBeanAbstractRoutingDataSource 實現了InitializingBean 那麼spring在初始化該bean時，會調用InitializingBean的接口void afterPropertiesSet() throws Exception; 我們看下AbstractRoutingDataSource是如何實現這個接口的： @Override public void afterPropertiesSet() { if (this.targetDataSources == null) { throw new IllegalArgumentException("Property 'targetDataSources' is required"); } this.resolvedDataSources = new HashMap<Object, DataSource>(this.targetDataSources.size()); for (Map.Entry<Object, Object> entry : this.targetDataSources.entrySet()) { Object lookupKey = resolveSpecifiedLookupKey(entry.getKey()); DataSource dataSource = resolveSpecifiedDataSource(entry.getValue()); this.resolvedDataSources.put(lookupKey, dataSource); } if (this.defaultTargetDataSource != null) { this.resolvedDefaultDataSource = resolveSpecifiedDataSource(this.defaultTargetDataSource); } } targetDataSources 是我們在xml配置文件中註入的dataSourceMaster 和dataSourceSlave. afterPropertiesSet方法就是使用注入的。
dataSourceMaster 和dataSourceSlave來構造一個HashMap――resolvedDataSources。方便後面根據key 從該map 中取得對應的dataSource。
我們在看下AbstractDataSource 接口中的Connection getConnection() throws SQLException; 是如何實現的：
@Override public Connection getConnection() throws SQLException { return determineTargetDataSource().getConnection(); }關鍵在於determineTargetDataSource()，根據方法名就可以看出，應該此處就決定了使用哪個dataSource ：
protected DataSource determineTargetDataSource() { Assert.notNull(this.resolvedDataSources, "DataSource router not initialized"); Object lookupKey = determineCurrentLookupKey(); DataSource dataSource = this.resolvedDataSources.get(lookupKey); if (dataSource == null && (this.lenientFallback || lookupKey == null)) { dataSource = this.resolvedDefaultDataSource; } if (dataSource == null) { throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]"); } return dataSource;} Object lookupKey = determineCurrentLookupKey(); 該方法是我們實現的，在其中獲取ThreadLocal中保存的key 值。獲得了key之後，在從afterPropertiesSet()中初始化好了的resolvedDataSources這個map中獲得key對應的dataSource。而ThreadLocal中保存的key 值是通過AOP的方式在調用service中相關方法之前設置好的。 OK，到此搞定！
3. 總結
從本文中我們可以體會到AOP的強大和靈活。
以上就是sping，mybatis 多數據源處理的資料整理，希望能幫助有需要的朋友