springMvc多数据源配置及使用

秒速五厘米 2022-05-17 10:53 258阅读 0赞

--------------------

\*\*查询数据库的时候，有增删改查。  
实际运用中，很多时候会遇到一些慢查询，如果用查询主库，会导致锁表等，导致用户端使用时很卡。  
为了解决此类问题，配置多个数据源，去主库做增加、修改操作，去从库查询数据（从库查询速度慢）\*\*

--------------------

下面配置以springMvc配置多个数据源为例

*  \-

## applicationContext.xml ##

1.  配置数据源
2.  配置数据源使用的切面
3.  配置service使用哪个数据源

<bean id="masterDataSource" class="com.alibaba.druid.pool.DruidDataSource">
            <property name="url" value="${jdbc.url}" />
            <property name="driverClassName" value="${jdbc.driver}" />
            <property name="maxActive" value="${pool.maxPoolSize}" />
            <property name="username" value="${jdbc.username}" />
            <property name="password" value="${jdbc.password}" />
            
            <property name="removeAbandoned" value="true" />
            
            <property name="removeAbandonedTimeout" value="${pool.removeAbandonedTimeout}" />
            
            <property name="maxWait" value="${pool.maxWait}" />
            
            <property name="timeBetweenEvictionRunsMillis" value="${pool.timeBetweenEvictionRunsMillis}" />
            
            <property name="minEvictableIdleTimeMillis" value="${pool.minEvictableIdleTimeMillis}" />
            <property name="validationQuery" value="${pool.validationQuery} " />
            <property name="testWhileIdle" value="true" />
            <property name="testOnBorrow" value="false" />
            <property name="testOnReturn" value="false" />
        </bean>
    
        
        <bean id="slaveDataSource" class="com.alibaba.druid.pool.DruidDataSource">
            <property name="url" value="${slave.jdbc.url}" />
            <property name="driverClassName" value="${slave.jdbc.driver}" />
            <property name="maxActive" value="${slave.pool.maxPoolSize}" />
            <property name="username" value="${slave.jdbc.username}" />
            <property name="password" value="${slave.jdbc.password}" />
            
            <property name="removeAbandoned" value="true" />
            
            <property name="removeAbandonedTimeout" value="${slave.pool.removeAbandonedTimeout}" />
            
            <property name="maxWait" value="${slave.pool.maxWait}" />
            
            <property name="timeBetweenEvictionRunsMillis" value="${slave.pool.timeBetween}" />
            
            <property name="minEvictableIdleTimeMillis" value="${slave.pool.minEvictableIdleTimeMillis}" />
            <property name="validationQuery" value="${slave.pool.validationQuery} " />
            <property name="testWhileIdle" value="true" />
            <property name="testOnBorrow" value="false" />
            <property name="testOnReturn" value="false" />
        </bean>
    
        
        <bean id="dataSourceAspect" class="cn.xxx.common.util.slave.DataSourceAspect" />
        <aop:config>
            <aop:aspect id="dataSourceAspect" ref="dataSourceAspect" order="-999">
                <aop:pointcut id="ds" expression="execution(* cn.xxx.service..*.*(..)) and !execution(* cn.xxx.service.XXXXService.*(..)) "/>
                <aop:before pointcut-ref="ds" method="before" />
                <aop:after pointcut-ref="ds" method="after"/>
            </aop:aspect>
        </aop:config>
    
        
        <bean id="dataSource" class="cn.xxx.common.util.slave.DynamicDataSource">
            <property name="targetDataSources">
                <map key-type="java.lang.String">
                    <entry key="slave" value-ref="slaveDataSource"/>
                    <entry key="master" value-ref="masterDataSource"/>
                </map>
            </property>
            
            <property name="defaultTargetDataSource" ref="masterDataSource"/>
        </bean>

## DynamicDataSource.java ##

此类是通过service类的中注解DataSource来确认具体使用哪一个数据源

package cn.xxx.service;
    
    import lombok.extern.slf4j.Slf4j;
    import org.aspectj.lang.JoinPoint;
    import org.aspectj.lang.reflect.MethodSignature;
    
    import java.lang.reflect.Method;
    
    @Slf4j
    public class DataSourceAspect { 
    
        /** * 在dao层方法获取datasource对象之前，在切面中指定当前线程数据源 */
        public void before(JoinPoint point) {
            Class<?>[] parameterTypes = ((MethodSignature)point.getSignature()).getMethod().getParameterTypes();
            Method method = null;
            try {
                method = point.getTarget().getClass().getDeclaredMethod(point.getSignature().getName(), parameterTypes);
                if (method != null && method.isAnnotationPresent(DataSource.class)) {
                    DataSource data = method.getAnnotation(DataSource.class);
                    log.debug("用户选择数据库库类型： {}", data.value());
                    HandleDataSource.putDataSource(data.value()); // 数据源放到当前线程中
                }
            } catch (Exception e) {
                log.error("aop分配数据源异常", e);
            }
        }
        public void after(JoinPoint joinPoint) throws Throwable {
            HandleDataSource.removeDataSource();
        }
    
    }

## HandleDataSource.java ##

对当前数据源的进行管理的类

public class HandleDataSource { 
    
        public static final ThreadLocal<String> holder = new ThreadLocal<String>();
    
        /** * 绑定当前线程数据源 * * @param datasource */
        public static void putDataSource(String datasource) {
            holder.set(datasource);
        }
    
        /** * 获取当前线程的数据源 * * @return */
        public static String getDataSource() {
            return holder.get();
        }
    
        public static void removeDataSource(){
            holder.remove();
        }
    
    }

## DynamicDataSource.java ##

获取当前线程的数据源

package cn.yhb.common.util.slave;
    
    import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
    
    
    public class DynamicDataSource extends AbstractRoutingDataSource { 
    
        /** * 获取与数据源相关的key 此key是Map<String,DataSource> resolvedDataSources 中与数据源绑定的key值 * 在通过determineTargetDataSource获取目标数据源时使用 */
        @Override
        protected Object determineCurrentLookupKey() {
            return HandleDataSource.getDataSource();
        }
    }

## Service使用 ##

@Service
    @Slf4j
    public class TestService { 
    
        @Resource
        private XXXXDao dao;
    
        @DataSource("slave")
        public User export(Integer id) {
            User user = dao.getByid(id);
            return user ;
        }
    }

文章写的有些简单，有什么疑问，请留言！谢谢