koala: A Java repository from WangJunTYTL

#koala

##多数据源动态切换

#####支持数据源分组和简单的负载均衡(轮询)

作者：kyrin(云中鹤) kyrincloud@qq.com

##项目简介

    在公司开发的过程中，用到主从库的切换，于是就想自己动手实现一个可以实现多库之间的随意切
 换。于是该项目就产生了！该项目基于spring2.0.1才添加的的AbstractRutingDataSource类，同时利
 用AspectJ项目实现aop, 从而实现数据源的动态切换。
    该项目由最初的的demo项目mydemo/AspectJDemo孵化而来。

##功能目标

####该项目基本上确定了所拥有的功能： 1.通过注解项目中自定义的@ChangeTo注解来实现，将该注解放到service层的方法的前即可,该注解拥有默认的数据源

2.还可以手动切换，利用DynamicDataSource.changeTo()方法来实现。手动切换只能用在一种情况下，那就是事务必须在数据持久层进行管理，在@Transaction下失效。

3.可以通过注解@DataSourceDistribute注解，对service层的实现类进行类级别的注解，然后可通过正则表达式来实现针对不同的方法使用指定的注解。

####支持数据源分组和简单的负载均衡(轮询) 1.负载均衡。在配置了多主多从的数据源的情况下，利用@DataSourceGroup把service层的方法与数据源组进行对应，当方法执行时，自动从数据源组中轮训数据源进行切换，从而达到均衡负载的目的。

####后期添加功能： 1.监控模块和过滤功能。后期会添加对你添加的每个注解进行流量监控，可以查看每个注解的流量大小，还可以进行限流，当某个注解的并发访问量查过你设置的最大的值时，会放弃请求。你自己也可以对过滤某块进行扩展，将你实现的过滤类进行设置，注入到aspect中，在每个注解运行前后都会执行。

##配置方式

	在配置DynamicDataSource数据源的时候，必须配置defaultTargetDataSource在这个关键字对应的数据源，否则报错！
defaultTargetDataSource是默认数据源。

####db.xml中的配置：

<bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  	<property name="driverClass" value="com.mysql.jdbc.Driver" />
	 <property name="jdbcUrl"
	   value="jdbc:mysql://localhost:3306/demo?useUnicode=true&amp;characterEncoding=UTF-8"/>
	 <property name="user" value="root"/>
	 <property name="password" value="root"/>
	 <property name="maxIdleTime" value="6000"/>
	 <property name="maxPoolSize" value="3" />
	 <property name="minPoolSize" value="1" />
  </bean>
  <bean id="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource">
	 <property name="driverClass" value="com.mysql.jdbc.Driver" />
	 <property name="jdbcUrl" 
	   value="jdbc:mysql://localhost:3306/demo1?useUnicode=true&amp;characterEncoding=UTF-8"/>
	 <property name="user" value="root"/>
	 <property name="password" value="root"/>
	 <property name="maxIdleTime" value="6000"/>
	 <property name="maxPoolSize" value="3" />
	 <property name="minPoolSize" value="1" />
  </bean>
  <bean id="dataSource3" class="com.mchange.v2.c3p0.ComboPooledDataSource">
	 <property name="driverClass" value="com.mysql.jdbc.Driver" />
	 <property name="jdbcUrl" 
	   value="jdbc:mysql://localhost:3306/demo2?useUnicode=true&amp;characterEncoding=UTF-8"/>
	 <property name="user" value="root"/>
	 <property name="password" value="root"/>
	 <property name="maxIdleTime" value="6000"/>
	 <property name="maxPoolSize" value="3" />
	 <property name="minPoolSize" value="1" />
  </bean>
  <bean id="dataSource4" class="com.mchange.v2.c3p0.ComboPooledDataSource">
	 <property name="driverClass" value="com.mysql.jdbc.Driver" />
	 <property name="jdbcUrl" 
	   value="jdbc:mysql://localhost:3306/demo3?useUnicode=true&amp;characterEncoding=UTF-8"/>
	 <property name="user" value="root"/>
	 <property name="password" value="root"/>
	 <property name="maxIdleTime" value="6000"/>
	 <property name="maxPoolSize" value="3" />
	 <property name="minPoolSize" value="1" />
  </bean>
  <bean id="dataSource5" class="com.mchange.v2.c3p0.ComboPooledDataSource">
	 <property name="driverClass" value="com.mysql.jdbc.Driver" />
	 <property name="jdbcUrl" 
	   value="jdbc:mysql://localhost:3306/demo5?useUnicode=true&amp;characterEncoding=UTF-8"/>
	 <property name="user" value="root"/>
	 <property name="password" value="root"/>
	 <property name="maxIdleTime" value="6000"/>
	 <property name="maxPoolSize" value="3" />
	 <property name="minPoolSize" value="1" />
  </bean>
  <bean id="dataSource" class="com.demo.AspectJDemo.datasource.DynamicDataSource">
	 <property name="targetDataSources">
		<map>
			<entry key="defaultTargetDataSource" value-ref="dataSource1" />
			<entry key="master" value-ref="dataSource5" />
			<entry key="slave1" value-ref="dataSource2" />
			<entry key="slave2" value-ref="dataSource3" />
			<entry key="slave3" value-ref="dataSource4" />
		</map>
	</property>		
	<!--（可选项）对上述的 key值进行分组配置，让数据源切换时，可以通过注解@DataSourceGroup按组进行轮训切换，这样也可以达到负载均衡的效果-->		
	<property name="dataSourceKeysGroup">
		<map>
			<entry key="master-group">
			  <list>
					<value>defaultTargetDataSource</value>
					<value>master</value>
				</list>
			</entry>
			<entry key="slave-group">
				<list>
					<value>slave1</value>
					<value>slave2</value>
					<value>slave3</value>
				</list>
			</entry>
		</map>
	</property>
</bean>
<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
	<property name="dataSource" ref="dataSource" />
	<property name="hibernateProperties">
		<props>
    <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect </prop>
    <prop key="hibernate.show_sql">true</prop>
    <prop key="hibernate.format_sql">true</prop>
    <prop key="hibernate.hbm2ddl.auto">update</prop>
  </props>
	</property>
	<property name="packagesToScan">
  <list>
    <value>com.demo.AspectJDemo.domain</value>
  </list>
</property>
</bean>
<bean id="transactionManager"
   class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory"/>

####spring.xml中的配置：（必须注册） <koala:default-aspect />

<!-- 只用cglib代理，替换掉默认的JDK动态代理,order必须大于@Aspect的order，也就是必须大于0-->
<aop:aspectj-autoproxy proxy-target-class="true" order="6000"/>

##使用案例

/**
 *@DataSourceDistribute和@changeTo同时使用时，符合“就近原则”，
 *@changeTo会覆盖@DataSourceDistribute
 *
 *  当@DataSourceDistribute和@DataSourceGroup同事出现的时候，如果两个注解同事覆盖
 *同一个方法时，@DataSourceDistribute要覆盖@DataSourceGroup的配置。
 *我们核心的三个注解的优先级如下：
 *
 * @ChangeTo > @DataSourceDistibute > @DataSourceGroup
 *
 */
@Service("userService")
@DataSourceDistribute(value={@DataSourceEntity(method="create*|delete*|update*"),@DataSourceEntity(dataSource="slave",method="find*")})
@DataSourceGroup(groups={@Group(groupName="slave-group",methodPattern="delete*"),@Group(groupName="master-group",methodPattern="create*")})

public class UserServiceImpl implements UserService{

  private static Logger logger=Logger.getLogger(UserServiceImpl.class);

  @Autowired
private UserReponsitory userReponsitory;

  @changeTo
  @Transactional(readOnly=false)
  public String create() {
	  logger.info("Starting create a new User !");
	  userReponsitory.create();
	  return "success";
  }

    @Transactional(readOnly=false)
   public void delete(String id) {
	  logger.info("Starting dalete a new User !");
	  userReponsitory.create();
  }

  @changeTo(value="slave")
  @Transactional(readOnly=false)
  public void update() {
	  logger.info("Starting update a new User !");
 }
  @changeTo(value="slave")
  @Transactional(readOnly=true)
  public void search() {
	 logger.info("Starting search a new User !");
 }
}

##遇到的问题

1.遇到的最大的问题，就是当使用@Transaction注解时，@ChangeTo和@DataSourceDistribute注解切换数据源失败！这是因为@Transaction注解先于自定义的注解运行了！最后通过加Order来实现了顺序的颠倒。

##Demo

mydemo/AspectJDemo

WangJunTYTL/koala