spring框架多数据源切换问题的解决

Spring动态配置多数据源，即在大型应用中对数据进行切分，并且采用多个数据库实例进行管理，这样可以有效提高系统的水平伸缩性。而这样的方案就会不同于常见的单一数据实例的方案，这就要程序在运行时根据当时的请求及系统状态来动态的决定将数据存储在哪个数据库实例中，以及从哪个数据库提取数据。

Spring配置多数据源的方式和具体使用过程。
Spring对于多数据源，以数据库表为参照，大体上可以分成两大类情况：
一是，表级上的跨数据库。即，对于不同的数据库却有相同的表（表名和表结构完全相同）。
二是，非表级上的跨数据库。即，多个数据源不存在相同的表。

1、根据用户的选择，使用不同的数据源。

2、解决思路锁定：将sessionFactory的属性dataSource设置成不同的数据源，以达到切换数据源的目的。

3、问题产生：因为整个项目用的几乎都是单例模式，当多个用户并发访问数据库的时候，会产生资源争夺的问题。即项目启动时候，所有的bean都被装载到内存，并且每个bean都只有一个对象。正因为只有一个对象，所有的对象属性就如同静态变量（静态变量跟单例很相似，常用静态来实现单例）。整个项目系统的dataSource只有一个，如果很多用户不断的去改变dataSource的值，那必然会出现资源的掠夺问题，造成系统隐患。

4、多资源共享解决思路：同一资源被抢夺的时候，通常有两种做法，a、以时间换空间 b、以空间换时间。

5、线程同步机制就是典型的“以时间换空间”，采用排队稍等的方法，一个个等待，直到前面一个用完，后面的才跟上，多人共用一个变量，用synchronized锁定排队。

6、“ThreadLocal”就是典型的“以空间换时间”，她可以为每一个人提供一份变量，因此可以同时访问并互不干扰。

7、言归正传：sessionFactory的属性dataSource设置成不用的数据源，首先不能在配置文件中写死，我们必须为她单独写一个类，让她来引用这个类，在这个类中再来判断我们到底要选择哪个数据源。

spring + mybatis 多数据源切换

DbContextHolder.java

Java代码

package com.easyway.stage.commons;
public class DbContextHolder
{
// ThreadLocal是线程安全的，并且不能在多线程之间共享。
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();
}
}

MultiDataSource.java

Java代码

package com.easyway.stage.commons;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class MultiDataSource extends AbstractRoutingDataSource
{
@Override
protected Object determineCurrentLookupKey()
{
return DbContextHolder.getDbType();
}
}

applicationContext.xml

Xml代码

<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<context:annotation-config/>
<bean id="parentDataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="initialSize" value="1" />
<property name="maxActive" value="20" />
<property name="minIdle" value="1" />
<property name="maxWait" value="60000" />
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<property name="minEvictableIdleTimeMillis" value="300000" />
<property name="validationQuery" value="SELECT 'x'" />
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="false" />
<property name="testOnReturn" value="false" />
<property name="poolPreparedStatements" value="true" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
<property name="filters" value="wall,stat,slf4j" />
<property name="removeAbandoned" value="true" />
<property name="removeAbandonedTimeout" value="1800" />
<property name="logAbandoned" value="true" />
</bean>
<bean id="local" parent="parentDataSource" init-method="init" destroy-method="close">
<property name="url" value="${local.jdbc.url}" />
<property name="username" value="${local.jdbc.username}" />
<property name="password" value="${local.jdbc.password}" />
</bean>
<bean id="server" parent="parentDataSource" init-method="init" destroy-method="close">
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</bean>
<bean id="dataSource" class="com.autrade.stage.commons.MultiDataSource">
<property name="targetDataSources">
<map key-type="java.lang.String">
<entry value-ref="local" key="local"></entry>
<entry value-ref="server" key="server"></entry>
</map>
</property>
<property name="defaultTargetDataSource" ref="server"></property>
</bean>
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="configLocation" value="classpath:resources/mybatis/myBatisConfig.xml" />
<property name="mapperLocations" value="classpath:resources/mybatis/mapper/*.xml"/>
</bean>
<bean class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg ref="sqlSessionFactory"/>
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
<bean id="methodAdvisor" class="com.easyway.app.interceptor.InjectorManager" />
<aop:config proxy-target-class="true">
<aop:pointcut id="baseMethods"
expression="execution(* com.easyway.app.service..*.*(..))" />
<aop:advisor advice-ref="methodAdvisor" pointcut-ref="baseMethods" />
</aop:config>
</beans>

