Spring+Struts+ibatis上配置数据读写分离及事务(一)

   最近使用ssi框架,参考了一位网友写的ssh数据读写分离及相关资源做了一个ssi的数据读写分离测试,一是给刚刚接触SSI的朋友一个参考,其次也给自己存储下code笔记,有不到位的地方请大家多多指教。

   首先介绍我使用相关框架的版本,Spring2.5+struts2.1.6+ibatis2.3,数据库使用的是mysql,使用的jar包请在附件中下载.

  1.配置jdbc.properties,由于只是测试,所以读写分离使用的还是一个数据库,同一个用户名和密码.这个可以根据需求修改

#MySQL master 主要数据源 负责数据Update
master.jdbc.driverClassName=com.mysql.jdbc.Driver
master.jdbc.url=jdbc:mysql://localhost:3306/myweb?useUnicode=true&characterEncoding=utf-8
master.jdbc.username=root
master.jdbc.password=root

#MySQL slave 从数据源 负责数据Query
slave.jdbc.driverClassName=com.mysql.jdbc.Driver
slave.jdbc.url=jdbc:mysql://localhost:3306/myweb?useUnicode=true&characterEncoding=utf-8
slave.jdbc.username=root
slave.jdbc.password=root

 2.编写数据源处理类

public class DataSourceSwitch {
	@SuppressWarnings("rawtypes")
	private static final ThreadLocal contextHolder = new ThreadLocal();

	@SuppressWarnings("unchecked")
	public static void setDataSource(String dataSource) {
		Assert.notNull(dataSource, "数据源未创建成功!");
		contextHolder.set(dataSource);
	}
	public static void setMaster() {
		contextHolder.remove();
		contextHolder.set("master");
	}
	public static void setSlave() {
		contextHolder.remove();
		contextHolder.set("slave");
	}
    public static String getDataSouce(){
    	return contextHolder.get().toString();
    }
}

 3.编写数据源AOP切面类

public class DataSourceAdvice implements MethodBeforeAdvice,
		AfterReturningAdvice, ThrowsAdvice {
	private static Log log = LogFactory.getLog(DataSourceAdvice.class);
    private long beginTime=0;
	@Override
	/**
	 * SERVICE方法调用结束后调用
	 */
	public void afterReturning(Object arg, Method method, Object[] args,
			Object target) throws Throwable {
		log.info("结束业务处理[" + method.getName() + "];耗时:" + (System.currentTimeMillis()-beginTime)+"毫秒;全路径[" +target.getClass().getName()+ "]");
		log.info("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
	}

	@Override
	public void before(Method method, Object[] arg, Object target)
			throws Throwable {
		    log.info("开始业务处理["+method.getName()+"];全路径["+  target.getClass().getName()+"]");
		    beginTime=System.currentTimeMillis();
		    log.info("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
		   if(method.getName().startsWith("add")||method.getName().startsWith("create")
		      ||method.getName().startsWith("del")||method.getName().startsWith("edit")
		      ||method.getName().startsWith("insert")||method.getName().startsWith("save")
		      ||method.getName().startsWith("update")||method.getName().startsWith("modeify")){
			     log.info("数据源切换到:master"); 
			     DataSourceSwitch.setMaster();
			     log.info("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
		   }else{
			     log.info("数据源切换到:slave"); 
			     DataSourceSwitch.setSlave();
			     log.info("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
		   }
	}
	/**
	 * 抛出Exception异常调用
	 */
	public void afterThrowing(Method method, Object[] args, Object target, Exception ex) throws Throwable {
		 log.info("数据源调用发生异常,数据源切换到:slave");
		 DataSourceSwitch.setSlave();
		 log.error("数据源调用异常信息:"+ex.getMessage());
		 log.info("数据源调用异常信息:"+ex.getMessage());
		 log.info("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
	} 
}

 4.编写动态数据源切换AOP类

public class DynamicDataSource extends AbstractRoutingDataSource{

	@Override
	protected Object determineCurrentLookupKey() {
		return DataSourceSwitch.getDataSouce();
	}

}