데이터베이스의 스프링 예를 읽고 씁니다

오늘날, 대규모 전자 상거래 시스템은 주로 마스터 데이터베이스 및 여러 슬레이브 데이터베이스 인 데이터베이스 수준에서 읽기 및 쓰기 분리 기술을 사용합니다. 마스터 라이브러리는 데이터 업데이트 및 실시간 데이터 쿼리를 담당하며 Slave Library는 비상 시간 데이터 쿼리를 담당합니다. 실제 애플리케이션에서 데이터베이스는 더 많이 읽고 더 적게 쓸 수 있기 때문에 (읽기 데이터의 빈도는 높고 데이터 업데이트 빈도는 비교적 작습니다), 읽기 데이터는 일반적으로 더 길고 데이터베이스 서버에서 더 많은 CPU를 차지하여 사용자 경험에 영향을 미칩니다. 우리의 일반적인 접근 방식은 기본 라이브러리에서 쿼리를 추출하고 여러 슬레이브 라이브러리를 사용하며로드 밸런싱을 사용하여 각 슬레이브 라이브러리의 쿼리 압력을 줄이는 것입니다.

읽기 및 쓰기 분리 기술을 사용하는 목표는 마스터 라이브러리의 압력을 효과적으로 줄이고 사용자 쿼리 데이터 요청을 다른 슬레이브 라이브러리에 배포하여 시스템의 견고성을 보장하는 것입니다. 읽기 쓰기 분리를 사용하는 배경을 살펴 보겠습니다.

웹 사이트의 비즈니스가 계속 확장됨에 따라 데이터가 계속 증가하고 더 많은 사용자가 데이터베이스에 대한 압력이 커집니다. 데이터베이스 또는 SQL 최적화와 같은 전통적인 방법은 기본적으로 요구 사항을 충족시킬 수 없습니다. 현재 읽기 및 쓰기 분리 전략을 사용하여 현 상태를 바꿀 수 있습니다.

구체적으로 개발에서 읽기 및 쓰기 분리를 쉽게 달성하는 방법은 무엇입니까? 일반적으로 사용되는 두 가지 방법이 있습니다.

1 첫 번째 방법은 가장 일반적으로 사용되는 메소드이며,이 방법은 두 개의 데이터베이스 연결을 정의하는 것입니다. 하나는 Mas 데이터를 업데이트 할 때 Mas 이 방법은 매우 간단하므로 자세한 내용은 없습니다.

2 동적 데이터 소스 스위칭의 두 번째 방법은 프로그램이 실행될 때 프로그램에 데이터 소스를 동적으로 직조하여 마스터 라이브러리 또는 슬레이브 라이브러리를 읽는 것입니다. 사용 된 주요 기술은 주석, 스프링 AOP, 반사입니다. 구현 방법은 아래에 자세히 설명됩니다.

구현 방법을 도입하기 전에 필요한 지식을 준비합니다.

AbstractroutingDatasource 클래스는 봄 2.0 이후에 추가되었습니다. 먼저 AbstractroutingDatasource의 정의를 살펴 보겠습니다.

코드 사본은 다음과 같습니다.
공개 초록 클래스 AbstroutingDatasource 확장 초기화 비도 초기화 비안 {}

AbstractroutingDatasource는 DataSource의 서브 클래스 인 AbstractDatasource를 상속합니다. DataSource는 javax.sql의 데이터 소스 인터페이스이며 다음과 같이 정의됩니다.

 Public Interface DataSource는 CommondataSource, Wrapper { /** * <p> { /** * <p>를 확장합니다. *이 <code> dataSource < /code> 객체가 나타내는 데이터 소스와 연결을 설정하려고 시도합니다. * * @데이터 소스에 대한 연결 * @exception sqlexception 데이터베이스 액세스 오류가 발생하는 경우 */ Connection getConnection ()가 sqlexception을 던졌습니다. /** * <p> *이 <code> dataSource </code> 객체가 나타내는 데이터 소스와 연결을 설정하려고 시도합니다. * * @param 사용자 이름 연결 측면의 데이터베이스 사용자 * @param 비밀번호 사용자의 비밀번호 * @return 데이터 소스에 대한 연결 * @exception sqlexception 데이터베이스 액세스 오류가 발생하는 경우 * @since 1.4 */ 연결 getConnection (String username, String password) sqlexception;}

DataSource 인터페이스는 두 가지 방법을 정의합니다. 두 가지 방법은 모두 데이터베이스 연결을 얻습니다. AbstractroutingDatasource가 DataSource 인터페이스를 어떻게 구현하는지 살펴 보겠습니다.

 공개 연결 getConnection ()는 sqlexception {return dectinetArgetDatasource (). getConnection (); } public Connection getConnection (문자열 사용자 이름, 문자열 비밀번호)은 sqlexception {return decminetArgetDatasource (). getConnection (username, password); }

