Spring AOP 동적 다 중 데이터 원본 의 실례 상세 설명

Spring AOP 동적 다 중 데이터 원본 의 실례 상세 설명
항목 에서 읽 기와 쓰기 가 분 리 될 때,우 리 는 다 중 데이터 원본 의 문제 에 부 딪 힐 것 이다.다 중 데이터 소스 가 가장 골 치 아 픈 것 은 여러 데이터 소스 를 설정 하 는 것 이 아니 라 데이터 소스 를 어떻게 유연 하고 동적 으로 전환 할 수 있 는 지 하 는 것 이다.예 를 들 어 spring 과 Mybatis 의 프레임 워 크 프로젝트 에서 저 희 는 spring 설정 에서 데이터 베 이 스 를 연결 하 는 dataSource 를 설정 한 다음 에 session Factory 에 연결 하고 dao 층 코드 에서 session Factory 를 지정 하여 데이터 베 이 스 를 조작 합 니 다.
 
위의 그림 에서 보 듯 이 모든 조각 은 묶 여 죽 는 것 을 지정 하고 여러 데이터 소스 라면 다음 그림 에서 만 그런 방식 일 수 있다.

Dao 층 코드 에 두 개의 Session Factory 가 죽 었 음 을 알 수 있 습 니 다.그러면 앞으로 데이터 원본 이 하나 더 있 으 면 코드 를 바 꾸 고 Session Factory 를 추가 해 야 합 니 다.이것 은 개폐 원칙 에 부합 되 지 않 습 니 다.
그렇다면 정확 한 방법 은:

구체 적 인 코드 와 설정 은 다음 과 같다.
1、applicationContext-mgr.xml

<?xml version="1.0" encoding="utf-8" ?>
<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:context="http://www.springframework.org/schema/context" 
  xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:p="http://www.springframework.org/schema/p"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
  <!-- use annotation -->
  <context:annotation-config />
    <context:component-scan base-package="com.carl.o2o.**.mgr">
  </context:component-scan>

  <!-- master -->
  <bean id="master" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="${driverClassName_master}"/>
    <property name="user" value="${username_master}"/>
    <property name="password" value="${password_master}"/>
    <property name="jdbcUrl" value="${url_master}?Unicode=true&amp;characterEncoding=UTF-8&amp;allowMultiQueries=true"/>

    <property name="maxPoolSize" value="150"/> 
    <property name="minPoolSize" value="10"/> 
    <property name="initialPoolSize" value="20"/> 
    <property name="maxIdleTime" value="3600"/> 
    <property name="acquireIncrement" value="10"/> 
    <property name="idleConnectionTestPeriod" value="1800"/>  
  </bean>

  <!-- slave -->
  <bean id="slave" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="${driverClassName_slave}"/>
    <property name="user" value="${username_slave}"/>
    <property name="password" value="${password_slave}"/>
    <property name="jdbcUrl" value="${url_slave}?Unicode=true&amp;characterEncoding=UTF-8"/>

    <property name="maxPoolSize" value="150"/> 
    <property name="minPoolSize" value="10"/> 
    <property name="initialPoolSize" value="20"/> 
    <property name="maxIdleTime" value="3600"/> 
    <property name="acquireIncrement" value="10"/> 
    <property name="idleConnectionTestPeriod" value="1800"/>  
  </bean>

  <!-- spring       -->
  <bean id="dynamicDataSource" class="com.carl.dbUtil.DynamicDataSource">
    <property name="targetDataSources"> 
      <map key-type="java.lang.String"> 
        <entry key="slave" value-ref="slave" /> 
      </map> 
    </property> 
    <property name="defaultTargetDataSource" ref="master" />   
  </bean> 

  <!-- mybatis mapper config -->
  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dynamicDataSource"/>
    <property name="configLocation" value="classpath:o2o_mybatis_config.xml"/>
    <property name="mapperLocations" >
      <list>
        <value>classpath:sqlMap/*.xml</value>
        <value>classpath*:/com/carl/o2o/**/*.xml</value>
      </list>
    </property>
  </bean>

  <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg index="0" ref="sqlSessionFactory"></constructor-arg>
  </bean>

  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.carl.o2o.**.mgr.dao" />
  </bean>

  <!--      aop -->
  <bean id="DataSourceAspect" class="com.carl.dbUtil.DataSourceAspect" />
  <aop:config> 
    <aop:advisor pointcut="execution(* com.carl.o2o.mgr.*.*(..))" advice-ref="DataSourceAspect" />
  </aop:config> 

  <!--    -->
  <bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  
    <property name="dataSource" ref="dynamicDataSource"></property>
  </bean>
 </beans>

