设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

详解使用spring aop实现业务层mysql 读写分离

2017-3-7 12:50| 发布者: zhangjf| 查看: 1270| 评论: 0

摘要: spring aop ， mysql 主从配置 实现读写分离，接下来把自己的配置过程，以及遇到的问题记录下来，方便下次操作，也希望给一些朋友带来帮助。 1.使用spring aop 拦截机制现数据源的动态选取。 import java.lang.ann ...

spring aop ， mysql 主从配置 实现读写分离，接下来把自己的配置过程，以及遇到的问题记录下来，方便下次操作，也希望给一些朋友带来帮助。

1.使用spring aop 拦截机制现数据源的动态选取。

  2. import java.lang.annotation.ElementType;
  3. import java.lang.annotation.Target;
  4. import java.lang.annotation.Retention;
  5. import java.lang.annotation.RetentionPolicy;
  6. /**
  7. * RUNTIME
  8. * 编译器将把注释记录在类文件中，在运行时 VM 将保留注释，因此可以反射性地读取。
  9. * @author yangGuang
  10. *
  11. */
  12. @Retention(RetentionPolicy.RUNTIME)
  13. @Target(ElementType.METHOD)
  14. public @interface DataSource {
  15. String value();
  16. }
复制代码

3.利用Spring的AbstractRoutingDataSource解决多数据源的问题

  2. import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
  4. public class ChooseDataSource extends AbstractRoutingDataSource {
  6. @Override
  7. protected Object determineCurrentLookupKey() {
  8. return HandleDataSource.getDataSource();
  9. }
  11. }
复制代码

4.利用ThreadLocal解决线程安全问题

  2. public class HandleDataSource {
  3. public static final ThreadLocal<String> holder = new ThreadLocal<String>();
  4. public static void putDataSource(String datasource) {
  5. holder.set(datasource);
  6. }
  8. public static String getDataSource() {
  9. return holder.get();
  10. }
  11. }
复制代码

5.定义一个数据源切面类，通过aop访问，在spring配置文件中配置了，所以没有使用aop注解。

  2. import java.lang.reflect.Method;
  3. import org.aspectj.lang.JoinPoint;
  4. import org.aspectj.lang.annotation.Aspect;
  5. import org.aspectj.lang.annotation.Before;
  6. import org.aspectj.lang.annotation.Pointcut;
  7. import org.aspectj.lang.reflect.MethodSignature;
  8. import org.springframework.stereotype.Component;
  9. //@Aspect
  10. //@Component
  11. public class DataSourceAspect {
  12. //@Pointcut("execution(* com.apc.cms.service.*.*(..))")
  13. public void pointCut(){};
  15. // @Before(value = "pointCut()")
  16. public void before(JoinPoint point)
  17. {
  18. Object target = point.getTarget();
  19. System.out.println(target.toString());
  20. String method = point.getSignature().getName();
  21. System.out.println(method);
  22. Class<?>[] classz = target.getClass().getInterfaces();
  23. Class<?>[] parameterTypes = ((MethodSignature) point.getSignature())
  24. .getMethod().getParameterTypes();
  25. try {
  26. Method m = classz[0].getMethod(method, parameterTypes);
  27. System.out.println(m.getName());
  28. if (m != null && m.isAnnotationPresent(DataSource.class)) {
  29. DataSource data = m.getAnnotation(DataSource.class);
  30. HandleDataSource.putDataSource(data.value());
  31. }
  33. } catch (Exception e) {
  34. e.printStackTrace();
  35. }
  36. }
  37. }
复制代码

