springboot结合mysql主从来实现读写分离的方法示例

更新时间：2021年04月18日 16:21:48 作者：yancun93

这篇文章主要介绍了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 读写分离内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Activiti流程引擎对象及配置原理解析
这篇文章主要介绍了Activiti流程引擎对象及配置原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03
SpringBoot扩展点EnvironmentPostProcessor实例详解
这篇文章主要介绍了SpringBoot扩展点EnvironmentPostProcessor的相关知识，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2022-04-04
详解Java中的pinpoint1.8.5安装及使用指南
pinpoint是开源在github上的一款APM监控工具，它是用Java编写的，用于大规模分布式系统监控。这篇文章主要介绍了pinpoint1.8.5安装及使用指南,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下
2019-10-10
Java Stream API与函数式编程的实战详解
Java 8引入的Stream API和函数式编程特性,彻底改变了Java开发者编写代码的方式,本文将深入探讨Java Stream API与函数式编程的核心概念,最佳实践以及性能优化技巧,感兴趣的小伙伴可以了解下
2025-06-06
Java中清空集合列表元素的四种方法
Java清空列表有多种方式,包括clear()高效直接、创建新列表需注意引用、removeAll需传入集合、循环移除效率低,下面就来介绍一下如何实现,感兴趣的可以了解一下
2025-07-07
关于json解析多层嵌套并转为对应类(List)
在进行JSON解析时,遇到多层嵌套结构可通过递归或专用库来实现,重要的是将嵌套的JSON对象准确转化为对应的Java类,通常需要依赖如Gson或Jackson等库,将JSONObject转为JavaBean时,关注字段匹配与数据类型转换
2024-10-10
图解Java线程的生命周期
本文主要介绍了Java中线程的5种状态（新建（New）、就绪（Runable）、运行（Running）、阻塞（Blocked）和死亡（Dead））之间的转换图解，有需要的朋友可以参考下
2014-10-10
SpringBoot小程序推送信息的项目实践
本文主要介绍了SpringBoot小程序推送信息的项目实践，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-04-04
Java SpringBoot模板引擎之 Thymeleaf入门详解
jsp有着强大的功能，能查出一些数据转发到JSP页面以后，我们可以用jsp轻松实现数据的显示及交互等，包括能写Java代码。但是，SpringBoot首先是以jar的方式，不是war；其次我们的tomcat是嵌入式的，所以现在默认不支持jsp
2021-10-10
mybatis拦截器实现通用权限字段添加的方法
这篇文章主要给大家介绍了关于mybatis拦截器实现通用权限字段添加的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用mybatis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-09-09

springboot结合mysql主从来实现读写分离的方法示例

1.实现的功能

2.代码实现

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具