mysql+spring+mybatis实现数据库读写分离[代码配置] .
2024-10-01 08:48:53
场景:一个读数据源一个读写数据源。
原理:借助spring的【org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource】这个抽象类实现,看名字可以了解到是一个路由数据源的东西,这个类中有一个方法
/**
* Determine the current lookup key. This will typically be
* implemented to check a thread-bound transaction context.
* <p>Allows for arbitrary keys. The returned key needs
* to match the stored lookup key type, as resolved by the
* {@link #resolveSpecifiedLookupKey} method.
*/
protected abstract Object determineCurrentLookupKey();
每次去连数据库的时候,spring会调用这个方法去找对应的数据源。返回值即对应的数据源的LookUpKey.那么这个LookUpKey在哪定义的呢?看下面的dataBase.xml的配置
<!--数据源 读写 -->
<bean id="dataSourceRW" class="org.logicalcobwebs.proxool.ProxoolDataSource">
<property name="alias" value="ihotelRW"></property>
<property name="delegateProperties">
<value>user=${jdbc.username},password=${jdbc.password}
</value>
</property>
<property name="user" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="driver" value="${jdbc.driverClassName}" />
<property name="driverUrl" value="${jdbc.url}" />
<property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}"></property>
<property name="maximumActiveTime" value="${jdbc.maximumActiveTime}"></property>
<property name="maximumConnectionLifetime" value="${jdbc.maximumConnectionLifetime}"></property>
<property name="prototypeCount" value="${jdbc.prototypeCount}"></property>
<property name="houseKeepingSleepTime" value="${jdbc.houseKeepingSleepTime}"></property>
<property name="simultaneousBuildThrottle" value="${jdbc.simultaneousBuildThrottle}"></property>
<property name="houseKeepingTestSql" value="${jdbc.houseKeepingTestSql}"></property>
<property name="verbose" value="${jdbc.verbose}"></property>
<property name="statistics" value="${jdbc.statistics}"></property>
<property name="statisticsLogLevel" value="${jdbc.statisticsLogLevel}"></property>
</bean> <!--数据源 读-->
<bean id="dataSourceR" class="org.logicalcobwebs.proxool.ProxoolDataSource">
<property name="alias" value="ihotelR"></property>
<property name="delegateProperties">
<value>user=${jdbc.r.username},password=${jdbc.r.password}
</value>
</property>
<property name="user" value="${jdbc.r.username}" />
<property name="password" value="${jdbc.r.password}" />
<property name="driver" value="${jdbc.r.driverClassName}" />
<property name="driverUrl" value="${jdbc.r.url}" />
<property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}"></property>
<property name="maximumActiveTime" value="${jdbc.maximumActiveTime}"></property>
<property name="maximumConnectionLifetime" value="${jdbc.maximumConnectionLifetime}"></property>
<property name="prototypeCount" value="${jdbc.prototypeCount}"></property>
<property name="houseKeepingSleepTime" value="${jdbc.houseKeepingSleepTime}"></property>
<property name="simultaneousBuildThrottle" value="${jdbc.simultaneousBuildThrottle}"></property>
<property name="houseKeepingTestSql" value="${jdbc.houseKeepingTestSql}"></property>
<property name="verbose" value="${jdbc.verbose}"></property>
<property name="statistics" value="${jdbc.statistics}"></property>
<property name="statisticsLogLevel" value="${jdbc.statisticsLogLevel}"></property>
</bean> <!-- 动态数据源 -->
<bean id="dynamicDataSource" class="com.dao.datasource.DynamicDataSource">
<!-- 通过key-value关联数据源 -->
<property name="targetDataSources">
<map>
<entry value-ref="dataSourceRW" key="dataSourceKeyRW"></entry>
<entry value-ref="dataSourceR" key="dataSourceKeyR"></entry>
</map>
</property>
<property name="defaultTargetDataSource" ref="dataSourceRW" />
</bean> <!--mybatis与Spring整合 开始 -->
<bean id="sqlSessionFactory" name="sqlSessionFactory"
class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="configLocation" value="classpath:conf/core/sqlMapConfig.xml" />
<property name="dataSource" ref="dynamicDataSource" />
</bean>
动态数据源dynamicDataSource中的dataSourceKeyRW、dataSourceKeyR就是
protected abstract Object determineCurrentLookupKey();
这个方法要返回的值。那么如何设置,让这个方法的返回值是根据我们的需要返回dataSourceKeyRW、dataSourceKeyR呢?由于这个方法没有入参,并且是spring自动调用的,因此考虑使用静态变量存储dataSource的key,在调用sql语句前设置静态变量的值,然后在这个方法中得到静态变量的值,返回。又考虑到多线程,同时可能会有很多请求,为避免线程之间相互干扰,考虑使用threadLocal。
先看存储dataSourceKey的容器类。
public class DBContextHolder { /**
* 线程threadlocal
*/
private static ThreadLocal<String> contextHolder = new ThreadLocal<>(); private String DB_TYPE_RW = "dataSourceKeyRW";
private String DB_TYPE_R = "dataSourceKeyR"; public String getDbType() {
String db = contextHolder.get();
if (db == null) {
db = DB_TYPE_RW;// 默认是读写库
}
return db;
} /**
*
* 设置本线程的dbtype
*
* @param str
* @see [相关类/方法](可选)
* @since [产品/模块版本](可选)
*/
public void setDbType(String str) {
contextHolder.set(str);
} /**
* clearDBType
*
* @Title: clearDBType
* @Description: 清理连接类型
*/
public static void clearDBType() {
contextHolder.remove();
}
}
动态数据源的实现类。
public class DynamicDataSource extends AbstractRoutingDataSource { /*
* (non-Javadoc)
* @see javax.sql.CommonDataSource#getParentLogger()
*/
@Override
public Logger getParentLogger() throws SQLFeatureNotSupportedException {
// TODO Auto-generated method stub
return null;
} /**
*
* override determineCurrentLookupKey
* <p>
* Title: determineCurrentLookupKey
* </p>
* <p>
* Description: 自动查找datasource
* </p>
*
* @return
*/
@Override
protected Object determineCurrentLookupKey() {
return DBContextHolder.getDbType();
} }
在DAO层中设置数据库类型。
/**
* 添加邮件
*
* @param sms
* @return
*/
public boolean insertEmail(Email email) { //根据具体需要设置不同的数据库
DBContextHolder.setDbType(DBContextHolder.DB_TYPE_RW);
//DBContextHolder.setDbType(DBContextHolder.DB_TYPE_R);
int result = this.getSqlSession().insert(STATEMENT + ".addEntity",
email);
return result == 1;
}
在本例中,我们是在DAO中指定数据库,我们也可以根据需要在service或者controller中指定DB类型,需要记住的是setDbType是针对线程维度的。要考虑多线程的问题。
最新文章
- [官方软件] Easy Sysprep v4.3.29.602 【系统封装部署利器】(2016.01.22)--skyfree大神
- LPTHW 笨办法学python 33章
- NOIp 0910 爆零记
- MySQL中快速复制数据表方法汇总
- react-redux(1)
- Windows 10 Edge浏览器、照片查看程序关闭“平滑滚动”
- JS知识点备忘
- linq中的cast<;T>;()及OfType<;T>;()
- php简单数据缓存类
- 10165 - Stone Game(Nim游戏)
- poj 2184(dp变形,进一步加深01背包)
- JS 与 OC
- jQuery 提供多个与 AJAX 有关的方法。
- Android App插件式换肤实现方案
- Git报错 bad numeric config value &#39;100000&#39; for &#39;pack.windowmemory&#39;: out of range
- html css笔记zht
- Flask与mysql数据库字段类型的区别以及基本用法
- centos7操作SSH/SSHD服务(查看/启动/重启/自启)
- 那些年读过的书《Java并发编程实战》一、构建线程安全类和并发应用程序的基础
- Java 13 - Java 数组
热门文章
- (转) shiro权限框架详解06-shiro与web项目整合(上)
- mach-o格式分析
- 洛谷P1297 [国家集训队]单选错位_数学期望
- MAC上ITERM2配置SZ, RZ远程上传和下载文件
- C语言提高 (2) 第二天 用指针对字符串进行操作
- LAMP环境下,通过网页url获取gb2312编码中文命名的下载资源方法
- 兼容IE的两端对齐
- 洛谷P1200 [USACO1.1]你的飞碟在这儿Your Ride Is He…
- 可执行程序无法在Linux上运行,显示line 1: syntax error: word unexpected (expecting ";) .
- chckBox样式的修改