使用Adivisor配置增强处理，来实现数据库读写分离

一、先写一个demo来概述Adivisor的简单使用步骤

实现步骤：

1、通过MethodBeforeAdivice接口实现前置增强处理

public class ServiceBeforeAdvisor implements MethodBeforeAdvice {
    private Logger logger = Logger.getLogger(ServiceBeforeAdvisor.class);
    @Override
    public void before(Method method, Object[] args, Object target)
            throws Throwable {
        logger.info("启动事务");
        logger.info("连接点对象："+target.getClass().getSimpleName());
        logger.info("连接点方法："+method.getName());
        logger.info("连接点方法参数："+args[0]);
        
    }
    
}

2、使用<aop:advisor>标签织入增强处理

//注意：advisor要放在aspect前面
    <bean id="userService" class="com.pb.service.UserService"></bean>
     <bean id="serviceBeforeAdvisor" class="com.pb.aop.ServiceBeforeAdvisor"></bean>
     <aop:config>
         <aop:pointcut expression="execution(public * com.pb.service.*.*(..))" 
　　　　　　　　　　　　　　　　id="servicePointcut"/>
         <aop:advisor advice-ref="serviceBeforeAdvisor" pointcut-ref="servicePointcut"/>
     </aop:config>

3、测试类型

public class Test {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext
　　　　　　　　　　　　　　　　　　　　("applicationContext.xml");
        UserService service =  (UserService)context.getBean("userService");
        service.addUser(new User());
    }
}

二、使用Adivisor来实现数据读写分离

实现步骤：

1、通过MethodBeforeAdivice接口实现前置增强处理

public class DataBaseAdvice implements MethodBeforeAdvice {
    /**
     * 日志计数器
     */
    private final static Logger logger = LoggerFactory.getLogger(DataBaseAdvice.class);
    /**
     * 存储方法前缀
     */
    private List<String> methodKey;
    /**
     * 是否打印日志：true-打印，false-不打印
     */
    private boolean showLog = true;

    public void before(Method method, Object[] objects, Object o) throws Throwable {
        boolean write = true;
        String methodName = method.getName().toLowerCase();
        //若方法前缀匹配成功，返回false
        if (CollectionUtils.isNotEmpty(methodKey)) {
            for (String key : methodKey) {
                if (methodName.startsWith(key.toLowerCase())) {
                    write = false;
                    break;
                }
            }
        }

        if (write) {
            DbContextHolder.setDbType(DbContextHolder.DB_TYPE_RW);
            if (showLog) {
                logger.info(method.getName()+"连接主库");
            }
        }else {
            DbContextHolder.setDbType(DbContextHolder.DB_TYPE_R);
            if (showLog) {
                logger.info(method.getName()+"连接从库");
            }
        }
    }

    public List<String> getMethodKey() {
        return methodKey;
    }

    public void setMethodKey(List<String> methodKey) {
        this.methodKey = methodKey;
    }

    public boolean isShowLog() {
        return showLog;
    }

    public void setShowLog(boolean showLog) {
        this.showLog = showLog;
    }
}

切换主从库的持有类

public class DbContextHolder {

    /**
     * 线程threadLocal
     */
    private static ThreadLocal<String> contextHolder = new ThreadLocal<String>();
    /**
     * 主库：执行读写操作
     */
    public static String DB_TYPE_RW = "dataSourceMaster";
    /**
     * 从库：执行读库操作
     */
    public static String DB_TYPE_R = "dataSourceSlave";

    /**
     * 默认是读写库
     * @return
     */
    public static String getDbType() {
        String db = contextHolder.get();
        if (db == null) {
            db = DB_TYPE_RW;
        }
        return db;
    }

    /**
     * 置本线程的dbType
     * @param str
     */
    public static void setDbType(String str) {
        contextHolder.set(str);
    }

    /**
     * @Title: clearDBType
     * @Description: 清理连接类型
     */
    public static void clearDBType() {
        contextHolder.remove();
    }
}

2、使用<aop:advisor>标签织入增强处理

<!-- 动态数据源 -->
    <bean id="dynamicDataSource" class="com.alibaba.health.dao.dynamic.DynamicDataSource">
        <!-- 通过key-value关联数据源 -->
        <property name="targetDataSources">
            <map>
                <entry value-ref="dataSourceMaster" key="monitorDataSourceMaster"/>
                <entry value-ref="dataSourceSlave" key="monitorDataSourceSlave"/>
            </map>
        </property>
        <property name="defaultTargetDataSource" ref="dataSourceMaster"/>
    </bean>

<!-- 通知器的具体实现：配置主从库读写分离：以select、query、find、count开头的方法走从库 -->
    <bean id="DataBaseAdvice" class="com.aliaba.health.dao.dynamic.DataBaseAdvice">
        <property name="methodKey">
            <list>
                <value>select</value>
                <value>query</value>
                <value>find</value>
                <value>count</value>
            </list>
        </property>
        <property name="showLog" value="false"/>
    </bean>

    <!-- 切面配置 -->
    <aop:config>
        <!-- 配置切点：第一个*表示匹配所有方法的返回值类型，.表示当前包下所有类的方法，..表示当前包下及此包下所有自爆中的所有类方法；
             第二个*表示所有类名，第三个*表示所有方法名，(..)表示所有方法参数-->
        <aop:pointcut expression="execution(* com.alibaba.health.dao..*.*(..))" id="cutPoint"/>
        <!-- 定义通知器 -->
        <aop:advisor advice-ref="DataBaseAdvice" pointcut-ref="cutPoint"/>
    </aop:config>

此时就完成了主从数据库读写分离的代码和xml配置，尤其可见各种技术组件，在于是否能灵活运用。