当前位置：首页 > news >正文

Spring Boot3 配合ProxySQL实现对 MySQL 主从同步的读写分离和负载均衡

news 来源：原创 2025/5/9 10:03:39

将 ProxySQL 配合 Spring Boot 使用，主要的目的是在 Spring Boot 应用程序中实现对 MySQL 主从同步的读写分离和负载均衡。这样，你可以利用 ProxySQL 自动将写操作路由到主库，而将读操作路由到从库。

1. 准备工作

确保你的 MySQL 主从同步环境和 ProxySQL 已经成功配置并正常工作。接下来，我们将进行以下几个步骤：

配置 Spring Boot 连接 ProxySQL。
配置 数据源 来支持读写分离。

2. 修改 Spring Boot 配置

在 Spring Boot 项目中，配置数据库连接时，使用 ProxySQL 作为 MySQL 的代理。你需要将 Spring Boot 的 数据源配置 进行一些调整，以支持读写分离。

1.1 配置 `application.yml`（或 `application.properties`）

你可以在 application.yml 中配置多个数据源，分别对应主库和从库。ProxySQL 会作为一个代理处理读写分离。

示例：`application.yml`

spring:datasource:# 主数据源 (写库)primary:url: jdbc:mysql://127.0.0.1:6033/mydbusername: your_userpassword: your_passworddriver-class-name: com.mysql.cj.jdbc.Driverhikari:maximum-pool-size: 10minimum-idle: 5pool-name: PrimaryPool# 从数据源 (读库)secondary:url: jdbc:mysql://127.0.0.1:6033/mydbusername: your_userpassword: your_passworddriver-class-name: com.mysql.cj.jdbc.Driverhikari:maximum-pool-size: 10minimum-idle: 5pool-name: SecondaryPool# 设置数据源的路由策略jpa:hibernate:ddl-auto: updateproperties:hibernate:dialect: org.hibernate.dialect.MySQL8Dialectshow-sql: truedatabase-platform: org.hibernate.dialect.MySQL8Dialect

在这个配置文件中：

主数据源（primary）用于写入操作，连接到 ProxySQL 的主库。
从数据源（secondary）用于读取操作，连接到 ProxySQL 的从库。

ProxySQL 会根据 SQL 语句的类型（SELECT 路由到从库，INSERT/UPDATE 路由到主库）自动分配流量。

1.2 配置 `DataSource` 路由

Spring Boot 默认只支持单个数据源。如果你需要同时配置多个数据源（主从分离），需要定义一个 数据源路由 类，将请求的数据库连接动态路由到主库或从库。

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "com.example.repository")
public class DataSourceConfig {@Primary@Bean(name = "primaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.primary")public DataSource dataSource() {return DataSourceBuilder.create().build();}@Bean(name = "secondaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.secondary")public DataSource secondaryDataSource() {return DataSourceBuilder.create().build();}// 配置EntityManagerFactory和TransactionManager@Bean(name = "entityManagerFactory")public LocalContainerEntityManagerFactoryBean entityManagerFactory(EntityManagerFactoryBuilder builder, @Qualifier("primaryDataSource") DataSource dataSource) {return builder.dataSource(dataSource).packages("com.example.model") // 你的实体类包路径.persistenceUnit("primary").build();}@Bean(name = "transactionManager")public PlatformTransactionManager transactionManager(@Qualifier("entityManagerFactory") EntityManagerFactory entityManagerFactory) {return new JpaTransactionManager(entityManagerFactory);}
}

在这个配置中，我们定义了两个数据源：primaryDataSource 和 secondaryDataSource，分别连接到 ProxySQL 的主库和从库。

3. 实现动态数据源路由

为了动态选择使用主库还是从库，你可以使用一个 AbstractRoutingDataSource 来实现动态的数据源路由。

