Mysql主从+springboot+mybatis实践篇

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,集群系列 2核4GB
简介: Mysql主从+springboot+mybatis实践篇

Mysql主从+springboot+mybatis实践篇

注意: 代码连接在文章末尾。

本次主要是按照上一个主从配置过后的数据库进行和springboot的连接实践操作。

环境配置

环境配置过程分为三个步骤

  1. 相关依赖引入
<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--数据库三剑客-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.4</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.25</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.9</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.9.6</version>
        </dependency>
        <!-- google java lib -->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>17.0</version>
        </dependency>
    </dependencies>
  1. application.yml配置文件配置。
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: 你的主数据库密码
    type: com.alibaba.druid.pool.DruidDataSource
    url: jdbc:mysql://主数据库IP地址:端口/test?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8
  db:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: 你的从数据库密码
    type: com.alibaba.druid.pool.DruidDataSource
    url: jdbc:mysql://从数据库ip地址:端口/test?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8
mybatis:
  mapper-locations: classpath:mappers/*.xml
logging:
  level:
    com:
      example: debug

数据库相关配置文件编写

配置数据源

@Configuration
public class DruidConfig {
    /**
     * 主据源
     *
     * @return 返回数据源对象
     */
    @Primary
    @Bean(name = "writeDataSource")
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource dataSource() {
        return DataSourceBuilder.create().type(com.alibaba.druid.pool.DruidDataSource.class).build();
    }
    /**
     * 从数据源
     *
     * @return 返回数据源对象
     */
    @Bean(name = "readDataSource")
    @ConfigurationProperties(prefix = "spring.db")
    public DataSource readDataSource0() {
        return DataSourceBuilder.create().type(com.alibaba.druid.pool.DruidDataSource.class).build();
    }
}

配置数据源路由和事务等

@Configuration
@EnableTransactionManagement(order = 2)
@MapperScan(basePackages = {"com.example.demoms.mapper"})
public class MybatisConfig
        implements TransactionManagementConfigurer, ApplicationContextAware {
    private static ApplicationContext context;
    /**
     * 数据源路由代理
     * 将数据源以map的形式放入数据源路由中,key分别为write和read,
     * 切面拦截指定方法的调用,判断是读还是写,将read或write放入ThreadLocale变量中
     * RoutingDataSource重写的determineCurrentLookupKey决定要使用哪个数据源,
     * 然后AbstractRoutingDataSource中的determineTargetDataSource的方法在map变量中将数据源取出,
     *
     * @return
     */
    @Bean
    public AbstractRoutingDataSource routingDataSourceProxy() {
        RoutingDataSource proxy = new RoutingDataSource();
        Map<Object, Object> targetDataSources = Maps.newHashMap();
        targetDataSources.put("write", context.getBean("writeDataSource", DataSource.class));
        targetDataSources.put("read", context.getBean("readDataSource", DataSource.class));
        proxy.setDefaultTargetDataSource(context.getBean("writeDataSource", DataSource.class));
        proxy.setTargetDataSources(targetDataSources);
        return proxy;
    }
    @Bean
    @ConditionalOnMissingBean
    public SqlSessionFactoryBean sqlSessionFactory() throws IOException {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(routingDataSourceProxy());
        bean.setVfs(SpringBootVFS.class);
        bean.setTypeAliasesPackage("com.example.demoms.entity");
//        Resource configResource = new ClassPathResource("mybatis/mybatis.cfg.xml");
//        bean.setConfigLocation(configResource);
        ResourcePatternResolver mapperResource = new PathMatchingResourcePatternResolver();
        Resource[] resources = mapperResource.getResources("classpath:mappers/*.xml");
        bean.setMapperLocations(resources);
        return bean;
    }
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return new DataSourceTransactionManager(routingDataSourceProxy());
    }
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        if (context == null) {
            context = applicationContext;
        }
    }
}

数据源路由类

public class RoutingDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        String typeKey = DataSourceContextHolder.getJdbcType();
        if (typeKey == null) {
            return "write";
        }else {
            if(typeKey.equals("read")) return "read";
            return "write";
        }
    }
}

定义切换数据源的注解

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DynamicDataSource {
    /**
     * 数据源key值
     *
     * @return
     */
    String value() default "write";
}

定义切面,拦截定义的注解,获取ThreadLocal中的值

