Spring 多数据源连接配置解决方案

野性酷女 2022-06-15 07:59 193阅读 0赞

List：

1.需求  
2.实现  
3.总结

# ……1.需求…… #

数据库实例的管理和配置一般都是使用spring框架。项目中需要切换多个数据库，动态切换，在编码过程中，决定在哪个DB中写入或读取数据。还有，在大型应用中对数据进行切分，也是采用多个数据库实例进行管理，这样可以有效提高系统的水平伸缩性。所以spring提供AbstractRoutingDataSource为我们管理多个数据库实例。

# ……2.实现…… #

1.spring配置文件中配置数据库实例们

<bean id="ds_ResourceManagementSystemPlat" class="org.apache.tomcat.jdbc.pool.DataSource">
    		<property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
    		<property name="url" value="jdbc:sqlserver://ip:port;databaseName=ResourceManagementSystemPlat" />
    		<property name="username" value="sa"/>
    		<property name="password" value="pwd"/>
    		
        	<property name="maxIdle" value="10" />
        	
        	<property name="minIdle" value="10" />
        	
        	<property name="maxActive" value="10" />
    	    
    	    <property name="maxWait" value="10000" />
    	    
    	    <property name="initialSize" value="10" />
    	    
    	    <property name="removeAbandoned" value="true" />
    	    
    	    <property name="removeAbandonedTimeout" value="600" />
    	    
    	    <property name="validationQuery" value="select 1" />
    	    
    	    <property name="validationInterval" value="30000" />
    	    
    	    <property name="defaultAutoCommit" value="true" />
    	    
    	    <property name="testWhileIdle" value="true" />
    	    
    	    <property name="timeBetweenEvictionRunsMillis" value="1200000" />
    	    
    	    <property name="minEvictableIdleTimeMillis" value="1800000" />
    	    
    	    <property name="numTestsPerEvictionRun" value="5" />
    	</bean>
    	
    	<bean id="ds_TradeRoad" class="org.apache.tomcat.jdbc.pool.DataSource">
    		<property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
    		<property name="url" value="jdbc:sqlserver://ip:port;databaseName=TradeRoad" />
    		<property name="username" value="sa"/>
    		<property name="password" value="pwd"/>
    		
        	<property name="maxIdle" value="10" />
        	
        	<property name="minIdle" value="10" />
        	
        	<property name="maxActive" value="10" />
    	    
    	    <property name="maxWait" value="10000" />
    	    
    	    <property name="initialSize" value="10" />
    	    
    	    <property name="removeAbandoned" value="true" />
    	    
    	    <property name="removeAbandonedTimeout" value="600" />
    	    
    	    <property name="validationQuery" value="select 1" />
    	    
    	    <property name="validationInterval" value="30000" />
    	    
    	    <property name="defaultAutoCommit" value="true" />
    	    
    	    <property name="testWhileIdle" value="true" />
    	    
    	    <property name="timeBetweenEvictionRunsMillis" value="1200000" />
    	    
    	    <property name="minEvictableIdleTimeMillis" value="1800000" />
    	    
    	    <property name="numTestsPerEvictionRun" value="5" />
    	</bean>
    	
    	<bean id="ds_TradeRoad_APP" class="org.apache.tomcat.jdbc.pool.DataSource">
    		<property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
    		<property name="url" value="jdbc:sqlserver://ip:port;databaseName=TradeRoadAPP" />
    		<property name="username" value="sa"/>
    		<property name="password" value="pwd"/>
    		
        	<property name="maxIdle" value="10" />
        	
        	<property name="minIdle" value="10" />
        	
        	<property name="maxActive" value="10" />
    	    
    	    <property name="maxWait" value="10000" />
    	    
    	    <property name="initialSize" value="10" />
    	    
    	    <property name="removeAbandoned" value="true" />
    	    
    	    <property name="removeAbandonedTimeout" value="600" />
    	    
    	    <property name="validationQuery" value="select 1" />
    	    
    	    <property name="validationInterval" value="30000" />
    	    
    	    <property name="defaultAutoCommit" value="true" />
    	    
    	    <property name="testWhileIdle" value="true" />
    	    
    	    <property name="timeBetweenEvictionRunsMillis" value="1200000" />
    	    
    	    <property name="minEvictableIdleTimeMillis" value="1800000" />
    	    
    	    <property name="numTestsPerEvictionRun" value="5" />
    	</bean>

2.编写spring配置文件配置多数据源映射关系

<bean id="dataSource" class="com.jczb.trApp.teacher.datasource.DynamicDataSource">
    		<property name="targetDataSources">
    			<map key-type="java.lang.String">
    				<entry value-ref="ds_ResourceManagementSystemPlat" key="ds_ResourceManagementSystemPlat"></entry>
    				<entry value-ref="ds_TradeRoad" key="ds_TradeRoad"></entry>
    				<entry value-ref="ds_TradeRoad_APP" key="ds_TradeRoad_APP"></entry>
    			</map>
    		</property>
    		
    		<property name="defaultTargetDataSource" ref="ds_TradeRoad"></property>      
    	</bean>

3.建立数据库名称常量类

public class DataSourceType {
    	public static final String SOURCE_RMSP = "ds_ResourceManagementSystemPlat";
    	public static final String SOURCE_TR = "ds_TradeRoad";
    	public static final String SOURCE_TRAPP = "ds_TradeRoad_APP";
    }

4.建立一个改变数据库实例的上下文类

ThreadLocal是解决线程安全问题一个很好的思路，它通过为每个线程提供一个独立的变量副本解决了变量并发访问的冲突问题。在很多情况下，ThreadLocal比直接使用synchronized同步机制解决线程安全问题更简单，更方便，且结果程序拥有更高的并发性。

public class DataSourceContextHolder {
    	private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
    
    
    	public static void setDbType(String dbType) {
    		contextHolder.set(dbType);
    	}
    
    
    	public static String getDbType() {
    		return ((String) contextHolder.get());
    	}
    
    
    	public static void clearDbType() {
    		contextHolder.remove();
    	}
    }

5.建立动态数据源类

AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是实现数据源的route的核心。

public class DynamicDataSource extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() { return DataSourceContextHolder.getDbType(); } }

# ……3.总结…… #

优点：改动不大，还是用spring配置，可以兼容单数据实例和多数据实例，因为可以指定一个缺省的。便于维护。  
         But，缺点是，当多用户访问时，多数据源可能会导致系统性能下降。引起资源的争抢。  
  
  
  
  
          当初做权限的时候还不知道这个用法，学习了。