Spring+Mybatis 实现aop数据库读写分离与多数据库源配置操作

2023-09-24 20:45:05 44

在数据库层面大都采用读写分离技术，就是一个Master数据库，多个Slave数据库。Master库负责数据更新和实时数据查询，Slave库当然负责非实时数据查询。因为在实际的应用中，数据库都是读多写少（读取数据的频率高，更新数据的频率相对较少），而读取数据通常耗时比较长，占用数据库服务器的CPU较多，从而影响用户体验。我们通常的做法就是把查询从主库中抽取出来，采用多个从库，使用负载均衡，减轻每个从库的查询压力。

废话不多说，多数据源配置和主从数据配置原理一样

1、首先配置 jdbc.properties两个数据库A和B

#============双数据源======#
#----------------------Aservers--------------------------#
A.driver=com.mysql.jdbc.Driver
A.url=jdbc:mysql://localhost:3619/gps4?useUnicode=true&characterEncoding=utf8
A.username=gpsadmin
A.password=1qaz&619
#----------------------Bservers--------------------------#
B.driver=com.mysql.jdbc.Driver
B.url=jdbc:mysql://localhost:3619/gps6?useUnicode=true&characterEncoding=utf8
B.username=gpsadmin
B.password=1qaz&619

2、配置spring-mybatis.xml文件【重要】

3、编写几个java类动态调用数据源【重要】

a:自定义一个注解，负责动态调用数据源

packagecom.ifengSearch.common.database;
importjava.lang.annotation.*;
/**
*设置数据源注解标签的用法写上注解标签，
*调用相应方法切换数据源咯（就跟你设置事务一样）
*【也可以配置主从数据库】
*
*@authorflm
*@2017年9月12日
*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public@interfaceDataSource{
publicstaticStringdataSourceA="dataSourceA";//A数据源
publicstaticStringdataSourceB="dataSourceB";//B数据源
Stringvalue();
}

b、数据源的获取Object aop实现（反射）

packagecom.ifengSearch.common.database;
importjava.lang.reflect.Method;
importorg.apache.log4j.Logger;
importorg.aspectj.lang.JoinPoint;
importorg.aspectj.lang.reflect.MethodSignature;
/**
*数据源的获取
*aop实现（反射）
*@authorflm
*@2017年9月12日
*/
publicclassDataSourceAspect{
privateLoggerlog=Logger.getLogger(DataSourceAspect.class);
publicvoidbefore(JoinPointpoint)
{
Objecttarget=point.getTarget();//拦截的实体类
Stringmethod=point.getSignature().getName();//拦截的方法名称
Class[]classz=target.getClass().getInterfaces();
Class[]parameterTypes=((MethodSignature)point.getSignature())
.getMethod().getParameterTypes();//拦截的方法参数类型
try{
Methodm=classz[0].getMethod(method,parameterTypes);
if(m!=null&&m.isAnnotationPresent(DataSource.class)){
DataSourcedata=m
.getAnnotation(DataSource.class);
DataSourceHolder.setDataSource(data.value());
log.info("数据源的获取DataSource:"+data.value());
}
}catch(Exceptione){
log.error("数据源的获取aop实现出错："+e.getMessage());
}
}
}

c、DataSourceHolder 数据源操作获取数据源帮助类

packagecom.ifengSearch.common.database;
/**
*多数据源
*数据源操作获取数据源
*@authorflm
*@2017年9月12日
*/
publicclassDataSourceHolder{
//线程本地环境
privatestaticfinalThreadLocaldataSources=newThreadLocal();
//设置数据源
publicstaticvoidsetDataSource(StringcustomerType){
dataSources.set(customerType);
}
//获取数据源
publicstaticStringgetDataSource(){
return(String)dataSources.get();
}
//清除数据源
publicstaticvoidclearDataSource(){
dataSources.remove();
}
}

d、我们还需要实现spring的抽象类AbstractRoutingDataSource，就是实现determineCurrentLookupKey方法：

packagecom.ifengSearch.common.database;
importorg.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/**
*多数据源
*获取数据源（依赖于spring）
*@authorflm
*@2017年9月12日
*/
publicclassDynamicDataSourceextendsAbstractRoutingDataSource{
@Override
protectedObjectdetermineCurrentLookupKey(){
returnDataSourceHolder.getDataSource();
}
}

4、接下来就可以看结果了

我在dao层直接调用

publicinterfaceUserDao{
/**
*登录判断【数据源B】
*/
@DataSource(value=DataSource.dataSourceB)
publicListgetLoginUserList(@Param("loginName")StringloginName,@Param("loginPwd")StringloginPwd);
/**
*查找上一级服务商【数据源A】
*/
@DataSource(value=DataSource.dataSourceA)
publicUserBeangetServerUser(@Param("u_last_id")Integeru_last_id);
}

总结

以上所述是小编给大家介绍的Spring+Mybatis实现aop数据库读写分离与多数据库源配置操作，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！

Spring+Mybatis 实现aop数据库读写分离与多数据库源配置操作

热门推荐

随机推荐