[转]Spring数据库读写分离

数据库的读写分离简单的说是把对数据库的读和写操作分开对应不同的数据库服务器，这样能有效地减轻数据库压力，也能减轻io压力。

主(master)数据库提供写操作，从(slave)数据库提供读操作，其实在很多系统中，主要是读的操作。

当主(master)数据库进行写操作时，数据要同步到从(slave)的数据库，这样才能有效保证数据库完整性。主(master)数据库同步到从(slave)数据库，从数据库一般由多台数据库组成这样才能达到减轻压力的目的。这里还要注意处理好负载均衡。

使用spring的动态路由实现数据库读写分离
Spring2.0.1以后的版本已经支持配置多数据源，并且可以在运行的时候动态加载不同的数据源。通过继承AbstractRoutingDataSource就可以实现多数据源的动态转换。目前做的项目就是需要访问2个数据源，每个数据源的表结构都是相同的，所以要求数据源的变动对于编码人员来说是透明，也就是说同样SQL语句在不同的环境下操作的数据库是不一样的。具体的流程如下：

1.建立一个获得和设置上下文的类

[java] view plaincopy

package com.lvye.base.dao.impl.jdbc;
/**
*连接哪个数据源的环境变量
*/
public class JdbcContextHolder {
private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
public static void setJdbcType(String jdbcType) {
contextHolder.set(jdbcType);
}
public static void setSlave(){
setJdbcType("slave");
}
public static void setMaster(){
clearJdbcType();
}
public static String getJdbcType(){
return (String) contextHolder.get();
}
public static void clearJdbcType() {
contextHolder.remove();
}
}

2.建立动态数据源类，这个类必须继承AbstractRoutingDataSource

[java] view plaincopy

package com.lvye.base.dao.impl.jdbc;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class DynamicDataSource extends AbstractRoutingDataSource{
/*(non-Javadoc)
*@see org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource#determineCurrentLookupKey()
*@author wenc
*/
@Override
protected Object determineCurrentLookupKey() {
return JdbcContextHolder.getJdbcType();
}
}

这个类实现了determineCurrentLookupKey方法，该方法返回一个Object，一般是返回字符串。该方法中直接使用了JdbcContextHolder.getJdbcType();方法获得上下文环境并直接返回。

3.编写spring的配置文件配置数据源

[html] view plaincopy

<beans>
<bean id="master" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
<property name="driverClass">
<value>com.mysql.jdbc.Driver</value>
</property>
<property name="jdbcUrl">
<value>jdbc:mysql://192.168.18.143:3306/wenhq?useUnicode=true&characterEncoding=utf-8</value>
</property>
<property name="user">
<value>root</value>
</property>
<property name="password">
<value></value>
</property>
</bean>
<bean id="slave" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
<property name="driverClass">
<value>com.mysql.jdbc.Driver</value>
</property>
<property name="jdbcUrl">
<value>jdbc:mysql://192.168.18.144:3306/ wenhq?useUnicode=true&characterEncoding=utf-8</value>
</property>
<property name="user">
<value>root</value>
</property>
<property name="password">
<value></value>
</property>
</bean>
<bean id="mySqlDataSource" class="com.lvye.base.dao.impl.jdbc.DynamicDataSource">
<property name="targetDataSources">
<map>
<entry key="slave" value-ref="slave"/>
</map>
</property>
<property name="defaultTargetDataSource" ref="master"/>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="mySqlDataSource" />
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="mySqlDataSource" />
</bean>
</beans>

在这个配置中可以看到首先配置两个真实的数据库连接，使用的msyql数据库；master和slave是按照mysql配置的主从关系的数据库，数据会自动实时同步mySqlDataSource会根据上下文选择不同的数据源。在这个配置中第一个property属性配置目标数据源，<entry key="slave" value-ref=" slave"/>中key的值必须要和JdbcContextHolder类中设置的参数值相同，如果有多个值，可以配置多个<entry>标签。第二个property属性配置默认的数据源，我们一般默认为主数据库。有些朋友喜欢使用hibernate，只需要把上面的jdbcTemplate替换为hibernate的就可以了。
4.多数据库连接配置完毕，简单测试

[java] view plaincopy

