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

矫情吗；* 2024-04-15 14:02 73阅读 0赞

#### 文章目录 ####

*   *  1. 引言
     *  2. MyBatis-Plus简介
     *  3. 准备工作
     *  4. 配置数据源
     *  5. 配置MyBatis-Plus
     *  6. 创建实体类和Mapper接口
     *  7. 编写Service
     *  8. 控制器层
     *  9. 测试
     *  10. 数据库读写分离的原理
     *  11. 拓展
     *   *  11.1. 动态数据源
         *  11.2. 多数据源事务管理
         *  11.3. 多租户支持
     *  12. 总结

![在这里插入图片描述][579a429daf314744b995f37351b46548.gif_pic_center]

> ?Spring Boot + MyBatis-Plus实现数据库读写分离
> 
> --------------------
> 
>  *  ☆\* o(≧▽≦)o \*☆嗨~我是IT·陈寒?
>  *  ✨博客主页：[IT·陈寒的博客][IT]
>  *  ?该系列文章专栏：[架构设计][Link 1]
>  *  ?其他专栏：[Java学习路线][Java] [Java面试技巧][Java 1] [Java实战项目][Java 2] [AIGC人工智能][AIGC] [数据结构学习][Link 2]
>  *  ?文章作者技术和水平有限，如果文中出现错误，希望大家能指正?
>  *  ? 欢迎大家关注！ ❤️

--------------------

### 1. 引言 ###

在当今互联网应用中，数据库读写分离是提高系统性能和稳定性的重要手段之一。通过将读操作和写操作分别路由到不同的数据库节点，可以有效减轻数据库服务器的负担，提升系统的整体性能。本文将介绍如何利用Spring Boot和MyBatis-Plus框架实现数据库读写分离，并通过简单易懂的代码示例来详细说明每个步骤。  
![在这里插入图片描述][657c5f85da184af39456b11ba51c06d8.png_pic_center]

### 2. MyBatis-Plus简介 ###

MyBatis-Plus是MyBatis的增强工具，提供了许多实用的功能，包括但不限于代码生成器、通用Mapper、分页插件等。在本文中，我们将专注于使用MyBatis-Plus实现数据库读写分离。

### 3. 准备工作 ###

在开始之前，确保你的开发环境中已经安装了以下软件：

*  JDK（推荐使用JDK 8及以上版本）
 *  Maven
 *  IntelliJ IDEA或Eclipse（可选）

在项目的`pom.xml`文件中添加MyBatis-Plus和数据库驱动的依赖：

<dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus-boot-starter</artifactId>
        <version>3.4.3.2</version>
    </dependency>
    
    
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>

### 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<User> {
        
    }

### 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<UserMapper, User> {
        
    }

### 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 1]】[Java面试八股文 - 掌握面试必备知识（目录篇）][Java_ -]
>  *  【[Java学习路线][Java]】[2023年完整版Java学习路线图][2023_Java]
>  *  【[AIGC人工智能][AIGC]】[Chat GPT是什么，初学者怎么使用Chat GPT，需要注意些什么][Chat GPT_Chat GPT]
>  *  【[Java实战项目][Java 2]】[SpringBoot+SSM实战：打造高效便捷的企业级Java外卖订购系统][SpringBoot_SSM_Java]
>  *  【[数据结构学习][Link 2]】[从零起步：学习数据结构的完整路径][Link 3]
> 
> > ![在这里插入图片描述][d7565cfc032647bfb69e7971731a06a2.gif_pic_center]

[579a429daf314744b995f37351b46548.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/915d741f48c049be8d607c12a41cf061.gif
[IT]: https://blog.csdn.net/qq_43546721?type=blog
[Link 1]: https://blog.csdn.net/qq_43546721/category_12435443.html?spm=1001.2014.3001.5482
[Java]: https://blog.csdn.net/qq_43546721/category_12367981.html
[Java 1]: https://blog.csdn.net/qq_43546721/category_12384780.html?spm=1001.2014.3001.5482
[Java 2]: https://blog.csdn.net/qq_43546721/category_12378614.html?spm=1001.2014.3001.5482
[AIGC]: https://blog.csdn.net/qq_43546721/category_12369819.html?spm=1001.2014.3001.5482
[Link 2]: https://blog.csdn.net/qq_43546721/category_12417284.html?spm=1001.2014.3001.5482
[657c5f85da184af39456b11ba51c06d8.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/732f63bf8c9149f984caad01eec59b95.png
[Java_ -]: https://blog.csdn.net/qq_43546721/article/details/131832856
[2023_Java]: https://blog.csdn.net/qq_43546721/article/details/131550605
[Chat GPT_Chat GPT]: https://blog.csdn.net/qq_43546721/article/details/131866932
[SpringBoot_SSM_Java]: https://blog.csdn.net/qq_43546721/article/details/132119791
[Link 3]: https://blog.csdn.net/qq_43546721/article/details/132404477
[d7565cfc032647bfb69e7971731a06a2.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/3bc607d9f9ff4e22a3a21dcabf2839b6.gif