开源软件名称： zeq9069/koala开源软件地址： https://github.com/zeq9069/koala开源编程语言：
Java
100.0%
开源软件介绍： #koala
##多数据源动态切换
#####支持数据源分组和简单的负载均衡(轮询)
作者：kyrin(云中鹤) [email protected]
##项目简介
在公司开发的过程中，用到主从库的切换，于是就想自己动手实现一个可以实现多库之间的随意切
换。于是该项目就产生了！该项目基于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&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&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&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&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&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
客服电话
APP下载
官方微信
请发表评论