1.首先需要一個 資料來源型別的類。

 public enum DBType {
      dataSource, frontDataSource;
}

2.需要一個本地執行緒變數物件儲存 資料來源型別，這裡使用的 是ThreadLocal，因為ThreadLocal 可以為每個執行緒單獨創立一個新的副本變數。
public class ContextHolder {
    private static final ThreadLocal<Object> holder = new ThreadLocal<Object>();

    public static void setDbType(DBType dbType) {
        holder.set(dbType);
    }

    public static DBType getDbType() {
        return (DBType) holder.get();
    }

    public static void clearDbType() {
        holder.remove();
    }
}

3.需要一個動態資料來源類用於代替之前的 dataSource bean，這個類需要繼承AbstractRoutingDataSource，並且重寫 determineCurrentLookupKey 方法，返回本地執行緒變數中儲存的 資料來源型別key。

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    protected Object determineCurrentLookupKey() {
        DBType key = ContextHolder.getDbType();//獲得當前資料來源識別符號
        System.out.println("當前資料來源 :" + key);
        return key;
    }

}

4.需要一個攔截器，該攔截器可以根據實際情況進行配置，我這裡是攔截 service根據方法名稱去切換資料來源，這裡切記：

[email protected](1) 這個值必須有，因為資料來源的獲取也是通過攔截器中獲取的，這個地方攔截器優先順序必須高過資料來源獲取的攔截器。

[email protected]  註解 需要在application.xml 配置啟用

    <context:component-scan base-package="com">
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller" />
    </context:component-scan>
    <!-- -開啟 aspect 註解使用 -->
    <aop:aspectj-autoproxy />

import java.lang.reflect.Method;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
 
/**
 *  aop實現動態切換資料來源
 *
 */  
@Aspect  
@Component
@Order(1)
public class DataSourceAopProxy {  
 
    @Before("dataSourcePoint()")
    public  void setDataSource(JoinPoint joinPoint){  
        
        Signature signature = joinPoint.getSignature();  
        MethodSignature methodSignature = (MethodSignature) signature;  
        Method method = methodSignature.getMethod();  
        
        //此處進行切換資料來源   根據業務條件   獲取資料來源id  
        if(method.getName().contains("Front")){
             ContextHolder.setDbType(DBType.frontDataSource);
            
            
             System.out.println("設定當前資料來源 DBType.frontDataSource");
        }else{
             ContextHolder.setDbType(DBType.dataSource);
            
             System.out.println("設定當前資料來源 DBType.dataSource");
        }
    
        
       
    }  
 
    
    @After("dataSourcePoint()")
    public  void after(JoinPoint joinPoint){  
        
        System.out.println("清除 DB type！");
        ContextHolder.clearDbType();
    }  
    
    
    //@Pointcut("execution(* com.dao.impl.*.*(..))")
    @Pointcut("execution(* com.service.impl.*.*(..))")
    private void dataSourcePoint(){  
       
    }
}

5.需要配置兩個資料來源和上面的資料來源型別對應，我這裡${jdbc.url}是讀取的屬性檔案，你們可以在這裡直接寫值

<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
        <property name="driverClass" value="${jdbc.driver}" />
        <property name="jdbcUrl" value="${jdbc.url}" />
        <property name="user" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
        <property name="initialPoolSize" value="${connection_pools.initial_pool_size}" />
        <property name="minPoolSize" value="${connection_pools.min_pool_size}" />
        <property name="maxPoolSize" value="${connection_pools.max_pool_size}" />
        <property name="maxIdleTime" value="${connection_pools.max_idle_time}" />
        <property name="acquireIncrement" value="${connection_pools.acquire_increment}" />
        <property name="checkoutTimeout" value="${connection_pools.checkout_timeout}" />
    </bean>
    
    
    <bean id="frontDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
        <property name="driverClass" value="${front.jdbc.driver}" />
        <property name="jdbcUrl" value="${front.jdbc.url}" />
        <property name="user" value="${front.jdbc.username}" />
        <property name="password" value="${front.jdbc.password}" />
        <property name="initialPoolSize" value="${connection_pools.initial_pool_size}" />
        <property name="minPoolSize" value="${connection_pools.min_pool_size}" />
        <property name="maxPoolSize" value="${connection_pools.max_pool_size}" />
        <property name="maxIdleTime" value="${connection_pools.max_idle_time}" />
        <property name="acquireIncrement" value="${connection_pools.acquire_increment}" />
        <property name="checkoutTimeout" value="${connection_pools.checkout_timeout}" />
    </bean>

6.需要 修改 bean為entityManagerFactory的配置,其中將dataSource屬性配置為 mysqlDynamicDataSource，如下：

    <property name="dataSource" ref="mysqlDynamicDataSource" />

7.最後一步，配置 bean mysqlDynamicDataSource，對應上一步。

a.此處bean中targetDataSources 為目標資料來源，key-type 值為資料來源型別類，也就是第一條那個列舉。

b.map 中的key  對應的是資料來源型別中的 兩個列舉值，value-ref 則是第五條 配置的兩個bean。

c.defaultTargetDataSource 為預設的資料來源型別，就是本地執行緒變數中值 為null而預設的資料來源物件。   

     <bean id="mysqlDynamicDataSource" class="com.titanos.dynamic.DynamicDataSource">
        <property name="targetDataSources">
            <!-- 識別符號型別 -->
            <map key-type="com.dynamic.DBType">
                <entry key="dataSource" value-ref="dataSource"/>
                <entry key="frontDataSource" value-ref="frontDataSource"/>
            </map>
        </property>
        <property name="defaultTargetDataSource" ref="dataSource"/>
    </bean>