분명히, 연결을 얻기 위해 자신의 DeciNeTargetDatasource () 메소드를 호출하는 것입니다. DeciNETARGETDATASOURCE 메소드는 다음과 같이 정의됩니다.

 보호 된 DataSource degiMinetArgetDatasource () {assert.notnull (this.ResolvedDatasources, "DataSource 라우터가 초기화되지 않았다"); Object Lookupkey = DegiMineCurrentLookUpkey (); DataSource DataSource = this.resolvedDatasources.get (Lookupkey); if (dataSource == null && (this.lenientfallback || lookupkey == null)) {dataSource = this.ResolvedDefaultDatasource; } if (dataSource == null) {throw new new ElegalStateException ( "조회 키를위한 대상 데이터 소스를 결정할 수 없습니다 [" + Xookupkey + "]"; } return dataSource; }

우리가 가장 관심을 갖는 것은 다음 두 문장입니다.

 Object Lookupkey = DegiMineCurrentLookUpkey (); DataSource DataSource = this.ResolvedDatasources.get (Lookupkey);

DeciNecurrentLookupkey 메소드 Lookupkey를 반환하고 ResolvedDatasources 메소드는 Lookupkey를 기반으로 맵에서 데이터 소스를 얻는 것입니다. RESOLVEDDATASOURCES 및 DECEDINDCURRENTLOOKUPKEY는 다음과 같이 정의됩니다.

 개인지도 <개체, DataSource> ResolvedDatasources; 보호 된 추상 객체 DecineCurrentLookUpkey ()

위의 정의를 본 후에는 몇 가지 아이디어가 있습니까? ResolvedDatasources는 맵 유형입니다. 우리는 mas

우리는 AbstractroutingDatasource를 상속하는 클래스 DynamicDatasource를 작성하고 맵의 키, 마스터 또는 슬레이브를 반환하는 DecineCurrentLookupkey () 메소드를 구현합니다.

좋아, 너무 많이 말한 후, 나는 조금 성가시다. 그것을 달성하는 방법을 봅시다.

우리가 사용하려는 기술은 위에서 언급되었습니다. 먼저 주석의 정의를 살펴 보겠습니다.

 @retention (rendentionpolicy.runtime) @target (elementtype.method) public @interface dataSource {string value ();}

또한 Spring의 추상 클래스 AbstroutingDatasource를 구현해야합니다. 이는 DegienecurrentLookupkey 메소드를 구현하는 것입니다.

 Public Class DynamicDatasource는 AbsTractroutingDataSource를 확장합니다. {@override Protected Object DecniNecurrentLookupkey () {// todo 자동 생성 메소드 스터브 리턴 DynamicDatasourceHolder.getDatasouce (); }} public class dynamicdatasourceholder {public static final threadlocal <string> holder = new ThreadLocal <string> (); public static void putdatasource (문자열 이름) {holder.set (name); } public static string getDatasouce () {return holder.get (); }}

DynamicDatasource의 정의에서 DynamicDatasourceholder.getDatasouce () 값을 반환합니다. 프로그램이 실행 중일 때 DynamicDatasourceholder.putDatasource () 메소드를 호출하고 값을 할당해야합니다. 다음은 구현의 핵심 부분, 즉 AOP 부분입니다. DataSourceatect는 다음과 같이 정의됩니다.

 public class datasourceaspect {public void 이전 (joinpoint point) {개체 target = point.getTarget (); 문자열 메소드 = point.getSignature (). getName (); class <?> [] classz = target.getClass (). getInterfaces (); class <?> [] parametertypes = (((methodsignature) point.getSignature ()) .getMethod (). getParameterTypes (); try {method m = classz [0] .getMethod (메소드, ParameterTypes); if (m! = null && m.isannotationPresent (dataSource.class)) {dataSource data = m .getAntation (dataSource.class); DynamicDatasourceholder.putDatasource (data.value ()); System.out.println (data.value ()); }} catch (예외 e) {// todo : 핸들 예외}}}}

테스트의 편의를 위해 2 개의 데이터베이스, Shop Mock Master Library, Test Mock Slave Library, Shop 및 Test Table 구조는 동일하지만 데이터는 다르며 데이터베이스 구성은 다음과 같습니다.

 <bean id = "mas value = "yangyanping0615"/> </bean> <bean id = "slavedatasource"> <property name = "driver className"value = "com.mysql.jdbc.driver"/> <속성 이름 = "url"value = "jdbc : mysql : //127.0.0.1 : 3306/test"/>>>>>>>>>. /> <property name = "password"value = "yangyanping0615" /> < /bean> <beans : bean id = "dataSource"> <property name = "target datasources"> <map key-type = "java.lang.string"> <!-write-> <eptry Key = "mas Value-Ref = "Slavedatasource"/> </map> </property> <속성 이름 = "defaultTargetDatasource"ref = "mas id = "sqlsessionFactory"> <속성 이름 = "dataSource"ref = "dataSource" /> <property name = "configlocation"value = "classpath : config /mybatis-config.xml" /> < /bean>

스프링 구성에 AOP 구성을 추가하십시오

 <!-데이터베이스 주석 aop-> <aop : sagne-autoproxy> < /aop : agage-autoproxy> <beans : bean id = "manydatasourceaspect" /> <aop : config> <aop : 측면 id = "c"ref = "manydatasourceaspect : <aop : pointcut id ="tx ""표현 " com.air.shop.mapper.*.*(..)) "/> <aop : pointcut-ref ="tx "method ="이전 "/> </aop : 측면> </aop : config> <!-데이터베이스 주석 AOP->

다음은 mybatis usermapper의 정의입니다. 테스트의 편의를 위해 로그인은 마스터 라이브러리를 읽고 사용자 목록은 슬레이브 라이브러리를 읽습니다.

 public interface usermapper {@datasource ( "master") public void add (사용자 사용자); @datasource ( "마스터") public void update (사용자); @datasource ( "마스터") public void delete (int id); @datasource ( "슬레이브") 공개 사용자 loadBeyid (int id); @datasource ( "마스터") public user loadbyname (문자열 이름); @datasource ( "슬레이브") 공개 목록 <user> list ();}

자, Eclipse를 실행하여 효과를 확인하고 사용자 이름 관리자를 입력하고 로그인하여 효과를 확인하십시오.

위는이 기사의 모든 내용입니다. 모든 사람의 학습에 도움이되기를 바랍니다. 모든 사람이 wulin.com을 더 지원하기를 바랍니다.