@Aspect
@Component
@Order(1)
public class DynamicDataSourceAspect {
    @Pointcut("@annotation(DynamicDataSource)")
    public void annotationPointcut() {
    }
    /**
     * 切换数据源
     *
     * @param point 节点
     */
    @Before("annotationPointcut()")
    public void setDataSourceType(JoinPoint point) {
        MethodSignature methodSignature =  (MethodSignature) point.getSignature();
        Method method = methodSignature.getMethod();
        DynamicDataSource annotation = method.getAnnotation(DynamicDataSource.class);
        String value = annotation.value();
        System.out.println("切面中::"+value);
        if ("write".equals(value)){
            DataSourceContextHolder.write();
        }else {
            DataSourceContextHolder.read();
        }
    }
    @After("annotationPointcut()")
    public void clear() {
        System.out.println("切面中::清除类型");
        DataSourceContextHolder.clearDbType();
    }
}

DataSourceContextHolder类

public class DataSourceContextHolder {
    private static Logger logger = LoggerFactory.getLogger(DataSourceContextHolder.class);
    private final static ThreadLocal<String> local = new ThreadLocal<>();
    public static ThreadLocal<String> getLocal() {
        return local;
    }
    public static void read() {
        logger.debug("切换至[读]数据源");
        System.out.println("切换至[读]数据源");
        local.set("read");
    }
    public static void write() {
        logger.debug("切换至[写]数据源");
        System.out.println("切换至[写]数据源");
        local.set("write");
    }
    public static String getJdbcType() {
        return local.get();
    }
    /**
     * 清理链接类型
     */
    public static void clearDbType() {
        local.remove();
    }
}

注解的使用

在service层的方法上加入@DynamicDataSource("read"),根据RoutingDataSource中的定义,如果不加注解,使用的是主数据源。

注意:以上方式在加入@Transactional注解或@LcnTransaction注解后并不能实现切换数据源,

测试

先配置好对应的mapper controller service 等。 在service的实现类中定义方法

@Override
    @DynamicDataSource("write")  //这个代表的是从写数据源里边进行数据查询
    public String getInfo() {
        return testMapper.getInfo();
    }

结果如下:

网络异常,图片无法展示
|

整体项目姐构图:

网络异常,图片无法展示
|

代码链接:https://englishcode.lanzoul.com/iphJ0019fq7e

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
|
JavaScript 安全 Java
java版药品不良反应智能监测系统源码,采用SpringBoot、Vue、MySQL技术开发
基于B/S架构,采用Java、SpringBoot、Vue、MySQL等技术自主研发的ADR智能监测系统,适用于三甲医院,支持二次开发。该系统能自动监测全院患者药物不良反应,通过移动端和PC端实时反馈,提升用药安全。系统涵盖规则管理、监测报告、系统管理三大模块,确保精准、高效地处理ADR事件。
|
1月前
|
负载均衡 Java 开发者
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
167 5
|
1月前
|
Java 关系型数据库 MySQL
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
67 5
|
2月前
|
安全 Java 数据安全/隐私保护
如何使用Spring Boot进行表单登录身份验证:从基础到实践
如何使用Spring Boot进行表单登录身份验证:从基础到实践
75 5
|
2月前
|
监控 Java 数据安全/隐私保护
如何用Spring Boot实现拦截器:从入门到实践
如何用Spring Boot实现拦截器:从入门到实践
59 5
|
2月前
|
分布式计算 关系型数据库 MySQL
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型
SpringBoot项目中mysql字段映射使用JSONObject和JSONArray类型 图像处理 光通信 分布式计算 算法语言 信息技术 计算机应用
69 8
|
2月前
|
SQL 前端开发 关系型数据库
SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据
SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据
82 9
|
2月前
|
Java 测试技术 数据库连接
使用Spring Boot编写测试用例:实践与最佳实践
使用Spring Boot编写测试用例:实践与最佳实践
137 0
|
2月前
|
数据采集 Java 数据安全/隐私保护
Spring Boot 3.3中的优雅实践:全局数据绑定与预处理
【10月更文挑战第22天】 在Spring Boot应用中,`@ControllerAdvice`是一个强大的工具,它允许我们在单个位置处理多个控制器的跨切面关注点,如全局数据绑定和预处理。这种方式可以大大减少重复代码,提高开发效率。本文将探讨如何在Spring Boot 3.3中使用`@ControllerAdvice`来实现全局数据绑定与预处理。
80 2
|
3月前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
477 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库