spring控制数据库读写分离(多数据源动态切换)

问题描述:

项目一直是使用同一个数据库进行读和写的操作,在写操作时会锁表,并且效率低,后期出现性能问题

原因描述:

项目只能操作一个数据源

需求描述:

配置多个数据源,利用切面进行动态切换

解决方案:

修改配置,并且增加切面进行自动控制

解决方式:

第一步:配置多个数据源:

 数据源1

<!-- 数据源 -->

<bean id="DataSource1" class="com.alibaba.druid.pool.DruidDataSource"

init-method="init" destroy-method="close">

<property name="driverClassName" value="${jdbc.driverClass}" />

<property name="url" value="${jdbc.url}" />

<property name="username" value="${jdbc.user}" />

<property name="password" value="${jdbc.password}" />

<property name="filters" value="stat" />

<property name="maxActive" value="1000" />

<property name="initialSize" value="1" />

<property name="maxWait" value="80000" />

<property name="minIdle" value="1" />

<!-- 超过时间限制是否回收 -->

<property name="removeAbandoned" value="true" />

<!-- 超时时间;单位为秒。120秒=2分钟 -->

<property name="removeAbandonedTimeout" value="120" />

<!-- 关闭abanded连接时输出错误日志 -->

<!-- <property name="logAbandoned" value="true" /> -->

<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="defaultAutoCommit" value="true" />

</bean>

数据源2

<!-- 数据源 -->

<bean id="DataSource2" class="com.alibaba.druid.pool.DruidDataSource"

init-method="init" destroy-method="close">

<property name="driverClassName" value="${jdbc.driverClass}" />

<property name="url" value="${jdbc.url2}" />

<property name="username" value="${jdbc.user}" />

<property name="password" value="${jdbc.password}" />

<property name="filters" value="stat" />

<property name="maxActive" value="1000" />

<property name="initialSize" value="1" />

<property name="maxWait" value="80000" />

<property name="minIdle" value="1" />

<!-- 超过时间限制是否回收 -->

<property name="removeAbandoned" value="true" />

<!-- 超时时间;单位为秒。120秒=2分钟 -->

<property name="removeAbandonedTimeout" value="120" />

<!-- 关闭abanded连接时输出错误日志 -->

<!-- <property name="logAbandoned" value="true" /> -->

<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="defaultAutoCommit" value="true" />

</bean>

第二步:配置选择数据源的bean

a.配置数据源切换的bean

<bean id="dataSource" class="com.zsrt.devbase.datesource.DynamicDataSource">

<property name="targetDataSources">

<map key-type="java.lang.String">

<entry value-ref="DataSource1" key="testDataSource1"></entry>

<entry value-ref="DataSource2" key="testDataSource2"></entry>

</map>

</property>

<property name="defaultTargetDataSource" ref="testDataSource1" />

</bean>

 class 为自定义的数据源切换控制的bean

在map中,key指向的是后台需要选择的数据源名称,value指向的是第一步配置的数据源id


b.编写切换控制器

/**

* 数据源的切换与选择器

* @author leixin

* @Date 2017年4月19日

* @version 1.0

*/

public class DataSourceContextHolder {

private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();

/**

* @Description: 设置数据源类型

* @param dataSourceType 数据库类型

* @return void

* @throws

*/

public static void setDataSourceType(String dataSourceType) {

System.err.println(dataSourceType);

contextHolder.set(dataSourceType);

}

/**

* @Description: 获取数据源类型

* @param

* @return String

* @throws

*/

public static String getDataSourceType() {

return contextHolder.get();

}

/**

* @Description: 清除数据源类型

* @param

* @return void

* @throws

*/

public static void clearDataSourceType() {

contextHolder.remove();

}

}

c.编写切换控制器

public class DynamicDataSource extends AbstractRoutingDataSource {

@Override

protected Object determineCurrentLookupKey() {

return DataSourceContextHolder.getDataSourceType();

}

}

以上步骤已经完成数据库的手动切换,在控制层可以手动切换。

具体切换方法为:当需要调用数据源A时,用静态的类去设置数据源A的名字,然后再去调用service




问题:每次都需要手动切换,有点麻烦,因此想到利用切面控制

在上面的基础上利用切面控制,最先想到的是切面控制service,但是控制service会和事务控制切面产生冲突(原因是事务需要锁定数据源的链接,而当前的数据源链接还没有进行动态切换,所以只能选择默认的数据源,从而导致切换失败)


思路一:

于是想到切面切入点为控制层,在开启事务之前就切换数据源。

思路二:

      利用@order注解控制切面的执行顺序


经过上面的分析,思路二明显优于思路一,于是开始尝试思路二,在思路二的基础上,打算开启注解切入


第一步:自定义切面注解:     

@Target(ElementType.METHOD)

@Retention(RetentionPolicy.RUNTIME)

public @interface DataSource {

}

第二步:编写切面:

@Aspect

@Order(0)

public class DataSourceAspect{

@AfterReturning("execution(* com.zsrt.devbase.service.*.*(..))")

public void afterReturning() throws Throwable {

DataSourceContextHolder.clearDataSourceType();

}

@Before("execution(* com.zsrt.devbase.service.*.*(..)) && @annotation(com.zsrt.devbase.annotation.DataSource)")

public void before(JoinPoint jp) throws Throwable {

DataSourceContextHolder.setDataSourceType("testDataSource2");

}

}


第三步:配置事务切面的执行顺序:


<aop:config>

<!-- 切点表达式:所有的service类中的方法都会有事务 -->

<aop:pointcut id="appService"

expression="execution(* com.zsrt.devbase.service.*Service*.*(..))" />

<aop:advisor advice-ref="txAdvice" pointcut-ref="appService" order="1" />

</aop:config>

结果:

经测试,程序按照预期进行执行:

先切换了数据源,然后开启了事务,最后再执行了别的切面

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


原文:https://blog.csdn.net/leixin821792669/article/details/70242397

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,362评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,330评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,247评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,560评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,580评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,569评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,929评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,587评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,840评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,596评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,678评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,366评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,945评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,929评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,165评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,271评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,403评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,580评论 18 139
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,560评论 18 399
  • IoC 容器 Bean 的作用域 自定义作用域实现 org.springframework.beans.facto...
    Hsinwong阅读 2,450评论 0 7
  • 我是一位即将要小升初孩子的妈妈,“小升初”这个词在很多省有一个再普通不过的意思,但是在我们这里对于很多家...
    桐熹阅读 666评论 0 1