springboot结合mysql主从来实现读写分离的方法示例
1.实现的功能
基于springboot框架,application.yml配置多个数据源,使用AOP以及AbstractRootingDataSource、ThreadLocal来实现多数据源切换,以实现读写分离。mysql的主从数据库需要进行设置数据之间的同步。
2.代码实现
application.properties中的配置
spring.datasource.druid.master.driver-class-name=com.mysql.jdbc.Driver spring.datasource.druid.master.url=jdbc:mysql://127.0.0.1:3306/node2?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false spring.datasource.druid.master.username=root spring.datasource.druid.master.password=123456 spring.datasource.druid.slave.driver-class-name=com.mysql.jdbc.Driver spring.datasource.druid.slave.url=jdbc:mysql://127.0.0.1:3306/node1?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false spring.datasource.druid.slave.username=root spring.datasource.druid.slave.password=123456
写一个DataSourceConfig.java来注入两个bean
@Bean @ConfigurationProperties("spring.datasource.druid.master") public DataSource masterDataSource() { logger.info("select master data source"); return DruidDataSourceBuilder.create().build(); } @Bean @ConfigurationProperties("spring.datasource.druid.slave") public DataSource slaveDataSource() { logger.info("select slave data source"); return DruidDataSourceBuilder.create().build(); }
写一个enum来标识有哪些数据源
public enum DBTypeEnum { MASTER, SLAVE; }
然后写一个ThreadLocal本地线程的管理类,用于设置当前线程是那一个数据源
private static final ThreadLocal<DBTypeEnum> contextHolder = new ThreadLocal<>(); private static final ThreadLocal<DBTypeEnum> contextHolder2 = ThreadLocal.withInitial(() -> DBTypeEnum.MASTER); public static void set(DBTypeEnum dbType) { contextHolder.set(dbType); } public static DBTypeEnum get() { return contextHolder.get(); } public static void master() { set(DBTypeEnum.MASTER); logger.info("切换到master数据源"); } public static void slave() { set(DBTypeEnum.SLAVE); logger.info("切换到slave数据源"); } public static void cleanAll() { contextHolder.remove(); }
然后写一个DynamicDataSource继承AbstractRootingDataSource,重写它的determineCurrentLookupKey方法。
public class DynamicDataSource extends AbstractRoutingDataSource { private Logger logger = LogManager.getLogger(DynamicDataSource.class); @Override protected Object determineCurrentLookupKey() { logger.info("此时数据源为{}", DBContextHolder.get()); return DBContextHolder.get(); } }
最后写一个AOP来实现数据源切换
@Aspect @Order(1) @Component public class DataSourceAop { private Logger logger = LogManager.getLogger(DataSourceAop.class); @Pointcut("(execution(* com.springboot.demo.service..*.select*(..)) " + "|| execution(* com.springboot.demo.service..*.find*(..)) " + "|| execution(* com.springboot.demo.service..*.get*(..)))") public void readPointcut() { logger.info("read only operate ,into slave db"); } @Pointcut("execution(* com.springboot.demo.service..*.insert*(..)) " + "|| execution(* com.springboot.demo.service..*.update*(..)) " + "|| execution(* com.springboot.demo.service..*.delete*(..)) ") public void writePointcut() { logger.info("read or write operate ,into master db"); } @Before("readPointcut()") public void read() { logger.info("read operate"); DBContextHolder.slave(); } @Before("writePointcut()") public void write() { logger.info("write operate"); DBContextHolder.master(); } @After("writePointcut(),readPointcut()") public void clean() { logger.info("dataSource cleanAll"); DBContextHolder.cleanAll(); } }
注意:这里只是使用了偷懒的方法,对于service里面的select、get、find前缀的方法都使用从库,对于insert、update和delete方法都使用主库。
可以使用注解如下来进行优化:
@Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface DataSource { @AliasFor("dataSource") DBTypeEnum value() default DBTypeEnum.MASTER; DBTypeEnum dataSource() default DBTypeEnum.MASTER; }
使用此注解来放入到service方法上,
@DataSource(DBTypeEnum.SLAVE)
然后AOP方法修改为:
private static final String POINT = "execution (* com.springboot.demo.service.*.*(..))"; @Around(POINT) public Object dataSourceAround(ProceedingJoinPoint joinPoint) throws Throwable { Object[] args = joinPoint.getArgs(); Object obj; Object target = joinPoint.getTarget(); String methodName = joinPoint.getSignature().getName(); Class clazz = target.getClass(); Class<?>[] parameterTypes = ((MethodSignature) joinPoint.getSignature()).getMethod().getParameterTypes(); boolean isDynamicDataSourceMethod = false; try { Method method = clazz.getMethod(methodName, parameterTypes); DataSources currentDataSource = null; if (method != null && method.isAnnotationPresent(DataSource.class)) { isDynamicDataSourceMethod = true; currentDataSource = method.getAnnotation(DataSource.class).value(); DataSourceTypeManager.set(currentDataSource); log.info("DataSourceInterceptor Switch DataSource To {}",currentDataSource); } obj = joinPoint.proceed(args); if (isDynamicDataSourceMethod) { log.info("DataSourceInterceptor DataSource {} proceed",currentDataSource); } } finally { if (isDynamicDataSourceMethod) { DataSourceTypeManager.reset(); log.info("DataSourceInterceptor Reset DataSource To {}",DataSourceTypeManager.get()); } } return obj; }
到此这篇关于springboot结合mysql主从来实现读写分离的方法示例的文章就介绍到这了,更多相关springboot 读写分离内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
- 这篇文章主要介绍了MySQL性能监控软件Nagios的安装及配置教程,这里以CentOS操作系统为环境进行演示,需要的朋友可以参考下...2015-12-14
解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题
这篇文章主要介绍了解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-04-28- 新版 Mysql 中加入了对 JSON Document 的支持,可以创建 JSON 类型的字段,并有一套函数支持对JSON的查询、修改等操作,下面就实际体验一下...2016-08-23
- 这篇文章主要为大家详细介绍了SpringBoot实现excel文件生成和下载,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-02-09
深入研究mysql中的varchar和limit(容易被忽略的知识)
为什么标题要起这个名字呢?commen sence指的是那些大家都应该知道的事情,但往往大家又会会略这些东西,或者对这些东西一知半解,今天我总结下自己在mysql中遇到的一些commen sense类型的问题。 ...2015-03-15- 这篇文章主要介绍了MySQL 字符串拆分操作(含分隔符的字符串截取),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-22
- 这篇文章主要介绍了详解springBoot启动时找不到或无法加载主类解决办法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-16
- 一、先说一下为什么要分表:当一张的数据达到几百万时,你查询一次所花的时间会变多,如果有联合查询的话,有可能会死在那儿了。分表的目的就在于此,减小数据库的负担,缩短查询时间。根据个人经验,mysql执行一个sql的过程如下:1...2014-05-31
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
- 这篇文章主要介绍了解决Springboot get请求是参数过长的情况,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-09-17
- 我们自己鼓捣mysql时,总免不了会遇到这个问题:插入中文字符出现乱码,虽然这是运维先给配好的环境,但是在自己机子上玩的时候咧,总得知道个一二吧,不然以后如何优雅的吹牛B。...2015-03-15
Spring Boot项目@RestController使用重定向redirect方式
这篇文章主要介绍了Spring Boot项目@RestController使用重定向redirect方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-02- 这篇文章主要介绍了Springboot+TCP监听服务器搭建过程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-10-28
- 宿主机使用网线的时候,客户机在Bridged Adapter模式下,使用Atheros AR8131 PCI-E Gigabit Ethernet Controller上网没问题。 宿主机使用无线的时候,客户机在Bridged Adapter模式下,使用可选项里唯一一个WIFI选项,Microsoft Virtual Wifi Miniport Adapter也无法上网,故弃之。...2013-09-19
- 这几天在centos下装mysql,这里记录一下安装的过程,方便以后查阅Mysql5.5.37安装需要cmake,5.6版本开始都需要cmake来编译,5.5以后的版本应该也要装这个。安装cmake复制代码 代码如下: [root@local ~]# wget http://www.cm...2015-03-15
- 这篇文章主要介绍了springBoot 项目排除数据库启动方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-10
- 首先要声明一点,大部分情况下,修改MySQL密码是需要有mysql里的root权限的...2013-09-11
- MySQL命令行导出数据库: 1,进入MySQL目录下的bin文件夹:cd MySQL中到bin文件夹的目录 如我输入的命令行:cd C:/Program Files/MySQL/MySQL Server 4.1/bin (或者直接将windows的环境变量path中添加该目录) ...2013-09-26
- 一、连接Mysql格式: mysql -h主机地址 -u用户名 -p用户密码1、连接到本机上的MYSQL。首先打开DOS窗口,然后进入目录mysql/bin,再键入命令mysql -u root -p,回车后提示你输密码.注意用户名前可以有空格也可以没有空格,但是密...2015-11-08
springboot中使用@Transactional注解事物不生效的坑
这篇文章主要介绍了springboot中使用@Transactional注解事物不生效的原因,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-01-26