6.配置applicationContext.xml

  2. <!-- 主库数据源 -->
  3. <bean id="writeDataSource" class="com.jolbox.bonecp.BoneCPDataSource" destroy-method="close">
  4. <property name="driverClass" value="com.mysql.jdbc.Driver"/>
  5. <property name="jdbcUrl" value="jdbc:mysql://172.22.14.6:3306/cpp?autoReconnect=true"/>
  6. <property name="username" value="root"/>
  7. <property name="password" value="root"/>
  8. <property name="partitionCount" value="4"/>
  9. <property name="releaseHelperThreads" value="3"/>
  10. <property name="acquireIncrement" value="2"/>
  11. <property name="maxConnectionsPerPartition" value="40"/>
  12. <property name="minConnectionsPerPartition" value="20"/>
  13. <property name="idleMaxAgeInSeconds" value="60"/>
  14. <property name="idleConnectionTestPeriodInSeconds" value="60"/>
  15. <property name="poolAvailabilityThreshold" value="5"/>
  16. </bean>
  18. <!-- 从库数据源 -->
  19. <bean id="readDataSource" class="com.jolbox.bonecp.BoneCPDataSource" destroy-method="close">
  20. <property name="driverClass" value="com.mysql.jdbc.Driver"/>
  21. <property name="jdbcUrl" value="jdbc:mysql://172.22.14.7:3306/cpp?autoReconnect=true"/>
  22. <property name="username" value="root"/>
  23. <property name="password" value="root"/>
  24. <property name="partitionCount" value="4"/>
  25. <property name="releaseHelperThreads" value="3"/>
  26. <property name="acquireIncrement" value="2"/>
  27. <property name="maxConnectionsPerPartition" value="40"/>
  28. <property name="minConnectionsPerPartition" value="20"/>
  29. <property name="idleMaxAgeInSeconds" value="60"/>
  30. <property name="idleConnectionTestPeriodInSeconds" value="60"/>
  31. <property name="poolAvailabilityThreshold" value="5"/>
  32. </bean>
  34. <!-- transaction manager, 事务管理 -->
  35. <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  36. <property name="dataSource" ref="dataSource" />
  37. </bean>
  40. <!-- 注解自动载入 -->
  41. <context:annotation-config />
  43. <!--enale component scanning (beware that this does not enable mapper scanning!)-->
  44. <context:component-scan base-package="com.apc.cms.persistence.rdbms" />
  45. <context:component-scan base-package="com.apc.cms.service">
  46. <context:include-filter type="annotation"
  47. expression="org.springframework.stereotype.Component" />
  48. </context:component-scan>
  50. <context:component-scan base-package="com.apc.cms.auth" />
  52. <!-- enable transaction demarcation with annotations -->
  53. <tx:annotation-driven />
  56. <!-- define the SqlSessionFactory -->
  57. <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  58. <property name="dataSource" ref="dataSource" />
  59. <property name="typeAliasesPackage" value="com.apc.cms.model.domain" />
  60. </bean>
  62. <!-- scan for mappers and let them be autowired -->
  63. <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
  64. <property name="basePackage" value="com.apc.cms.persistence" />
  65. <property name="sqlSessionFactory" ref="sqlSessionFactory" />
  66. </bean>
  68. <bean id="dataSource" class="com.apc.cms.utils.ChooseDataSource">
  69. <property name="targetDataSources">
  70. <map key-type="java.lang.String">
  71. <!-- write -->
  72. <entry key="write" value-ref="writeDataSource"/>
  73. <!-- read -->
  74. <entry key="read" value-ref="readDataSource"/>
  75. </map>
  77. </property>
  78. <property name="defaultTargetDataSource" ref="writeDataSource"/>
  79. </bean>
  81. <!-- 激活自动代理功能 -->
  82. <aop:aspectj-autoproxy proxy-target-class="true"/>
  84. <!-- 配置数据库注解aop -->
  85. <bean id="dataSourceAspect" class="com.apc.cms.utils.DataSourceAspect" />
  86. <aop:config>
  87. <aop:aspect id="c" ref="dataSourceAspect">
  88. <aop:pointcut id="tx" expression="execution(* com.apc.cms.service..*.*(..))"/>
  89. <aop:before pointcut-ref="tx" method="before"/>
  90. </aop:aspect>
  91. </aop:config>
  92. <!-- 配置数据库注解aop -->
复制代码

7.使用注解，动态选择数据源，分别走读库和写库。

  2. @DataSource("write")
  3. public void update(User user) {
  4. userMapper.update(user);
  5. }
  7. @DataSource("read")
  8. public Document getDocById(long id) {
  9. return documentMapper.getById(id);
  10. }
复制代码

测试写操作：可以通过应用修改数据，修改主库数据，发现从库的数据被同步更新了，所以定义的write操作都是走的写库

测试读操作： 后台修改从库数据，查看主库的数据没有被修改，在应用页面中刷新，发现读的是从库的数据，说明读写分离ok。

遇到的问题总结：

问题1：项目是maven工程，用到了Spring aop机制，除了spring的核心jar包以为，还需要用到的jar包有aspectj.jar，aspectjweaver.jar，aopalliance.jar查看项目中的pom，发现缺少依赖包，由于本地仓库没有这些jar，查找可以提供下载jar包的maven中央库库，配置到maven中,自动更新：

  2. <repository>
  3. <id>nexus</id>
  4. <name>nexus</name>
  5. <url>http://repository.sonatype.org/content/groups/public/</url>
  6. <layout>default</layout>
  7. </repository>
复制代码

配置项目依赖的jar，主要是缺少这两个。

  2. <dependency>
  3. <groupId>aspectj</groupId>
  4. <artifactId>aspectjrt</artifactId>
  5. <version>1.5.4</version>
  6. </dependency>
  7. <dependency>
  8. <groupId>aspectj</groupId>
  9. <artifactId>aspectjweaver</artifactId>
  10. <version>1.5.4</version>
  11. lt;/dependency>
复制代码

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持程序员之家。

收藏 邀请
上一篇：完美解决java.lang.OutOfMemoryError处理错误的问题下一篇：JAVA实现读取txt文件内容的方法

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-4 02:36

Copyright 2015-2025 djqfx

返回顶部