Test.java测试类

Java代码

package com.easyway.stage.test;
import javax.sql.DataSource;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.Resource;
import com.easyway.stage.commons.DbContextHolder;
public class Test
{
/**
* @param args
*/
public static void main(String[] args)
{
ApplicationContext appContext = new ClassPathXmlApplicationContext("client-beans.xml");
DbContextHolder.setDbType("local");
String res = "resources/mybatis/myBatisConfig.xml";
DataSource datasource = (DataSource) appContext.getBean("dataSource");
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(datasource);
Resource resource = new FileSystemResource(res);
bean.setConfigLocation(resource);
try
{
SqlSessionFactory sessionfactory = bean.getObject();
SqlSession session = sessionfactory.openSession();
User user = session.selectOne("com.easyway.mybatis.mapper.findOne");
System.out.println(user.getName());
}
catch (Exception e)
{
e.printStackTrace();
}
DbContextHolder.setDbType("server");
String res1 = "resources/mybatis/myBatisConfig.xml";
DataSource datasource1 = (DataSource) appContext.getBean("dataSource");
SqlSessionFactoryBean bean1 = new SqlSessionFactoryBean();
bean1.setDataSource(datasource1);
Resource resource1 = new FileSystemResource(res1);
bean1.setConfigLocation(resource1);
try
{
SqlSessionFactory sessionfactory = bean.getObject();
SqlSession session = sessionfactory.openSession();
User user = session.selectOne("com.easyway.mybatis.mapper.findOne");
System.out.println(user.getName());
}
catch (Exception e)
{
e.printStackTrace();
}
}
}

spring框架多数据源切换问题的解决相关推荐

spring+mybatis 多数据源切换
spring+mybatis 多数据源切换摘自: http://www.oschina.net/code/snippet_347813_12525 1. 代码: DbContextHolder pu ...
spring框架完整配置(后面)，以及解决No qualifying bean of type 或Error creating bean with name。。。
本人刚接触spring,被这问题活活困扰了两天,问题让人快速跳过这坑,特写下此文章共参考. 先说本文下出现的问题. 说下出问题的原因:这是因为我使用了两个spring的配置文件,而在web.xml配置 ...
Spring(AbstractRoutingDataSource)实现动态数据源切换
参考:http://linhongyu.blog.51cto.com/6373370/1615895 一.前言近期一项目A需实现数据同步到另一项目B数据库中,在不改变B项目的情况下,只好选择项目A中 ...
Spring(AbstractRoutingDataSource)实现动态数据源切换--转载
原始出处:http://linhongyu.blog.51cto.com/6373370/1615895 一.前言近期一项目A需实现数据同步到另一项目B数据库中,在不改变B项目的情况下,只好选择项目 ...
spring mysql 多数据源_spring框架学习【多数据源配置】
在我们的项目中遇到这样一个问题:我们的项目需要连接多个数据库,而且不同的客户在每次访问中根据需要会去访问不同的数据库.我们以往在spring和hibernate框架中总是配置一个数据源,因而sessi ...
spring boot多数据源动态切换, 多数据源事务管理
1 . 项目目标实现不同数据源的切换 (使用AbstractRoutingDataSource) 不同数据源之间,事物管理,多个数据源之间同时commit或者同时rollback 兼容不同的连接池 ...
spring 动态数据源切换实例
我们很多项目中业务都需要涉及到多个数据源,最简单的做法就是直接在java代码里面lookup需要的数据源,但是这样的做法很明显耦合度太高了, 而且当逻辑流程不够严谨的时候就会出现各种大家不愿意看到的问 ...
Spring Boot + Mybatis 配合 AOP 和注解实现动态数据源切换配置
Spring Boot + Mybatis 配合 AOP 和注解实现动态数据源切换配置前言: 1. 数据库准备: 2. 环境准备: 3.代码部分 4. 测试: 5.等等 6.配合注解实现 7 .测试 ...
spring boot+mybatis 多数据源切换
由于公司业务划分了多个数据库,开发一个项目会同时调用多个库,经过学习我们采用了注解+aop的方式实现的 1.首先定义一个注解类 @Retention(RetentionPolicy.RUNTIME) ...

spring框架多数据源切换问题的解决

spring框架多数据源切换问题的解决相关推荐

最新文章

热门文章