spring+mybatis实现数据读写分离

随着网站的业务不断扩展，数据不断增加，用户越来越多，数据库的压力也就越来越大，采用传统的方式，比如：数据库或者SQL的优化基本已达不到要求，这个时候可以采用读写分离的策 略来改变现状。现在主要介绍进行动态数据源切换的方式实现读写分离。

原理就是在在程序运行时，把数据源动态织入到程序中，从而选择读取主库还是从库。主要使用的技术是：annotation，Spring AOP ，反射。

首先我们要先准备一些知识，我们先来看下AbstractRoutingDataSource的定义：

public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean {}

AbstractRoutingDataSource继承了AbstractDataSource ，而AbstractDataSource 又是DataSource 的子类。DataSource 是javax.sql 的数据源接口。DataSource定义如下

DataSource 接口定义了2个方法，都是获取数据库连接。我们在看下AbstractRoutingDataSource 如何实现了DataSource接口：

很显然就是调用自己的determineTargetDataSource() 方法获取到connection。determineTargetDataSource方法定义如下：

我们最关心的还是下面2句话：

Object lookupKey = determineCurrentLookupKey();

DataSource dataSource = this.resolvedDataSources.get(lookupKey);

determineCurrentLookupKey方法返回lookupKey,resolvedDataSources方法就是根据lookupKey从Map中获得数据源。resolvedDataSources 和determineCurrentLookupKey定义如下：

private Map resolvedDataSources; protected abstract Object determineCurrentLookupKey()

看到以上定义，我们是不是有点思路了，resolvedDataSources是Map类型，我们可以把MasterDataSource和SlaveDataSource存到Map中，如下：

key value

master masterDataSource slave slaveDataSource

我们在写一个类ReplicationDataSource 继承AbstractRoutingDataSource，实现其determineCurrentLookupKey() 方法，该方法返回Map的key，master或slave。

下面开始操作，首先定一个annotation

然后创建保存数据源标识的一个线程变量

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

从ReplicationDataSource 的定义看出，他返回的是ReplicationDataSourceHolder.getDataSouce()值，我们需要在程序运行时调用ReplicationDataSourceHolder.putDataSource()方法，对其赋值。下面是我们实现的核心部分，也就是AOP部分，ReplicationDataSourceAspect定义如下:

下面就需要在application.xml中配置主从库的数据源了，如下

在spring的配置中增加aop配置,这里拦截的service

最后在service中配置注解

本文来源：https://www.bwwdw.com/article/s6xf.html