Spring Boot + MyBatis-Plus实现数据库读写分离

您的位置：上海毫米网络优化公司 > 小程序 > 百度小程序 >

文章目录

- 1. 引言
- 2. MyBatis-Plus简介
- 3. 准备工作
- 4. 配置数据源
- 5. 配置MyBatis-Plus
- 6. 创建实体类和Mapper接口
- 7. 编写Service
- 8. 控制器层
- 9. 测试
- 10. 数据库读写分离的原理
- 11. 拓展
- - 11.1. 动态数据源
  - 11.2. 多数据源事务管理
  - 11.3. 多租户支持
  - 12. 总结
    🎉Spring Boot + MyBatis-Plus实现数据库读写分离
    - ☆* o(≧▽≦)o *☆嗨~我是IT·陈寒🍹
    - ✨博客主页：IT·陈寒的博客
    - 🎈该系列文章专栏：架构设计
    - 📜其他专栏：Java学习路线 Java面试技巧 Java实战项目 AIGC人工智能数据结构学习
    - 🍹文章作者技术和水平有限，如果文中出现错误，希望大家能指正🙏
    - 📜 欢迎大家关注！ ❤️
    1. 引言
    
    在当今互联网应用中，数据库读写分离是提高系统性能和稳定性的重要手段之一。通过将读操作和写操作分别路由到不同的数据库节点，可以有效减轻数据库服务器的负担，提升系统的整体性能。本文将介绍如何利用Spring Boot和MyBatis-Plus框架实现数据库读写分离，并通过简单易懂的代码示例来详细说明每个步骤。
    
    2. MyBatis-Plus简介
    
    MyBatis-Plus是MyBatis的增强工具，提供了许多实用的功能，包括但不限于代码生成器、通用Mapper、分页插件等。在本文中，我们将专注于使用MyBatis-Plus实现数据库读写分离。
    
    3. 准备工作
    
    在开始之前，确保你的开发环境中已经安装了以下软件：
    - JDK（推荐使用JDK 8及以上版本）
    - Maven
    - IntelliJ IDEA或Eclipse（可选）
      在项目的pom.xml文件中添加MyBatis-Plus和数据库驱动的依赖：
```
    com.baomidou
    mybatis-plus-boot-starter
    3.4.3.2



    mysql
    mysql-connector-java
    8.0.26
```
      4. 配置数据源
      
      在application.properties（或application.yml）中配置主库和从库的数据源：
```
# 主库数据源配置
spring.datasource.master.url=jdbc:mysql://localhost:3306/masterdb?useSSL=false&serverTimezone=UTC
spring.datasource.master.username=root
spring.datasource.master.password=root
spring.datasource.master.driver-class-name=com.mysql.cj.jdbc.Driver
# 从库数据源配置
spring.datasource.slave.url=jdbc:mysql://localhost:3307/slavedb?useSSL=false&serverTimezone=UTC
spring.datasource.slave.username=root
spring.datasource.slave.password=root
spring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driver
```
      5. 配置MyBatis-Plus
      
      创建一个配置类，用于配置MyBatis-Plus的分页插件和动态数据源：
```
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import javax.sql.DataSource;
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper", sqlSessionFactoryRef = "sqlSessionFactory")
public class MybatisPlusConfig {
    @Bean(name = "sqlSessionFactory")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSource") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        return sqlSessionFactoryBean.getObject();
    }
    @Bean(name = "transactionManager")
    public PlatformTransactionManager transactionManager(@Qualifier("dataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return new PaginationInterceptor();
    }
}
```
      6. 创建实体类和Mapper接口
      
      创建一个简单的实体类和对应的Mapper接口：
```
// User.java
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
@Data
@TableName("user")
public class User {
    @TableId
    private Long id;
    private String username;
    private String password;
}
```
```
// UserMapper.java
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UserMapper extends BaseMapper {
}
```
      7. 编写Service
      
      创建Service层，调用Mapper接口完成数据操作：
```
// UserService.java
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
@Service
public class UserService extends ServiceImpl {
}
```
      8. 控制器层
      
      编写Controller层，暴露接口供前端调用：
```
// UserController.java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/users")
public class UserController {
    private final UserService userService;
    @Autowired
    public UserController(UserService userService) {
        this.userService = userService;
    }
    @GetMapping("/{id}")
    public User getUser(@PathVariable Long id) {
        return userService.getById(id);
    }
    @PostMapping
    public boolean createUser(@RequestBody User user) {
        return userService.save(user);
    }
    @PutMapping
    public boolean updateUser(@RequestBody User user) {
        return userService.updateById(user);
    }
    @DeleteMapping("/{id}")
    public boolean deleteUser(@PathVariable Long id) {
        return userService.removeById(id);
    }
}
```
      9. 测试
      
      启动Spring Boot应用程序，访问相应的接口进行测试。通过日志可以看到，MyBatis-Plus会在执行查询时根据一定的规则选择主库或从库。
      
      10. 数据库读写分离的原理
      
      数据库读写分离的实现原理主要通过在MyBatis-Plus中使用@DataSource注解，根据不同的操作选择不同的数据源。这里简要说明一下原理：
      1. 创建多个数据源：配置文件中定义了主库和从库两个数据源。
      2. 配置动态数据源：在MybatisPlusConfig配置类中，使用DynamicDataSource类包装主库和从库的数据源，通过@Primary注解标识主库。
      3. 自定义注解：创建@DataSource注解，用于标识Mapper方法应该使用哪个数据源。
      4. AOP切面：利用AOP，在Mapper方法执行前根据@DataSource注解的值动态切换数据源。
      11. 拓展
      
      11.1. 动态数据源
      
      切换策略
      
      在实际应用中，动态数据源切换的策略可以根据业务需求来定制。可以基于用户的读写操作比例、数据库实例的性能等因素，灵活调整数据源切换的策略。
      
      11.2. 多数据源事务管理
      
      当涉及到跨数据源的事务时，需要谨慎处理。可以通过使用分布式事务框架（如Seata、TCC事务等）来保障事务的一致性。
      
      11.3. 多租户支持
      
      在一些场景中，需要为不同的租户提供独立的数据库，此时可以考虑使用多租户架构，并根据租户信息动态切换数据源。
      
      12. 总结
      
      通过本文的学习，我们了解了如何利用Spring Boot和MyBatis-Plus实现数据库读写分离。这一策略在提升系统性能和稳定性方面有着显著的效果。通过合理配置数据源、使用MyBatis-Plus框架以及编写自定义注解和AOP切面，我们成功地搭建了一个简单而完整的读写分离系统。
      
      希望这篇文章对你理解Spring Boot和MyBatis-Plus的读写分离实现提供了帮助。在实际项目中，可以根据具体的业务需求和性能要求调整和拓展这一方案。
      🧸结尾 ❤️ 感谢您的支持和鼓励！ 😊🙏
      📜您可能感兴趣的内容：
      
      【Java面试技巧】Java面试八股文 - 掌握面试必备知识（目录篇）
      【Java学习路线】2023年完整版Java学习路线图
      【AIGC人工智能】Chat GPT是什么，初学者怎么使用Chat GPT，需要注意些什么
      【Java实战项目】SpringBoot+SSM实战：打造高效便捷的企业级Java外卖订购系统
      【数据结构学习】从零起步：学习数据结构的完整路径