Spring(AbstractRoutingDataSource)동적 데이터 원본 전환 예시 실현

머리말
최근 에 한 항목 A 는 데이터 가 다른 항목 B 데이터베이스 에 동기 화 되 어야 한다.B 항목 을 바 꾸 지 않 은 상황 에서 프로젝트 A 에서 데이터 원본 을 전환 하고 데 이 터 를 프로젝트 B 의 데이터베이스 에 직접 기록 할 수 밖 에 없다.이러한 수 요 는 데이터 동기 화 와 정시 작업 에 자주 필요 하 다.
그렇다면 문제 가 생 겼 다.다 중 데이터 소스 문 제 를 어떻게 해결 해 야 할 까?여러 개의 데이터 원본 을 설정 하 는 것 뿐만 아니 라 유연 하고 동적 으로 데이터 원본 을 전환 할 수 있어 야 한다.spring+hibenate 프레임 워 크 항목 을 예 로 들 면:

하나의 데이터 원본 을 session Factory 에 연결 하고 Dao 층 에서 작업 합 니 다.여러 데이터 원본 이 있 으 면 다음 그림 이 되 지 않 습 니 다.
   
이 를 통 해 알 수 있 듯 이 session Factory 는 모두 Dao 층 에서 죽 었 다 고 쓰 여 있 습 니 다.만약 에 제 가 데이터 원본 을 추가 하면 session Factory 를 추가 해 야 합 니 다.그래서 비교적 좋 은 방법 은 다음 그림 일 것 이다.

이 데이터 원본 을 spring 으로 통합 하 는 방법 을 설명 하 겠 습 니 다.spring+hibenate 설정 을 예 로 들 면.
2.실현 원리
1.Spring 을 확장 하 는 AbstractRouting DataSource 추상 류(이 종 류 는 DataSource 의 경로 중개 역할 을 합 니 다.실행 할 때 특정한 key 값 에 따라 실제 DataSource 로 동적 전환 할 수 있 습 니 다.)
AbstractRouting DataSource 의 원본 코드 에서:

public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean

우 리 는 그것 이 AbstractDataSource 를 계승 한 것 을 볼 수 있 습 니 다.AbstractDataSource 는 javax.sql.Data Source 의 하위 클래스 가 아 닙 니 다.그래서 우 리 는 그것 의 getConnection 방법 을 분석 할 수 있 습 니 다.

public Connection getConnection() throws SQLException { 
 return determineTargetDataSource().getConnection(); 
} 
 
public Connection getConnection(String username, String password) throws SQLException { 
  return determineTargetDataSource().getConnection(username, password); 
}

연결 을 가 져 오 는 방법 중 중점 은 determineTargetDataSource()방법 입 니 다.원본 코드 를 보십시오.

/** 
  * Retrieve the current target DataSource. Determines the 
  * {@link #determineCurrentLookupKey() current lookup key}, performs 
  * a lookup in the {@link #setTargetDataSources targetDataSources} map, 
  * falls back to the specified 
  * {@link #setDefaultTargetDataSource default target DataSource} if necessary. 
  * @see #determineCurrentLookupKey() 
  */ 
 protected DataSource determineTargetDataSource() { 
  Assert.notNull(this.resolvedDataSources, "DataSource router not initialized"); 
  Object lookupKey = determineCurrentLookupKey(); 
  DataSource dataSource = this.resolvedDataSources.get(lookupKey); 
  if (dataSource == null && (this.lenientFallback || lookupKey == null)) { 
   dataSource = this.resolvedDefaultDataSource; 
  } 
  if (dataSource == null) { 
   throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]"); 
  } 
  return dataSource; 
 }

위의 소스 코드 는 determineCurrentLookupkey()방법 에 중점 을 두 고 있 습 니 다.이것 은 AbstractRouting DataSource 류 의 추상 적 인 방법 입 니 다.반환 값 은 사용 하고 자 하 는 데이터 원본 dataSource 의 key 값 입 니 다.이 key 값 이 있 으 면 resolvedDataSource(이것 은 map 입 니 다.설정 파일 에 설 치 된 후에 저 장 된 것)에서 해당 하 는 DataSource 를 찾 습 니 다.찾 지 못 하면...기본 데이터 원본 을 설정 합 니 다.
소스 코드 를 보고 뭔 가 깨 우 침 이 있 었 겠 지?맞 아!AbstractRouting DataSource 클래스 를 확장 하고 determineCurrentLookupkey()방법 을 다시 써 서 데이터 원본 전환 을 실현 하려 면:

package com.datasource.test.util.database;
 
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
 
/**
 *      （   spring）
 * @author linhy
 */
public class DynamicDataSource extends AbstractRoutingDataSource{
 @Override
 protected Object determineCurrentLookupKey() {
  return DataSourceHolder.getDataSource();
 }
}

DataSourceHolder 라 는 종 류 는 우리 가 봉 인 된 데이터 원본 을 조작 하 는 종류 입 니 다.

package com.datasource.test.util.database;
 
/**
 *      
 * @author linhy
 */
public class DataSourceHolder {
 //      
 private static final ThreadLocal<String> dataSources = new ThreadLocal<String>();
 //     
 public static void setDataSource(String customerType) {
  dataSources.set(customerType);
 }
 //     
 public static String getDataSource() {
  return (String) dataSources.get();
 }
 //     
 public static void clearDataSource() {
  dataSources.remove();
 }
 
}

2.누군가가 물 어 볼 것 이다.그러면 setDataSource 라 는 방법 은 언제 실행 해 야 합 니까?당연히 데이터 원본 을 바 꿔 야 할 때 실행 해 야 지.코드 에 수 동 으로 호출 하여 죽 습 니까?이것 은 얼마나 어 리 석 은 방법 인지,당연히 그것 을 움 직 이게 해 야 한다.그래서 우 리 는 spring op 을 사용 하여 설정 할 수 있 습 니 다.설정 한 데이터 원본 형식 을 모두 주석 태그 로 설정 할 수 있 습 니 다.service 층 에서 데이터 원본 을 전환 하 는 방법 에 주석 라벨 을 쓰 고 해당 하 는 방법 으로 데이터 원본 을 전환 할 수 있 습 니 다.(당신 이 설정 한 업무 와 같 습 니 다)

@DataSource(name=DataSource.slave1)
public List getProducts(){

물론 주석 라벨 의 용법 은 거의 사용 되 지 않 을 수 있 지만 좋 은 물건 입 니 다.우리 가 개발 하 는 데 큰 도움 을 주 었 습 니 다.

package com.datasource.test.util.database;
 
import java.lang.annotation.*;
 
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataSource {
 String name() default DataSource.master;
 
 public static String master = "dataSource1";
 
 public static String slave1 = "dataSource2";
 
 public static String slave2 = "dataSource3";
 
}

3.프로필
편폭 을 간소화 하기 위해 본 내용 의 주제 와 무관 한 설정 을 생략 하 였 다.
프로젝트 에서 application-database.xml 을 따로 분리 하여 데이터 원본 설정 에 관 한 파일 입 니 다.

<?xml version="1.0" encoding="UTF-8"?>
<!-- Spring              -->
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:aop="http://www.springframework.org/schema/aop"
  xmlns:tx="http://www.springframework.org/schema/tx"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/aop
  http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  http://www.springframework.org/schema/tx
  http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
 
 <bean id = "dataSource1" class = "com.mysql.jdbc.jdbc2.optional.MysqlDataSource"> 
  <property name="url" value="${db1.url}"/>
  <property name = "user" value = "${db1.user}"/>
  <property name = "password" value = "${db1.pwd}"/>
  <property name="autoReconnect" value="true"/>
  <property name="useUnicode" value="true"/>
  <property name="characterEncoding" value="UTF-8"/>
 </bean>
 
 <bean id = "dataSource2" class = "com.mysql.jdbc.jdbc2.optional.MysqlDataSource">
  <property name="url" value="${db2.url}"/>
  <property name = "user" value = "${db2.user}"/>
  <property name = "password" value = "${db2.pwd}"/>
  <property name="autoReconnect" value="true"/>
  <property name="useUnicode" value="true"/>
  <property name="characterEncoding" value="UTF-8"/>
 </bean>
 
 <bean id = "dataSource3" class = "com.mysql.jdbc.jdbc2.optional.MysqlDataSource">
  <property name="url" value="${db3.url}"/>
  <property name = "user" value = "${db3.user}"/>
  <property name = "password" value = "${db3.pwd}"/>
  <property name="autoReconnect" value="true"/>
  <property name="useUnicode" value="true"/>
  <property name="characterEncoding" value="UTF-8"/>
 </bean>
 <!--            -->
 <bean id="dataSource" class="com.datasource.test.util.database.DynamicDataSource">
  <property name="targetDataSources">
   <map key-type="java.lang.String">
  <entry key="dataSource1" value-ref="dataSource1"></entry>
    <entry key="dataSource2" value-ref="dataSource2"></entry>
    <entry key="dataSource3" value-ref="dataSource3"></entry>
   </map>
  </property>
 <!--                -->
  <property name="defaultTargetDataSource" ref="dataSource1"/>
 </bean>
 
 <bean id="sessionFactoryHibernate" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
  <property name="dataSource" ref="dataSource"/>
  <property name="hibernateProperties">
   <props>
    <prop key="hibernate.dialect">com.datasource.test.util.database.ExtendedMySQLDialect</prop>
    <prop key="hibernate.show_sql">${SHOWSQL}</prop>
    <prop key="hibernate.format_sql">${SHOWSQL}</prop>
    <prop key="query.factory_class">org.hibernate.hql.classic.ClassicQueryTranslatorFactory</prop>
    <prop key="hibernate.connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider</prop>
    <prop key="hibernate.c3p0.max_size">30</prop>
    <prop key="hibernate.c3p0.min_size">5</prop>
    <prop key="hibernate.c3p0.timeout">120</prop>
    <prop key="hibernate.c3p0.idle_test_period">120</prop>
    <prop key="hibernate.c3p0.acquire_increment">2</prop>
    <prop key="hibernate.c3p0.validate">true</prop>
    <prop key="hibernate.c3p0.max_statements">100</prop>
   </props>
  </property>
 </bean>
 
 <bean id="hibernateTemplate" class="org.springframework.orm.hibernate3.HibernateTemplate">
  <property name="sessionFactory" ref="sessionFactoryHibernate"/>
 </bean>
 
 <bean id="dataSourceExchange" class="com.datasource.test.util.database.DataSourceExchange"/>
 
 <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
  <property name="sessionFactory" ref="sessionFactoryHibernate"/>
 </bean>
 
 <tx:advice id="txAdvice" transaction-manager="transactionManager">
  <tx:attributes>
   <tx:method name="insert*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="add*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="update*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="modify*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="edit*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="del*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="save*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="send*" propagation="NESTED" rollback-for="Exception"/>
   <tx:method name="get*" read-only="true"/>
   <tx:method name="find*" read-only="true"/>
   <tx:method name="query*" read-only="true"/>
   <tx:method name="search*" read-only="true"/>
   <tx:method name="select*" read-only="true"/>
   <tx:method name="count*" read-only="true"/>
  </tx:attributes>
 </tx:advice>
 
 <aop:config>
  <aop:pointcut id="service" expression="execution(* com.datasource..*.service.*.*(..))"/>
  <!--     ，                  （         ） -->
  <aop:advisor advice-ref="txAdvice" pointcut-ref="service" order="2"/>
  <aop:advisor advice-ref="dataSourceExchange" pointcut-ref="service" order="1"/>
 </aop:config>
 
</beans>

의문
다 중 데이터 원본 전환 은 성 공 했 지만 업무 와 관련 이 있 습 니까?단일 데이터 원본 사 무 는 ok 이지 만 다 중 데이터 원본 이 하나의 사 무 를 동시에 사용 해 야 한다 면?이 문 제 는 다소 고 개 를 끄 덕 였 다.인터넷 에 서 는 아 토 미 코스 오픈 소스 프로젝트 로 JTA 분포 식 사무 처 리 를 실현 하 자 는 의견 이 나 왔 다.어떻게 생각 하 세 요?
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.