新聞中心
創(chuàng)新互聯(lián)-成都網站建設公司,專注成都網站設計、做網站、網站營銷推廣,申請域名,雅安服務器托管,成都網站托管有關企業(yè)網站制作方案、改版、費用等問題,請聯(lián)系創(chuàng)新互聯(lián)。
隨著系統(tǒng)用戶訪問量的不斷增加,數(shù)據庫的頻繁訪問將成為我們系統(tǒng)的一大瓶頸之一。由于項目前期用戶量不大,我們實現(xiàn)單一的數(shù)據庫就能完成。但是后期單一的數(shù)據庫根本無法支撐龐大的項目去訪問數(shù)據庫,那么如何解決這個問題呢?
實際的應用中,數(shù)據庫都是讀多寫少(讀取數(shù)據的頻率高,更新數(shù)據的頻率相對較少),而讀取數(shù)據通常耗時比較長,占用數(shù)據庫服務器的CPU較多,從而影響用戶體驗。我們通常的做法就是把查詢從主庫中抽取出來,采用多個從庫,使用負載均衡,減輕每個從庫的查詢壓力。
采用讀寫分離技術的目標:有效減輕Master庫的壓力,又可以把用戶查詢數(shù)據的請求分發(fā)到不同的Slave庫,從而保證系統(tǒng)的健壯性。我們看下采用讀寫分離的背景。
我們在項目開發(fā)初期的時候就設計了一個簡單的讀寫分離,現(xiàn)在我把demo分享給大家。
采用技術Spring + mybatis
首先定義一個annotation
import java.lang.annotation.ElementType;
import java.lang.annotation.Target;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface DataSource {
public String value();
}
再定義一個HandleDataSource
public class HandleDataSource {
public static final ThreadLocal holder = new ThreadLocal();
public static void putDataSource(String datasource) {
holder.set(datasource);
}
public static String getDataSource() {
return holder.get();
}
}
定義一個切面
import java.lang.reflect.Method;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;
public class DataSourceAspect {
public void pointCut() {
};
public void before(JoinPoint point) {
Object target = point.getTarget();// 攔截的實體類
String method = point.getSignature().getName();// 攔截的方法名稱
Class[] classz = target.getClass().getInterfaces();
Class[] parameterTypes = ((MethodSignature) point.getSignature()).getMethod().getParameterTypes();// 攔截的方法參數(shù)類型
try {
Method m = classz[0].getMethod(method, parameterTypes);
if (m != null && m.isAnnotationPresent(DataSource.class)) {
DataSource data = m.getAnnotation(DataSource.class);
HandleDataSource.putDataSource(data.value());
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
獲取數(shù)據源
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class ChooseDataSource extends AbstractRoutingDataSource {
protected Object determineCurrentLookupKey() {
return HandleDataSource.getDataSource();
}
}
配置XMl
classpath*:MySQL.propertiescom.mysql.jdbc.Driver${jdbc.url}${jdbc.user}${jdbc.password}SELECT 1 FROM DUAL32510010000true60com.mysql.jdbc.Driver${jdbc.url.read}${jdbc.user.read}${jdbc.password.read}SELECT 1 FROM DUAL32510010000true60
注解到service接口上面
數(shù)據庫表就一張 根據mybatis的xml大家自己建一下
另外這里還有一個瑕疵就是,當你使用注解事務的時候系統(tǒng)只能讀取默認的數(shù)據源,這個問題主要是因為spring的事務和自定義的aop存在一個先后順序的問題
Spring中的事務是通過aop來實現(xiàn)的,當我們自己寫aop攔截的時候,會遇到跟spring的事務aop執(zhí)行的先后順序問題,比如說動態(tài)切換數(shù)據源的問題,如果事務在前,數(shù)據源切換在后,會導致數(shù)據源切換失效,所以就用到了Order(排序)這個關鍵字.
我們可以通過在@AspectJ的方法中實現(xiàn)org.springframework.core.Ordered 這個接口來定義order的順序,order 的值越小,說明越先被執(zhí)行。
大家對技術感興趣的朋友也可以來 關注我的微信公眾號 : Java填坑之路 也會分享一些 架構技術資料。
新聞名稱:Java程序員干貨學習筆記—Spring結合MyBatis實現(xiàn)數(shù)據庫讀寫分離
文章起源:http://www.dlmjj.cn/article/jjchog.html