Spring AOP切面解决数据库读写分离实例详解

<aop:config expose-proxy="true"> 
 
<aop:pointcut id="txPointcut" expression="execution(* com.test..persistence..*.*(..))" /> 
 
<aop:aspect ref="readWriteInterceptor" order="1"> 
 
<aop:around pointcut-ref="txPointcut" method="readOrWriteDB"/> 
 
</aop:aspect> 
 
</aop:config> 
 
  
 
<bean id="readWriteInterceptor" class="com.test.ReadWriteInterceptor"> 
 
  <property name="readMethodList"> 
 
   <list> 
 
    <value>query*</value> 
 
    <value>use*</value> 
 
    <value>get*</value> 
 
    <value>count*</value> 
 
    <value>find*</value> 
 
    <value>list*</value> 
 
    <value>search*</value> 
 
  </list> 
 
 </property> 
 
<property name="writeMethodList"> 
 
  <list> 
 
    <value>save*</value> 
 
    <value>add*</value> 
 
    <value>create*</value> 
 
    <value>insert*</value> 
 
    <value>update*</value> 
 
    <value>merge*</value> 
 
    <value>del*</value> 
 
    <value>remove*</value> 
 
    <value>put*</value> 
 
    <value>write*</value> 
 
  </list> 
 
</property> 
 
</bean> 

public class ReadWriteInterceptor { 
  private static final String DB_SERVICE = "dbService"; 
  private List<String> readMethodList = new ArrayList<String>(); 
  private List<String> writeMethodList = new ArrayList<String>(); 

  public Object readOrWriteDB(ProceedingJoinPoint pjp) throws Throwable { 
    String methodName = pjp.getSignature().getName(); 
    if (isChooseReadDB(methodName)) { 
      //选择slave数据源 
    } else if (isChooseWriteDB(methodName)) { 
      //选择master数据源 
    } else { 
     //选择master数据源 
    } 
    return pjp.proceed(); 
} 
 
 private boolean isChooseWriteDB(String methodName) { 
   for (String mappedName : this.writeMethodList) { 
     if (isMatch(methodName, mappedName)) { 
       return true; 
     } 
   } 
  return false; 
} 
 
 private boolean isChooseReadDB(String methodName) { 
  for (String mappedName : this.readMethodList) { 
    if (isMatch(methodName, mappedName)) { 
      return true; 
    } 
  } 
  return false; 
} 
 
 private boolean isMatch(String methodName, String mappedName) { 
  return PatternMatchUtils.simpleMatch(mappedName, methodName); 
} 
 
 public List<String> getReadMethodList() { 
  return readMethodList; 
 } 
 
 public void setReadMethodList(List<String> readMethodList) { 
  this.readMethodList = readMethodList; 
} 
 
 public List<String> getWriteMethodList() { 
  return writeMethodList; 
 } 
 
 public void setWriteMethodList(List<String> writeMethodList) { 
  this.writeMethodList = writeMethodList; 
} 
 

public class MyTransactionManager extendsDataSourceTransactionManager{ 
 
@Override 
 
protected void doBegin(Object transaction, TransactionDefinitiondefinition) { 
 
//选择master数据库 
 
super.doBegin(transaction, definition); 
 
} 
 
}