在很多大型應(yīng)用中都會(huì)對(duì)數(shù)據(jù)進(jìn)行切分，并且采用多個(gè)數(shù)據(jù)庫(kù)實(shí)例進(jìn)行管理，這樣可以有效提高系統(tǒng)的水平伸縮性。而這樣的方案就會(huì)不同于常見的單一數(shù)據(jù)實(shí)例的方案，這就要程序在運(yùn)行時(shí)根據(jù)當(dāng)時(shí)的請(qǐng)求及系統(tǒng)狀態(tài)來(lái)動(dòng)態(tài)的決定將數(shù)據(jù)存儲(chǔ)在哪個(gè)數(shù)據(jù)庫(kù)實(shí)例中，以及從哪個(gè)數(shù)據(jù)庫(kù)提取數(shù)據(jù)。

 

Figure 1 數(shù)據(jù)分割及多數(shù)據(jù)庫(kù)架構(gòu)

    通常這種多數(shù)據(jù)源的邏輯會(huì)滲透到業(yè)務(wù)邏輯中，同時(shí)也會(huì)給我們使用的數(shù)據(jù)訪問(wèn)API諸如Hibernate和iBatis等帶來(lái)不便（需要指定多個(gè)SessionFactory或SqlMapClient實(shí)例來(lái)對(duì)應(yīng)多個(gè)DataSource）。

Figure 2 多數(shù)據(jù)源的選擇邏輯滲透至客戶端

 

    解決方案

Figure 3 采用Proxy模式來(lái)封裝數(shù)據(jù)源選擇邏輯

    通過(guò)采用Proxy模式我們?cè)诜桨钢袑?shí)現(xiàn)一個(gè)虛擬的數(shù)據(jù)源，并且用它來(lái)封裝數(shù)據(jù)源選擇邏輯，這樣就可以有效地將數(shù)據(jù)源選擇邏輯從Client中分離出來(lái)。

    Client提供選擇所需的上下文（因?yàn)檫@是Client所知道的），由虛擬的DataSource根據(jù)Client提供的上下文來(lái)實(shí)現(xiàn)數(shù)據(jù)源的選擇。

    Spring2.x的版本中提供了實(shí)現(xiàn)這種方式的基本框架，虛擬的DataSource僅需繼承AbstractRoutingDataSource實(shí)現(xiàn)determineCurrentLookupKey（）在其中封裝數(shù)據(jù)源的選擇邏輯。

    實(shí)例：

publicclass DynamicDataSource extends AbstractRoutingDataSource {       static Logger log = Logger.getLogger("DynamicDataSource");       @Override       protected Object determineCurrentLookupKey() {             String userId=(String)DbContextHolder.getContext();             Integer dataSourceId=getDataSourceIdByUserId(userId);             return dataSourceId;       } }

    實(shí)例中通過(guò)UserId來(lái)決定數(shù)據(jù)存放在哪個(gè)數(shù)據(jù)庫(kù)中。

    配置文件示例：

<bean id="dataSource" class="com.bitfone.smartdm.datasource.DynamicDataSource">               <property name="targetDataSources">                  <map key-type="java.lang.Integer">                     <entry key="0" value-ref="dataSource0"/>                     <entry key="1" value-ref="dataSource1"/>                     <entry key="2" value-ref="dataSource2"/>                  </map>               </property>               <property name="defaultTargetDataSource" ref="dataSource0"/>             </bean>             <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">                 <property name="configLocation" value="classpath:com/bitfone/smartdm/dao/sqlmap/sql-map-config.xml"/>                 <property name="dataSource" ref="dataSource"/>            </bean>             <bean id="UserInfoDAO" class="com.bitfone.smartdm.dao.impl.UserInfoDAO">                     <property name="sqlMapClient" ref="sqlMapClient"/>             </bean>