java 读写分离

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

源码地址：http://git.oschina.net/xiaochangwei

先回答下1.为啥要读写分离？大家都知道最初开始，一个项目对应一个数据库，基本是一对一的，但是由于后来用户及数据还有访问的急剧增多，系统在数据的读写上出现了瓶颈，为了让提高效率，想读和写不相互影响，读写分离就诞生了......2.什么样的项目需要读写分离？并不是所有项目都适合读写分离，如果我把我自己的博客网站也搞成读写分离的，菜鸟觉得哇好高大上；砖家就会说 SB读写分离仅适合用在读写尤其频繁的项目，如淘宝这类访问量多，读写都很频繁的情况下，一般来说想中小型企业的erp，网站啥的都不需要，用了反而影响性能，因为读写时的切换也是要耗费资源的3.读写分离的前提条件是什么？如2所说，如果确定了项目需要用到读写分离，那就得配置数据库同步了，数据不同步读写有啥意思，同步方式很多种，最简单的主从同步可以参考我的博客另一篇文章 http://www.cnblogs.com/xiaochangwei/p/4824355.html当然还有很多同步方式，抛砖引玉请自由发挥大家别急，不要说我写了半天还不如正题，我文学功底差，语文老师死得早，想到啥说啥，毕竟语文考试很少及格，你们要理解下下面我讲的j2ee主从同步，用到的是技术框架：基于注解的SpringMVC + Mybatis + Mysql,Spring mvc就很熟悉了，自己搭个框架一边玩吧，讲讲整合mybatis时候怎么读写分离的，直接贴代码：<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.2.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.2.xsd"> <context:component-scan base-package="com.xiao" />
<aop:aspectj-autoproxy/> 
<context:property-placeholder location="classpath:application.properties" /> 
<bean id="business_write" class="org.logicalcobwebs.proxool.ProxoolDataSource">

<property name="driver" value="${jdbc.driver}" />
<property name="driverUrl" value="${business.write.url}" />
<property name="user" value="${business.write.username}" />
<property name="password" value="${business.write.password}" />
<property name="alias" value="master_db" /> 
<property name="houseKeepingTestSql" value="select count(*) from dual" />

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

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

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

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

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

<property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}" />
</bean> <bean id="business_read" class="org.logicalcobwebs.proxool.ProxoolDataSource">

<property name="driver" value="${jdbc.driver}" />
<property name="driverUrl" value="${business.read.url}" />
<property name="user" value="${business.read.username}" />
<property name="password" value="${business.read.password}" />
<property name="alias" value="slave_db" />

<property name="houseKeepingTestSql" value="select count(*) from dual" />

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

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

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

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

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

<property name="maximumConnectionCount" value="${jdbc.maximumConnectionCount}" />
</bean> <bean id="dataSource" class="com.xiao.weixin.common.jdbc.DynamicDataSource">
<property name="targetDataSources">
<map>
<entry key="business_write" value-ref="business_write" />
<entry key="business_read" value-ref="business_read" />
</map>
</property>
<property name="defaultTargetDataSource" ref="business_write" />
</bean> 
<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">

<property name="corePoolSize" value="5" />

<property name="maxPoolSize" value="10" />

<property name="queueCapacity" value="25" />
</bean> 
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource" />

<property name="mapperLocations" value="classpath:com/xiao/**/*Mapper.xml" /> 
</bean> 
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.xiao.**.dao" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
</bean> 
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean> 
<tx:annotation-driven transaction-manager="transactionManager" order="2"/> 
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource" />
</bean> <bean id="xiaoFilter" class="com.xiao.weixin.common.filter.XiaoFilter" /> <import resource="spring-mybatis_quartz.xml"/>

<import resource="applicationContext-shiro.xml"/>

<import resource="spring-i18n.xml"/>
</beans>首先你得有配置好了的读数据库和写数据库不会的戳这里哈 http://www.cnblogs.com/xiaochangwei/p/4824355.html配置好了读和写的数据源了后，仔细看<bean id="dataSource" class="com.xiao.weixin.common.jdbc.DynamicDataSource">
<property name="targetDataSources">
<map>
<entry key="business_write" value-ref="business_write" />
<entry key="business_read" value-ref="business_read" />
</map>
</property>
<property name="defaultTargetDataSource" ref="business_write" />
</bean>这里指定了两个数据源，并且默认是用的写数据库，
数据源之所以能切换是因为Spring提供了 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource接口默认不是写么package com.xiao.weixin.common.jdbc;import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/**
* 设置数据源
*/
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface DataSource {
String value() default "business_read";
} 如果我们在serviceimpl中，某个方法上加上 @DataSource 如下：@Override
@DataSource
public String getAccessToken() {
String access_token = null;
try {
AccessToken token = weixinApiMapper.findToken();// 数据库查找没过期的token并返回
if (token != null) {
access_token = token.getAccessToken();
}
} catch (Exception e) {
log.error("获取accessToken出错");
e.printStackTrace();
}
log.debug("获取到的accessToken是：" + access_token);
return access_token;
}
就会连接到读数据库，不写则用默认的读数据库不过只是上面的代码是不行的，具体切换还得看Spring提供的接口配置中关联的实现类代码如下package com.xiao.weixin.common.jdbc;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;public class DynamicDataSource extends AbstractRoutingDataSource { @Override
protected Object determineCurrentLookupKey() {
return JdbcContextHolder.getJdbcType();
}
}JdbcContextHolder 又是下面这样实现滴package com.xiao.weixin.common.jdbc;/**
* 连接哪个数据源的环境变量
*/
public class JdbcContextHolder {
private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); public static void setJdbcType(String jdbcType) {
contextHolder.set(jdbcType);
} /**
* 在选用business_write数据源前，执行此方法
*/
public static void setBusinessWrite(){
setJdbcType("business_write");
}
/**
* 在选用business_read数据源前，执行此方法
*/
public static void setBusinessRead(){
setJdbcType("business_read");
}
public static String getJdbcType(){
return (String) contextHolder.get();
}
/**
* 恢复成默认的数据源，即defaultTargetDataSource，执行此方法
*/
public static void clearJdbcType() {
contextHolder.remove();
}
} 就这样就能轻松搞定读写分离了，搞不定的朋友请和我交流不要问我为啥知道这些，都是面试的时候不懂回来自己研究的，正如我股灾期间我告诉大家一定要坚持到16号，16号有大量资金入场，大家回复我这么牛逼，知道啥子内幕么，我呵呵一笑因为我们公司15号发工资 o(^▽^)o