首页 > 软件编程 > java > SpringBoot MyBatis-Flex配置ProxySQL

SpringBoot+MyBatis-Flex配置ProxySQL的实现步骤

2025-02-14 09:43:26 作者：成都市-高级Java开发-空

本文主要介绍了SpringBoot+MyBatis-Flex配置ProxySQL的实现步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

🎯 目标

在 Spring Boot 中连接 ProxySQL。
使用 MyBatis-Flex 访问数据库。
配置读写分离和延迟检测。

🔧 步骤 1：确保 ProxySQL 和 MySQL 主从同步已正确配置

首先，确保您已经正确配置了 ProxySQL 和 MySQL 主从同步。

ProxySQL 的默认配置

Hostgroup ID	描述
10	主库（写操作）
20	从库（读操作）

ProxySQL 的数据端口

端口：6033（默认数据接口端口）

🔧 步骤 2：在 Spring Boot 项目中引入依赖

引入 MyBatis-Flex 的依赖

在 pom.xml 中添加以下依赖：

<dependency>
    <groupId>com.mybatisflex</groupId>
    <artifactId>mybatis-flex-spring-boot-starter</artifactId>
    <version>1.4.3</version>
</dependency>

🔧 步骤 3：配置 application.yml

在 application.yml 文件中配置 ProxySQL 的数据源。

spring:
  datasource:
    url: jdbc:mysql://127.0.0.1:6033/db_order_plus?useSSL=false&useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
    username: root
    password: root
  mybatis-flex:
    mapper-locations: classpath:mapper/**/*Mapper.xml
    configuration:
      map-underscore-to-camel-case: true

🔧 步骤 4：配置数据源的读写分离

在 ProxySQL 中配置读写分离规则：

在 ProxySQL 管理界面执行以下 SQL

INSERT INTO mysql_query_rules (rule_id, active, match_pattern, destination_hostgroup)
VALUES (1, 1, '^SELECT.*', 20),
       (2, 1, '^INSERT.*|^UPDATE.*|^DELETE.*', 10);

LOAD MYSQL QUERY RULES TO RUNTIME;
SAVE MYSQL QUERY RULES TO DISK;

🔧 步骤 5：创建 MyBatis-Flex 的 Mapper 和实体类

1、创建实体类

在 com.example.demo.entity 包中创建一个实体类，例如 Order.java：

package com.example.demo.entity;

public class Order {
    private Long id;
    private String orderName;

    // Getters and Setters
}

2、创建 Mapper 接口

在 com.example.demo.mapper 包中创建一个 Mapper 接口：

package com.example.demo.mapper;

import com.example.demo.entity.Order;
import org.apache.ibatis.annotations.Select;

public interface OrderMapper {
    
    @Select("SELECT * FROM orders WHERE id = #{id}")
    Order selectOrderById(Long id);
}

3、创建 Mapper XML 文件

在 src/main/resources/mapper 目录下创建 OrderMapper.xml：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.example.demo.mapper.OrderMapper">
    <select id="selectOrderById" resultType="com.example.demo.entity.Order">
        SELECT * FROM orders WHERE id = #{id}
    </select>
</mapper>

🔧 步骤 6：创建 Service 和 Controller

1、创建 Service

在 com.example.demo.service 包中创建一个 OrderService：

package com.example.demo.service;

import com.example.demo.entity.Order;
import com.example.demo.mapper.OrderMapper;
import org.springframework.stereotype.Service;

@Service
public class OrderService {

    private final OrderMapper orderMapper;

    public OrderService(OrderMapper orderMapper) {
        this.orderMapper = orderMapper;
    }

    public Order getOrderById(Long id) {
        return orderMapper.selectOrderById(id);
    }
}

2、创建 Controller

在 com.example.demo.controller 包中创建一个 OrderController：

package com.example.demo.controller;

import com.example.demo.entity.Order;
import com.example.demo.service.OrderService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class OrderController {

    private final OrderService orderService;

    public OrderController(OrderService orderService) {
        this.orderService = orderService;
    }

    @GetMapping("/orders/{id}")
    public Order getOrderById(@PathVariable Long id) {
        return orderService.getOrderById(id);
    }
}

🔧 步骤 7：测试读写分离

启动 Spring Boot 项目：

mvn spring-boot:run

测试写操作（INSERT/UPDATE/DELETE）

通过 Navicat 或其他工具，向数据库执行写操作，确保这些操作路由到主库。

测试读操作（SELECT）

访问 http://localhost:8080/orders/{id}，验证读操作是否路由到从库。

🔧 步骤 8：配置延迟检测

在 ProxySQL 中启用延迟检测：

SET mysql-monitor_replication_lag_interval_ms = 1000;

INSERT INTO mysql_replication_hostgroups (writer_hostgroup, reader_hostgroup, check_type, max_replication_lag)
VALUES (10, 20, 'seconds_behind_master', 5);

LOAD MYSQL VARIABLES TO RUNTIME;
SAVE MYSQL VARIABLES TO DISK;

✅ 总结

步骤	描述
安装 MyBatis-Flex	在项目中引入 MyBatis-Flex
配置数据源	在 `application.yml` 中配置 ProxySQL 的数据源
配置读写分离规则	在 ProxySQL 中配置读写分离规则
创建实体类、Mapper、Service、Controller	实现数据库访问逻辑
启用延迟检测	在 ProxySQL 中启用延迟检测

到此这篇关于SpringBoot+MyBatis-Flex配置ProxySQL的实现步骤的文章就介绍到这了,更多相关SpringBoot MyBatis-Flex配置ProxySQL内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！