SpringBoot+MyBatis-Flex配置ProxySQL的實(shí)現(xiàn)步驟
更新時(shí)間：2025年02月14日 09:50:16 作者：成都市-高級(jí)Java開發(fā)-空
本文主要介紹了SpringBoot+MyBatis-Flex配置ProxySQL的實(shí)現(xiàn)步驟,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
?? 目標(biāo)
- 在 Spring Boot 中連接 ProxySQL。
- 使用 MyBatis-Flex 訪問數(shù)據(jù)庫。
- 配置 讀寫分離 和 延遲檢測(cè)。
?? 步驟 1：確保 ProxySQL 和 MySQL 主從同步已正確配置
首先，確保您已經(jīng)正確配置了 ProxySQL 和 MySQL 主從同步。
ProxySQL 的默認(rèn)配置
| Hostgroup ID | 描述 |
|---|---|
| 10 | 主庫（寫操作） |
| 20 | 從庫（讀操作） |
ProxySQL 的數(shù)據(jù)端口
- 端口：6033（默認(rèn)數(shù)據(jù)接口端口）
?? 步驟 2：在 Spring Boot 項(xiàng)目中引入依賴
引入 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 的數(shù)據(jù)源。
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：配置數(shù)據(jù)源的讀寫分離
在 ProxySQL 中配置 讀寫分離規(guī)則：
在 ProxySQL 管理界面執(zhí)行以下 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：創(chuàng)建 MyBatis-Flex 的 Mapper 和實(shí)體類
1、創(chuàng)建實(shí)體類
在 com.example.demo.entity 包中創(chuàng)建一個(gè)實(shí)體類，例如 Order.java：
package com.example.demo.entity;
public class Order {
private Long id;
private String orderName;
// Getters and Setters
}
2、創(chuàng)建 Mapper 接口
在 com.example.demo.mapper 包中創(chuàng)建一個(gè) 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、創(chuàng)建 Mapper XML 文件
在 src/main/resources/mapper 目錄下創(chuàng)建 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：創(chuàng)建 Service 和 Controller
1、 創(chuàng)建 Service
在 com.example.demo.service 包中創(chuàng)建一個(gè) 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、創(chuàng)建 Controller
在 com.example.demo.controller 包中創(chuàng)建一個(gè) 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：測(cè)試讀寫分離
- 啟動(dòng) Spring Boot 項(xiàng)目：
mvn spring-boot:run
- 測(cè)試寫操作（INSERT/UPDATE/DELETE）
通過 Navicat 或其他工具，向數(shù)據(jù)庫執(zhí)行寫操作，確保這些操作路由到 主庫。
- 測(cè)試讀操作（SELECT）
訪問 http://localhost:8080/orders/{id}，驗(yàn)證讀操作是否路由到 從庫。
?? 步驟 8：配置延遲檢測(cè)
在 ProxySQL 中啟用 延遲檢測(cè)：
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;
? 總結(jié)
| 步驟 | 描述 |
|---|---|
| 安裝 MyBatis-Flex | 在項(xiàng)目中引入 MyBatis-Flex |
| 配置數(shù)據(jù)源 | 在 application.yml 中配置 ProxySQL 的數(shù)據(jù)源 |
| 配置讀寫分離規(guī)則 | 在 ProxySQL 中配置讀寫分離規(guī)則 |
| 創(chuàng)建實(shí)體類、Mapper、Service、Controller | 實(shí)現(xiàn)數(shù)據(jù)庫訪問邏輯 |
| 啟用延遲檢測(cè) | 在 ProxySQL 中啟用延遲檢測(cè) |
到此這篇關(guān)于SpringBoot+MyBatis-Flex配置ProxySQL的實(shí)現(xiàn)步驟的文章就介紹到這了,更多相關(guān)SpringBoot MyBatis-Flex配置ProxySQL內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Springboot?整合maven插口調(diào)用maven?release?plugin實(shí)現(xiàn)一鍵打包功能
這篇文章主要介紹了Springboot?整合maven插口調(diào)用maven?release?plugin實(shí)現(xiàn)一鍵打包功能,整合maven-invoker使程序去執(zhí)行mvn命令，結(jié)合示例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下2022-03-03
java:無法訪問org.springframework.boot.SpringApplication的解決方法
這篇文章主要給大家介紹了關(guān)于java:無法訪問org.springframework.boot.SpringApplication的解決方法,文中通過實(shí)例代碼將解決的辦法介紹的非常詳細(xì),需要的朋友可以參考下2023-01-01
SpringBoot java-jar命令行啟動(dòng)原理解析
這篇文章主要介紹了SpringBoot java-jar命令行啟動(dòng)原理解析,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-07-07
java -jar啟動(dòng)項(xiàng)目以及日志輸出的相關(guān)問題
這篇文章主要介紹了java -jar啟動(dòng)項(xiàng)目以及日志輸出的相關(guān)問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-04-04
SpringBoot+Mybatis實(shí)現(xiàn)Mapper接口與Sql綁定幾種姿勢(shì)
通常我們?cè)谑褂肕ybatis進(jìn)行開發(fā)時(shí)，會(huì)選擇xml文件來寫對(duì)應(yīng)的sql，然后將Mapper接口與sql的xml文件建立綁定關(guān)系，然后在項(xiàng)目中調(diào)用mapper接口就可以執(zhí)行對(duì)應(yīng)的sql，感興趣的可以學(xué)習(xí)一下2021-09-09
Linux環(huán)境卸載Centos7自帶的OpenJDK和安裝JDK1.8圖文教程
CentOS系統(tǒng)是開發(fā)者常用的Linux操作系統(tǒng),安裝它時(shí)會(huì)默認(rèn)安裝自帶的舊版本的OpenJDK,但在開發(fā)者平時(shí)開發(fā)Java項(xiàng)目時(shí)還是需要完整的JDK,這篇文章主要給大家介紹了關(guān)于Linux環(huán)境卸載Centos7自帶的OpenJDK和安裝JDK1.8的相關(guān)資料,需要的朋友可以參考下2024-07-07
這篇文章主要介紹了Java中調(diào)用第三方接口的詳細(xì)代碼示例,文章總結(jié)了多種Java進(jìn)行HTTP請(qǐng)求的方法,每種方法都有其特點(diǎn)和適用場(chǎng)景,從原生到封裝,再到聲明式客戶端,滿足了不同復(fù)雜度的HTTP請(qǐng)求需求,需要的朋友可以參考下2024-12-12
使用Java進(jìn)行Json數(shù)據(jù)的解析(對(duì)象數(shù)組的相互嵌套)
下面小編就為大家?guī)硪黄褂肑ava進(jìn)行Json數(shù)據(jù)的解析(對(duì)象數(shù)組的相互嵌套)。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-08-08
Java getRealPath("/")與getContextPath()區(qū)別詳細(xì)分析
這篇文章主要介紹了Java getRealPath("/")與getContextPath()區(qū)別詳細(xì)分析,本篇文章通過簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-08-08
java設(shè)計(jì)模式之簡(jiǎn)單工廠模式詳解
這篇文章主要介紹了java設(shè)計(jì)模式之簡(jiǎn)單工廠模式的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-09-09