快捷導(dǎo)航

SpringBoot+MyBatis-Plus實現(xiàn)數(shù)據(jù)庫讀寫分離的代碼示例

更新時間：2023年11月30日 09:01:38 作者：IT·陳寒

在當(dāng)今互聯(lián)網(wǎng)應(yīng)用中,數(shù)據(jù)庫讀寫分離是提高系統(tǒng)性能和穩(wěn)定性的重要手段之一,通過將讀操作和寫操作分別路由到不同的數(shù)據(jù)庫節(jié)點,可以有效減輕數(shù)據(jù)庫服務(wù)器的負擔(dān),本文將介紹如何利用SpringBoot和MyBatis-Plus框架實現(xiàn)數(shù)據(jù)庫讀寫分離,需要的朋友可以參考下

1. 引言

在當(dāng)今互聯(lián)網(wǎng)應(yīng)用中，數(shù)據(jù)庫讀寫分離是提高系統(tǒng)性能和穩(wěn)定性的重要手段之一。通過將讀操作和寫操作分別路由到不同的數(shù)據(jù)庫節(jié)點，可以有效減輕數(shù)據(jù)庫服務(wù)器的負擔(dān)，提升系統(tǒng)的整體性能。本文將介紹如何利用Spring Boot和MyBatis-Plus框架實現(xiàn)數(shù)據(jù)庫讀寫分離，并通過簡單易懂的代碼示例來詳細說明每個步驟。

2. MyBatis-Plus簡介

MyBatis-Plus是MyBatis的增強工具，提供了許多實用的功能，包括但不限于代碼生成器、通用Mapper、分頁插件等。在本文中，我們將專注于使用MyBatis-Plus實現(xiàn)數(shù)據(jù)庫讀寫分離。

3. 準備工作

在開始之前，確保你的開發(fā)環(huán)境中已經(jīng)安裝了以下軟件：

JDK（推薦使用JDK 8及以上版本）
Maven
IntelliJ IDEA或Eclipse（可選）

在項目的pom.xml文件中添加MyBatis-Plus和數(shù)據(jù)庫驅(qū)動的依賴：

<!-- MyBatis-Plus -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.4.3.2</version>
</dependency>

<!-- MySQL驅(qū)動 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

4. 配置數(shù)據(jù)源

在application.properties（或application.yml）中配置主庫和從庫的數(shù)據(jù)源：

# 主庫數(shù)據(jù)源配置
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

# 從庫數(shù)據(jù)源配置
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

創(chuàng)建一個配置類，用于配置MyBatis-Plus的分頁插件和動態(tài)數(shù)據(jù)源：

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. 創(chuàng)建實體類和Mapper接口

創(chuàng)建一個簡單的實體類和對應(yīng)的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

創(chuàng)建Service層，調(diào)用Mapper接口完成數(shù)據(jù)操作：

// 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層，暴露接口供前端調(diào)用：

// 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應(yīng)用程序，訪問相應(yīng)的接口進行測試。通過日志可以看到，MyBatis-Plus會在執(zhí)行查詢時根據(jù)一定的規(guī)則選擇主庫或從庫。

10. 數(shù)據(jù)庫讀寫分離的原理

數(shù)據(jù)庫讀寫分離的實現(xiàn)原理主要通過在MyBatis-Plus中使用@DataSource注解，根據(jù)不同的操作選擇不同的數(shù)據(jù)源。這里簡要說明一下原理：

創(chuàng)建多個數(shù)據(jù)源： 配置文件中定義了主庫和從庫兩個數(shù)據(jù)源。
配置動態(tài)數(shù)據(jù)源： 在MybatisPlusConfig配置類中，使用DynamicDataSource類包裝主庫和從庫的數(shù)據(jù)源，通過@Primary注解標識主庫。
自定義注解： 創(chuàng)建@DataSource注解，用于標識Mapper方法應(yīng)該使用哪個數(shù)據(jù)源。
AOP切面： 利用AOP，在Mapper方法執(zhí)行前根據(jù)@DataSource注解的值動態(tài)切換數(shù)據(jù)源。

11. 拓展

11.1. 動態(tài)數(shù)據(jù)源

切換策略

在實際應(yīng)用中，動態(tài)數(shù)據(jù)源切換的策略可以根據(jù)業(yè)務(wù)需求來定制。可以基于用戶的讀寫操作比例、數(shù)據(jù)庫實例的性能等因素，靈活調(diào)整數(shù)據(jù)源切換的策略。

11.2. 多數(shù)據(jù)源事務(wù)管理

當(dāng)涉及到跨數(shù)據(jù)源的事務(wù)時，需要謹慎處理。可以通過使用分布式事務(wù)框架（如Seata、TCC事務(wù)等）來保障事務(wù)的一致性。

11.3. 多租戶支持

在一些場景中，需要為不同的租戶提供獨立的數(shù)據(jù)庫，此時可以考慮使用多租戶架構(gòu)，并根據(jù)租戶信息動態(tài)切換數(shù)據(jù)源。

12. 總結(jié)

通過本文的學(xué)習(xí)，我們了解了如何利用Spring Boot和MyBatis-Plus實現(xiàn)數(shù)據(jù)庫讀寫分離。這一策略在提升系統(tǒng)性能和穩(wěn)定性方面有著顯著的效果。通過合理配置數(shù)據(jù)源、使用MyBatis-Plus框架以及編寫自定義注解和AOP切面，我們成功地搭建了一個簡單而完整的讀寫分離系統(tǒng)。

希望這篇文章對你理解Spring Boot和MyBatis-Plus的讀寫分離實現(xiàn)提供了幫助。在實際項目中，可以根據(jù)具體的業(yè)務(wù)需求和性能要求調(diào)整和拓展這一方案。

以上就是SpringBoot+MyBatis-Plus實現(xiàn)數(shù)據(jù)庫讀寫分離的代碼示例的詳細內(nèi)容，更多關(guān)于SpringBoot+MyBatis-Plus讀寫分離的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: