使用Spring AOP实现MySQL数据库读写分离案例分析

1、前言

分布式环境下数据库的读写分离策略是解决数据库读写性能瓶颈的一个关键解决方案，更是最大限度了提升了应用中读取 （Read）数据的速度和并发量。

在进行数据库读写分离的时候，咱们首先要进行数据库的主从配置，最简单的是一台Master和一台Slave（大型网站系统的话，固然会很复杂，这里只是分析了最简单的状况）。经过主从配置主从数据库保持了相同的数据，咱们在进行读操做的时候访问从数据库Slave，在进行写操做的时候访问主数据库Master。这样的话就减轻了一台服务器的压力。

在进行读写分离案例分析的时候。首先，配置数据库的主从复制，下边是两种方法（任选其一便可）：

一、MySQL5.6 数据库主从（Master/Slave）同步安装与配置详解:

http://blog.csdn.net/xlgen157387/article/details/51331244

二、使用mysqlreplicate命令快速搭建 Mysql 主从复制:

http://blog.csdn.net/xlgen157387/article/details/52452394

固然，只是简单的为了看一下如何用代码的方式实现数据库的读写分离，彻底没必要要去配置主从数据库，只须要两台安装了 相同数据库的机器就能够了。

2、实现读写分离的两种方法

具体到开发中，实现读写分离经常使用的有两种方式：

一、第一种方式是咱们最经常使用的方式，就是定义2个数据库链接，一个是MasterDataSource,另外一个是SlaveDataSource。更新数据时咱们读取MasterDataSource，查询数据时咱们读取SlaveDataSource。这种方式很简单，我就不赘述了。

二、第二种方式动态数据源切换，就是在程序运行时，把数据源动态织入到程序中，从而选择读取主库仍是从库。主要使用的技术是：Annotation，Spring AOP ，反射。

下面会详细的介绍实现方式。

3、Aop实现主从数据库的读写分离案例

一、项目代码地址

目前该Demo的项目地址在开源中国 码云 上边：http://git.oschina.net/xuliugen/aop-choose-db-demo

或者CSDN免费下载：

http://download.csdn.net/detail/u010870518/9724872

二、项目结构

上图中，除了标记的代码，其余的主要是配置代码和业务代码。

三、具体分析

该项目是SSM框架的一个demo，Spring、Spring MVC和MyBatis，具体的配置文件不在过多介绍。

（1）UserContoller模拟读写数据

模拟读写数据，调用IUserService 。

（2）spring-db.xml读写数据源配置

<bean id="statFilter" class="com.alibaba.druid.filter.stat.StatFilter" lazy-init="true">

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

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

</bean>

<!-- 数据库链接 -->

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

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

<property name="driverClassName" value="${driver}"/>

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

<property name="username" value="root"/>

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

<!-- 省略部份内容 -->

</bean>

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

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

<property name="driverClassName" value="${driver}"/>

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

<property name="username" value="root"/>

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

<!-- 省略部份内容 -->

</bean>

<!-- 配置动态分配的读写 数据源 -->

<bean id="dataSource" class="com.xuliugen.choosedb.demo.aspect.ChooseDataSource" lazy-init="true">

<property name="targetDataSources">

<map key-type="java.lang.String" value-type="javax.sql.DataSource">

<!-- write -->

<entry key="write" value-ref="writeDataSource"/>

<!-- read -->

<entry key="read" value-ref="readDataSource"/>

</map>

</property>

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

<property name="methodType">

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

<!-- read -->

<entry key="read" value=",get,select,count,list,query"/>

<!-- write -->

<entry key="write" value=",add,create,update,delete,remove,"/>

</map>

</property>

</bean>

</beans>

上述配置中，配置了readDataSource和writeDataSource两个数据源，可是交给SqlSessionFactoryBean进行管理的只有dataSource，其中使用到了：com.xuliugen.choosedb.demo.aspect.ChooseDataSource 这个是进行数据库选择的。

（3）ChooseDataSource

（4）DataSourceAspect进行具体方法的AOP拦截

（5）DataSourceHandler，数据源的Handler类

主要代码，如上所述。具体细节能够下载代码查看。

原文：http://www.toutiao.com/i6370888340224344578