public class DynamicDataSource extends AbstractRoutingDataSource {@Overrideprotected Object determineCurrentLookupKey() {// 判断当前线程中是否有读请求或者写请求，选择数据源return DataSourceContextHolder.getDataSourceType();}
}

然后创建一个 DataSourceContextHolder 用来管理当前线程的数据源类型。

public class DataSourceContextHolder {private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();public static void setDataSourceType(String dataSourceType) {contextHolder.set(dataSourceType);}public static String getDataSourceType() {return contextHolder.get();}public static void clearDataSourceType() {contextHolder.remove();}
}

4. 配置 Service 层的读写分离

接下来，你需要在服务层中手动切换读写操作的数据源。通常，你可以通过注解来区分读操作和写操作。

@Service
public class UserService {@Transactionalpublic void saveUser(User user) {// 使用主库保存数据DataSourceContextHolder.setDataSourceType("primary");userRepository.save(user);DataSourceContextHolder.clearDataSourceType();}public User getUser(Long id) {// 使用从库查询数据DataSourceContextHolder.setDataSourceType("secondary");User user = userRepository.findById(id).orElse(null);DataSourceContextHolder.clearDataSourceType();return user;}
}

在上面的代码中，saveUser 方法会选择主库，而 getUser 方法会选择从库。

5. 配置 Spring AOP 自动切换数据源（可选）

你可以通过 AOP 来简化读写分离的配置，使得你不需要手动设置数据源类型。只需在方法上使用自定义注解（如 @ReadOnly 和 @WriteOnly），自动切换数据源。

自定义注解：

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface ReadOnly {
}@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface WriteOnly {
}

创建 AOP 切面：

@Aspect
@Component
public class DataSourceAspect {@Before("@annotation(ReadOnly)")public void setReadOnlyDataSource() {DataSourceContextHolder.setDataSourceType("secondary");}@Before("@annotation(WriteOnly)")public void setWriteOnlyDataSource() {DataSourceContextHolder.setDataSourceType("primary");}@After("@annotation(ReadOnly) || @annotation(WriteOnly)")public void clearDataSource() {DataSourceContextHolder.clearDataSourceType();}
}

在这段代码中：

使用 @ReadOnly 注解的方法将会切换到从库。
使用 @WriteOnly 注解的方法将会切换到主库。

6. 总结

通过以上步骤，你可以将 ProxySQL 与 Spring Boot 集成，实现 MySQL 主从同步的读写分离和负载均衡。

ProxySQL 作为 MySQL 的代理，负责将读请求路由到从库，写请求路由到主库。
Spring Boot 通过配置多个数据源和动态路由来实现读写分离。
你可以通过 AOP 或手动设置来决定何时使用主库或从库。

Spring Boot3 配合ProxySQL实现对 MySQL 主从同步的读写分离和负载均衡

将 ProxySQL 配合 Spring Boot 使用，主要的目的是在 Spring Boot 应用程序中实现对 MySQL 主从同步的读写分离和负载均衡。这样，你可以利用 ProxySQL 自动将写操作路由到主库，而将读操作路由到从库。 1. 准备工作确保你的 MySQL 主从同步环…...

编程日记 2025/5/9 10:03:39

ubuntu20下编译linux1.0 (part1)

author: hjjdebug date: 2025年 01月 09日星期四 15:56:15 CST description: ubuntu20下编译linux1.0 (part1) 该博客记录了新gcc编译旧代码可能碰到的问题和解决办法, 可留作参考操作环境: ubuntu20 $ gcc --version gcc (Ubuntu 9.4.0-1ubuntu1~20.04.2) 9.4.0 $ as --vers…...

编程日记 2025/5/6 6:06:04

【AI日记】25.01.10

【AI论文解读】【AI知识点】【AI小项目】【AI战略思考】【AI日记】【读书与思考】 AI kaggle 比赛：Forecasting Sticker Sales 读书书名：国家为什么会失败阅读原因：2024 年诺贝尔经济学奖得主的力作未删减版：https://book.dou…...

编程日记 2025/5/9 9:48:19

04_Redis数据类型-String字符串

1.Redis数据类型介绍 Redis是一种Key-Value类型缓存型数据库，Redis为了存储不同类型的数据，Value支持多种数据类型，Redis为我们提供了常用的9种数据类型。包括5种基本类型：String（字符串）、Hash（哈希）、List（列表），Set（集合）及zset（Sorted Set有序集合）；和4种…...

编程日记 2025/5/9 8:56:40

mysql之基本select语句运算符排序分页

1.SQL的分类 DDL:数据定义语言. CREATE ALTER DROP RENAME TRUNCATE DML: 数据操作语言. INSERT DELETE UPDATE SELECT 重中之重 DCL: 数据控制语言. COMMIT ROLLBACK SAVEPOINT GRANT REVOKE 2.SQL语言的规则与规范 1.基本规则 SQL可以在一行或多行,为了提高可…...

编程日记 2025/5/9 9:11:20

springboot整合admin

1. 添加依赖首先，在你的admin服务端pom.xml文件中添加Spring Boot Admin的依赖： <dependency><groupId>de.codecentric</groupId><artifactId>spring-boot-admin-starter-server</artifactId><version>2.5.4<…...

编程日记 2025/5/9 9:55:19

springboot整合gateway

1. 添加依赖首先，在你的pom.xml文件中添加Spring Cloud Gateway的依赖： <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId> </dependency> 如果…...

编程日记 2025/5/8 14:43:47

iOS实际开发中使用Alamofire实现多文件上传（以个人相册为例）

引言在移动应用中，图片上传是一个常见的功能，尤其是在个人中心或社交平台场景中，用户经常需要上传图片到服务器，用以展示个人风采或记录美好瞬间。然而，实现多图片上传的过程中，如何设计高效的上传逻辑并…...

编程日记 2025/5/5 23:46:48

PyCharm 的安装与使用（Window）

1 PyCharm 简介 PyCharm 是一款由 JetBrains 公司开发的专门用于 Python 语言开发的集成开发环境（IDE）。以下是其相关介绍： 1.1 特点与功能智能代码编辑：提供高度智能化的代码编辑器，支持语法高亮、自动补全、代码重…...

编程日记 2025/5/9 9:02:27

媒体资源生产转码过程

音视频基础 1. 音频基础原理 1.1 声音的基本概念声波: 声音是通过空气或其他介质传播的机械波。声波的特性包括频率（Hz）、振幅（dB）和波形。采样率 (Sampling Rate): 每秒对声音信号进行采样的次数，单位为赫兹&…...

编程日记 2025/5/3 3:50:55

WPF控件Grid的布局和C1FlexGrid的多选应用

使用 Grid.Column和Grid.Row布局，将多个C1FlexGrid布局其中，使用各种事件来达到所需效果，点击复选框可以加载数据到列表，移除列表的数据，自动取消复选框等移除复选框的要注意！！！&am…...

编程日记 2025/5/4 7:03:04

Postman配置环境变量

🍅 点击文末小卡片 ，免费获取软件测试全套资料，资料在手，涨薪更快 Postman是一套比较方便的接口测试工具，但我们在使用过程中，可能会出现创建了API请求，但API的URL会随着服务器IP地址的变化而改…...

编程日记 2025/5/5 17:51:00

import语句详解

在 Java 中，import 语句用于引入其他包中的类、接口或静态成员，以便在当前源文件中直接使用它们，而不需要写完整的类名（包括包名）。以下是 import 语句的详细解释和使用方法： 一、import语句的基本概念定…...

编程日记 2025/5/4 12:08:52

数据结构与算法之二叉树: LeetCode 199. 二叉树的右视图 (Ts版)

二叉树的右视图 https://leetcode.cn/problems/binary-tree-right-side-view/ 描述给定一个二叉树的根节点 root，想象自己站在它的右侧，按照从顶部到底部的顺序，返回从右侧所能看到的节点值。示例 1 输入：root [1,2,3,nu…...

编程日记 2025/5/8 20:42:11

CentOS7修改Docker默认存储路径

当你使用Docker时，Docker的默认配置是将镜像、容器和卷存储在系统/var/lib/docker/目录下，如果docker镜像安装的太多会导致磁盘不够，你可以尝试以下方法来释放空间： 清理无用的镜像和容器：使用docker命令删除不再使用…...

编程日记 2025/5/6 9:22:13

宝塔面板使用 GoAccess Web 日志分析教程

宝塔面板是一个简单方便的服务器运维面板，但其网站统计功能是收费的。而 GoAccess 是一个用 C 编写的免费开源 Web日志分析器，本文将介绍如何在宝塔面板中开启 GoAccess Web 日志分析功能。内容索引下载安装 GoAccess在宝塔面板中添加日志切割的计划任务将 Web 日志输出到…...

编程日记 2025/5/6 9:04:52

【FPGA】时序约束与分析

设计约束设计约束所处环节： 约束输入分析实现结果设计优化设计约束分类： 物理约束：I/O接口约束（例如引脚分配、电平标准设定等物理属性的约束）、布局约束、布线约束以及配置约束时序约束：设计FP…...

编程日记 2025/5/3 8:25:19

c++入门之命名空间与输入输出

1、命名空间 1.1使用命名空间的原因先看一个例子： #include <iostream>int round 0;int main() {printf("%d", round);return 0; }请问，这个程序能跑起来吗？ 答案是否定的原因是，当我们想创建一个全局变量 …...

编程日记 2025/5/5 7:03:43

【zotero】解决无法参考文献交叉跳转、相关参考文献插件推荐

无法跳转参考大佬文章的方法： https://blog.csdn.net/air__Heaven/article/details/137470687 但是有可能有时候又跳不了了，可以多多执行一下 zotero-citation插件 github地址 ： https://github.com/MuiseDestiny/zotero-citation cl ht…...

编程日记 2025/5/3 13:08:32

《深度学习模型在鸿蒙分布式框架下的跨设备高效之旅》

在人工智能领域，深度学习模型的训练与推理通常需要强大的计算资源和大量的数据支持。而鸿蒙系统的分布式框架为解决这一问题提供了新的思路和方法，使得深度学习模型能够在多个设备之间实现高效的训练与推理。鸿蒙分布式框架概述鸿蒙系统是一款面向万…...

编程日记 2025/5/5 14:27:08

不同方式获取音频时长 - python 实现

DataBall 助力快速掌握数据集的信息和使用方式，会员享有百种数据集，持续增加中。需要更多数据资源和技术解决方案，知识星球： “DataBall - X 数据球(free)” -------------------------------------------------------------…...

编程日记 2025/5/8 21:04:12

用python实现烟花代码，完整代码拿走不谢

有时候用python实现一些有趣的代码，既有趣，又能提升知识使用Python实现动态烟花代码效果如下： 不废话，直接上代码： import pygame from random import randint, uniform, choice import mathvector pygame.math…...

编程日记 2025/5/6 10:05:38

[OPEN SQL] 限定选择行数

本次操作使用的数据库表为SCUSTOM，其字段内容如下所示航班用户(SCUSTOM) 该数据库表中的部分值如下所示指定查询多少行数据，我们可以使用语法UP TO n ROWS来实现对数据前n项的查询语法格式 SELECT * FROM <dbtab> UP TO n ROWS 参数说明 db…...

编程日记 2025/5/9 9:47:23

【入门级】计算机网络学习

网络安全：前端开发者必知：Web安全威胁——XSS与CSRF攻击及其防范-CSDN博客三次握手四次挥手：前端网络—三次握手四次挥手_前端三次握手-CSDN博客 http协议和https协议的区别：前端网络—http协议和https协议的区别-CSDN博客网…...

编程日记 2025/5/8 13:41:04

Redis 安装与 Spring Boot 集成指南

安装 Redis 和将其与 Spring Boot 应用集成是构建高效缓存解决方案的常见步骤。以下是详细的指南，帮助你在本地环境中安装 Redis，并在 Spring Boot 项目中配置和使用它。 1. 安装 Redis Windows 环境 Redis 官方并不直接支持 Windows，但你…...

编程日记 2025/5/6 19:18:45

基于 Python 和 OpenCV 的人脸识别上课考勤管理系统

博主介绍：✌程序员徐师兄、7年大厂程序员经历。全网粉丝12w、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专栏推荐订阅👇…...

编程日记 2025/5/6 19:34:58

【c/c++】 windows下调用putty

windows和linux系统存在差异，同样的数据在两边的终端行为都不一样，就很头疼。例如：换行符，win下是\r\n 而linux下是\n 又或者win下使用vi 好在找到了解决方案 1、通过第三方程序GoTTY（支持windows和Linux&#x…...

编程日记 2025/5/6 13:40:52

JVM常见面试题

1.内存泄漏与内存溢出的区别内存泄漏是指不再使用的对象无法得到及时的回收，持续占用内存空间，从而导致系统内存逐渐减少，系统性能下降，最终可能引发内存溢出内存溢出是指程序在运行时需要分配内存，但 JVM 没有足够的内存可以分配（超出可用内存大小），最终导致内存分配…...

编程日记 2025/5/6 11:11:16

手机租赁系统开发解决方案与市场趋势分析

内容概要手机租赁系统开发正如一场技术与商业的双重舞会，双方时而相互辉映，时而却也是一场较量。在这片快速变幻的市场中，了解当前的技术实现与挑战尤为重要。例如，系统架构的选择、数据安全性以及用户体验设计都可能成为企业发…...

编程日记 2025/5/6 16:02:52

基于Qt的OFD阅读器开发原理与实践

摘要本文详细探讨了基于Qt开发OFD阅读器的原理与实践。通过解析OFD文件格式、构建文档结构、实现页面渲染、处理用户交互以及进行性能优化，本文展示了如何使用Qt框架开发一个功能强大、性能优异的OFD阅读器。文章还提供了示例代码和未来发展方向，为开发…...

编程日记 2025/5/6 16:44:46

Redis实现高效的负载均衡算法

1. Redis存储设计我们需要在 Redis 中存储以下信息： 配置列表（List<Config>）：存储所有配置项。总权重：存储所有配置的总权重。当前轮询状态：存储当前的轮询状态（如当前随机值或索引&am…...

编程日记 2025/5/8 21:35:30

spring依赖注入

一、注入方式 1. 构造器注入构造器注入通过构造方法来注入依赖的对象。当Spring容器创建Bean时，会通过构造器来传递依赖对象。这种方式是最推荐的方式，因为它可以确保依赖对象在创建时已经完全注入。示例： Component public class Car…...

编程日记 2025/5/6 3:15:56

流浪猫流浪狗领养PHP网站源码

源码介绍流浪猫流浪狗领养PHP网站源码，适合做猫狗宠物类的发信息发布。当然其他信息发布也是可以的。导入数据库，修改数据库配置/application/database.php 设置TP伪静态，设置运行目录， 后台：/abcd.php/dashboard?…...

编程日记 2025/5/6 8:42:25

ffmpeg 编译遇到的坑

makeinfo: error parsing ./doc/t2h.pm: Undefined subroutine &Texinfo::Config::set_from_init_file called at ./doc/t2h.pm line 24. 编译选项添加： --disable-htmlpages...

编程日记 2025/5/8 0:07:02

灵活运用事务回滚，快捷处理多张数据表格

各位编程宝子们（尤其是对MySQL了解不多的宝子们）在使用关系表处理时，有时候会希望简单一次性解决多张表的数据处理，但又有时候无从下手。其实有时候掌握数据的事务和回滚便可以简单解决这些事情，接下来我将以一个学生信…...

编程日记 2025/5/9 9:12:22

MyBatis 性能优化

1. 引言 1.1 什么是 MyBatis？ MyBatis 是一款流行的 Java 持久层框架，能够将 Java 对象与 SQL 数据库映射起来。与传统的 JDBC 不同，MyBatis 提供了灵活的 SQL 映射功能，使开发者可以专注于业务逻辑，而无需编写冗长的…...

编程日记 2025/5/6 20:01:12

【python基础】python内置函数 zip用法介绍

zip() 是 Python 中非常有用的内建函数，能够将多个可迭代对象（如列表、元组、字符串等）打包成一个迭代器，它将对应位置的元素组合成元组，并返回一个由这些元组组成的迭代器。通常用于并行处理多个可迭代对象。 1. 基本…...

编程日记 2025/5/6 22:57:02

Unity Android AAB包GooglePlay上线备忘

aab GooglePlay要求新上线的App必须使用aab格式提交，在Unity Build Settings中勾选Build App Bundle 选项即可；或者在代码中设置： EditorUserBuildSettings.buildAppBundle true; 安装测试 https://developer.android.com/tools/bundlet…...

编程日记 2025/4/29 20:11:16

基于springboot的课程作业管理系统源码（springboot+vue+mysql）

风定落花生，歌声逐流水，大家好我是风歌，混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的课程作业管理系统。项目源码以及部署相关请联系风歌，文末附上联系信息。项目简介： 可以管理首页、个人中心…...

编程日记 2025/5/8 11:00:22

JVM生产环境常用参数配置及调优建议

一、生产常用参数配置 JAVA_OPTS="-server -Xms4G -Xmx4 -Xmn2G -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:InitiatingHeapOccupancyPercent=45 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=8 -XX:G1HeapRegionSize=16m -XX:MaxGCCount=10 -XX:MetaspaceSize=256m -XX:…...

编程日记 2025/5/6 15:56:14

vue 实现打包并同时上传至服务器端

将 publish_script 及以下文件 upload.server.js 添加到主文件下，与 src 同级别具体操作步骤： 1、安装 npm install scp2 2、将下面两条命令加入至 package.json 的 scripts 中 "upload": "node publish_script/upload.server.js&q…...

编程日记 2025/5/8 17:52:07

深入探索AI核心模型：CNN、RNN、GAN与Transformer

在人工智能的飞速发展中，众多深度学习模型和算法不断涌现，推动了许多领域的进步。特别是在图像识别、自然语言处理、生成建模等方向，AI模型的应用越来越广泛。本文将介绍几种最常用的AI模型，包括卷积神经网络（CNN&…...

编程日记 2025/5/6 19:57:15

【Elasticsearch】配置分片分配到指定节点

配置分片分配到指定节点参考文章：https://www.elastic.co/guide/en/elasticsearch/reference/current/shard-allocation-filtering.html 两种方式：根据节点属性分配和根据节点名称分配。测试环境 tar xvf elasticsearch-7.17.25-linux-x86_64.tar.gz…...

编程日记 2025/5/3 8:49:31