2、DynamicDataSource
DynamicDataSource 는 Spring 의 코드 를 AOP 와 결합 하여 다 중 데이터 원본 전환 을 실현 합 니 다.

public class DynamicDataSource extends AbstractRoutingDataSource {
  public DynamicDataSource() {
  }

  protected Object determineCurrentLookupKey() {
    return DBContextHolder.getDbType();
  }

  public Logger getParentLogger() {
    return null;
  }
}

3、DBContextHolder
DynamicDataSource 의 보조 클래스 는 다 중 데이터 원본 을 실제 전환 하 는 데 사 용 됩 니 다.

public class DBContextHolder {
  private static ThreadLocal<String> contextHolder = new ThreadLocal();
  public static String MASTER = "master";
  public static String SLAVE = "slave";

  public DBContextHolder() {
  }

  public static String getDbType() {
    String db = (String)contextHolder.get();
    if(db == null) {
      db = MASTER;
    }

    return db;
  }

  public static void setDbType(String str) {
    contextHolder.set(str);
  }

  public static void setMaster() {
    contextHolder.set(MASTER);
  }

  public static void setSlave() {
    contextHolder.set(SLAVE);
  }

  public static void clearDBType() {
    contextHolder.remove();
  }
}

4、DataSourceAspect
다 중 데이터 원본 AOP 절단면 프로 그래 밍 실현.

public class DataSourceAspect implements MethodBeforeAdvice, AfterReturningAdvice, ThrowsAdvice {
  private static final Logger log = LogManager.getLogger(DataSourceAspect.class);

  public DataSourceAspect() {
  }

  public void before(Method m, Object[] args, Object target) throws Throwable {
    try {
      if(m != null) {
        if((m.getName().startsWith("list") || m.getName().startsWith("select") || m.getName().startsWith("get") 
        || m.getName().startsWith("count")) && !m.getName().contains("FromMaster")) {
          DBContextHolder.setDbType("slave");
        } else {
          DBContextHolder.setDbType("master");
        }
      }
    } catch (Exception var5) {
      log.error("data source aspect error.", var5);
    }

  }

  public void after(JoinPoint point) {
    log.info("clear db type after method.current id {}", new Object[]{Long.valueOf(Thread.currentThread().getId())});
    DBContextHolder.clearDBType();
  }

  public void afterReturning(Object returnValue, Method method, Object[] args, Object target) throws Throwable {
  }

  public void afterThrowing(Method method, Object[] args, Object target, Exception ex) throws Throwable {
    log.info("current db type {} when exception", new Object[]{DBContextHolder.getDbType()});
    DBContextHolder.setDbType("master");
  }
}

이상 은 Spring AOP 동적 다 중 데이터 소스 의 사례 상세 한 설명 입 니 다.궁금 한 점 이 있 으 시 면 메 시 지 를 남기 거나 본 사이트 의 커 뮤 니 티 에 가서 토론 하 십시오.읽 어 주 셔 서 감사합니다. 도움 이 되 셨 으 면 좋 겠 습 니 다.본 사이트 에 대한 지지 에 감 사 드 립 니 다!