public void testSave() throws Exception{
jdbcContextHolder.setSlave();//设置从数据源
Test test = new Test();
test.setTest("www.wenhq.com.cn");
mydao.save(test);//使用dao保存实体
jdbcContextHolder.setMaster();//设置主数据源
mydao.save(test);//使用dao保存实体到另一个库中
}

5.实现读写分离，上面的测试通过了，现在就简单了我的程序是使用jdbc实现的保存数据，只是使用了c3p0的数据库连接池而已。把所有访问数据库的方法包装一下，统一调用。把执行更新的sql发送到主数据库了

[java] view plaincopy

public void execute(String sql) {
JdbcContextHolder.setMaster();
log.debug("execute-sql:" + sql);
jdbcTemplate.execute(sql);
}

把查询的发送到从数据库，需要注意的是像LAST_INSERT_ID这类的查询需要特殊处理，必须发送到主数据库，建议增加专门的方法，用于获取自增长的主键。

[java] view plaincopy

public List findObject(String queryString, Class clazz) {
JdbcContextHolder.setSlave();
log.debug("findObject-sql:" + queryString);
List list = jdbcTemplate.queryForList(queryString);
try {
list = StringBase.convertList(list, clazz);// 将List转化为List<clazz>
} catch (Exception e) {
log.error("List convert List<Object> error:" + e);
}
AbstractRoutingDataSourcereturn list;
}

转载于:https://www.cnblogs.com/moonandstar08/p/5104069.html

[转]Spring数据库读写分离相关推荐

Spring - 数据库读写分离
文章目录 Spring - 数据库读写分离 1.读写分离解决方案 1.1 应用层解决 1.2 中间件解决 2.Mysql主从配置 2.1 Mysql主从复制原理 2.2 Master主库配置 2.3 ...
jedis 读写分离_Redis实现数据库读写分离
Redis是一种NoSQL的文档数据库,通过key-value的结构存储在内存中,Redis读的速度是110000次/s,写的速度是81000次/s,性能很高,使用范围也很广. 下面用一个实例实现re ...
简单好用！利用Spring AOP技术10分钟实现一个数据库读写分离方案
前言最近我们的APP在线用户越来越多,接口的响应速度也是越来越慢,经过运维排查发现是由于并发查询太多导致的数据库压力比较大,架构师经过调研给出了数据库读写分离的解决方案,为了快速解决问题,我们最终采 ...
java spring mysql配置_java相关：mysql+spring+mybatis实现数据库读写分离的代码配置
java相关:mysql+spring+mybatis实现数据库读写分离的代码配置发布于 2020-4-4| 复制链接分享一篇关于关于mysql+spring+mybatis实现数据库读写分离的代 ...
Spring 实现数据库读写分离
Spring 实现数据库读写分离现在大型的电子商务系统,在数据库层面大都采用读写分离技术,就是一个Master数据库,多个Slave数据库.Master库负责数据更新和实时数据查询,Slave库当然 ...
跟我学Springboot开发后端管理系统5：数据库读写分离
在Matrix-web后台管理系统中,使用到了数据库的读写分离技术.采用的开源的Sharding-JDBC作为数据库读写分离的框架.Matrix-Web后台数据库这一块采用的技术栈如下: 使用Myba ...
解决数据库读写分离（转）
如何配置mysql数据库的主从? 单机配置mysql主从:http://my.oschina.net/god/blog/496 常见的解决数据库读写分离有两种方案 1.应用层 http://neore ...
PG SQL数据库读写分离的思路
PGSQL可以设置一台主多个SLAVE,这样我们需要一个办法能在程序里做到读写分离,查询了互联网,找到了下面的解决思路,请周枫在后继开发中测试下面的思路方案: 在应用层通过spring特性解决数据库读 ...
mybatis获取mysql源数据类型_spring集成mybatis实现mysql数据库读写分离
前言在网站的用户达到一定规模后,数据库因为负载压力过高而成为网站的瓶颈.幸运的是目前大部分的主流数据库都提供主从热备功能,通过配置两台数据库主从关系,可以将一台数据库的数据更新同步到另一台服务器上. ...

[转]Spring数据库读写分离

[转]Spring数据库读写分离相关推荐

最新文章

热门文章