Spring?Boot?+?MySQL讀寫分離實現(xiàn)方案全過程
更新時間：2025年12月12日 10:22:04 作者：ZePingPingZe
讀寫分離是數(shù)據(jù)庫架構中的一種優(yōu)化策略,它將讀操作和寫操作分開處理,通常通過將讀請求和寫請求分別發(fā)送到不同的數(shù)據(jù)庫服務器來實現(xiàn),這篇文章主要介紹了Spring?Boot?+?MySQL讀寫分離實現(xiàn)方案的相關資料,需要的朋友可以參考下
一、MySQL主從復制搭建（一主一從）
1. 主庫配置
# 1. 修改主庫配置文件 /etc/my.cnf [mysqld] server-id=1 # 唯一ID log-bin=mysql-bin # 啟用二進制日志 binlog-format=mixed # 二進制日志格式
重啟MySQL后執(zhí)行：
# 2. 創(chuàng)建復制賬號 CREATE USER 'repl'@'%' IDENTIFIED BY 'repl_password'; GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%'; # 3. 查看二進制日志坐標 SHOW MASTER STATUS; # 記錄File和Position，例如：File 'mysql-bin.000001', Position 154
2. 從庫配置
# 1. 修改從庫配置文件 /etc/my.cnf [mysqld] server-id=2 # 必須與主庫不同 relay-log=mysql-relay-bin # 中繼日志 log-slave-updates=1 # 使從庫也能作為其他從庫的主庫
重啟MySQL后執(zhí)行：
# 2. 配置主從連接 CHANGE MASTER TO MASTER_HOST='主庫IP', MASTER_USER='repl', MASTER_PASSWORD='repl_password', MASTER_LOG_FILE='mysql-bin.000001', MASTER_LOG_POS=154; # 3. 啟動復制 START SLAVE; # 4. 驗證 SHOW SLAVE STATUS\G # 確認Slave_IO_Running和Slave_SQL_Running都是Yes
?? 小貼士：主從復制需要確保網(wǎng)絡通暢，主庫防火墻開放3306端口，從庫能訪問主庫的3306端口。
二、Spring Boot讀寫分離實現(xiàn)（推薦Dynamic-Datasource）
1. 添加Maven依賴（pom.xml）
<dependencies>
<!-- Spring Boot Starter -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- MyBatis-Plus -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.3.2</version>
</dependency>
<!-- Dynamic-Datasource（核心） -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.6.1</version>
</dependency>
<!-- MySQL驅動 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.33</version>
</dependency>
<!-- 連接池（可選） -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.16</version>
</dependency>
</dependencies>
2. 配置文件（application.yml）
spring:
datasource:
dynamic:
primary: master # 默認數(shù)據(jù)源
datasource:
master:
url: jdbc:mysql://主庫IP:3306/db_name?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
username: root
password: master_password
driver-class-name: com.mysql.cj.jdbc.Driver
hikari:
maximum-pool-size: 10
minimum-idle: 5
slave:
url: jdbc:mysql://從庫IP:3306/db_name?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
username: root
password: slave_password
driver-class-name: com.mysql.cj.jdbc.Driver
hikari:
maximum-pool-size: 15
minimum-idle: 8
strategy:
# 讀寫分離策略：讀操作走從庫，寫操作走主庫
# 可選：round_robin（輪詢）、random（隨機）等
datasource:
master: slave
3. 代碼實現(xiàn)
a. 定義數(shù)據(jù)源枚舉
public enum DataSourceType {
MASTER, // 主庫：寫操作
SLAVE // 從庫：讀操作
}
b. 數(shù)據(jù)源上下文管理器
public class DataSourceContextHolder {
private static final ThreadLocal<DataSourceType> CONTEXT_HOLDER = new ThreadLocal<>();
public static void setDataSourceType(DataSourceType dataSourceType) {
CONTEXT_HOLDER.set(dataSourceType);
}
public static DataSourceType getDataSourceType() {
return CONTEXT_HOLDER.get() == null ? DataSourceType.MASTER : CONTEXT_HOLDER.get();
}
public static void clearDataSourceType() {
CONTEXT_HOLDER.remove();
}
}
c. 使用AOP標注讀寫操作
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataSource {
DataSourceType value() default DataSourceType.MASTER;
}
d. AOP切面實現(xiàn)
@Aspect
@Component
public class DataSourceAspect {
@Before("@annotation(dataSource)")
public void before(JoinPoint point, DataSource dataSource) {
DataSourceType type = dataSource.value();
DataSourceContextHolder.setDataSourceType(type);
}
@After("@annotation(dataSource)")
public void after(JoinPoint point, DataSource dataSource) {
DataSourceContextHolder.clearDataSourceType();
}
}
e. 在Service層使用
@Service
public class OrderService {
@Autowired
private OrderMapper orderMapper;
// 寫操作：默認走主庫（也可以顯式指定）
@DataSource(DataSourceType.MASTER)
public void createOrder(Order order) {
orderMapper.insert(order);
}
// 讀操作：默認走從庫
@DataSource(DataSourceType.SLAVE)
public Order getOrderById(Long id) {
return orderMapper.selectById(id);
}
}
三、Redis和MQ整合方案分析
項目引入 redis和mq ，針對【熱門數(shù)據(jù)】的查詢可以從redis查詢，代碼層面往MySQL主庫執(zhí)行增刪改操作后往mq發(fā)送一條消息，然后由消費者將增刪改的數(shù)據(jù)同步到redis中，當然這樣的方案只適合少量的增刪改操作，不適合大批量的增刪改。
優(yōu)點：
- 保證了數(shù)據(jù)一致性（先寫庫，再更新緩存）
- 適合熱點數(shù)據(jù)緩存
- 降低數(shù)據(jù)庫壓力
問題與建議：
不適合大批量操作：大批量增刪改會導致MQ消息量過大，處理延遲高。建議：
- 對于大批量操作，使用批量同步（如Redis的pipeline）而不是MQ。
- 或者使用定時任務定期同步熱點數(shù)據(jù)。
消息可靠性：需要考慮MQ消息丟失、重復消費問題：
- 使用RocketMQ/RabbitMQ的事務消息。
- 添加消息重試機制。
- 消費者 添加 冪等性 處理。
更適合的場景：
- 用戶信息、商品詳情等高頻查詢數(shù)據(jù)。
- 但 不適用于 訂單狀態(tài)、交易流水等 高一致性 要求的數(shù)據(jù)。
優(yōu)化：
@Service
public class OrderService {
@Autowired
private RabbitTemplate rabbitTemplate;
@DataSource(DataSourceType.MASTER)
@Transactional
public Order createOrder(Order order) {
// 1. 寫數(shù)據(jù)庫
Order savedOrder = orderMapper.insert(order);
// 2. 發(fā)送MQ消息（只針對需要緩存的數(shù)據(jù)）
if (isCacheableData(order)) {
rabbitTemplate.convertAndSend("order-cache-topic",
new OrderCacheMessage(savedOrder.getId(), "CREATE"));
}
return savedOrder;
}
}
// 消費者處理
@Component
public class OrderCacheConsumer {
@RabbitListener(queues = "order-cache-queue")
public void process(OrderCacheMessage message) {
if ("CREATE".equals(message.getAction())) {
Order order = orderMapper.selectById(message.getOrderId());
redisTemplate.opsForValue().set("order:" + message.getOrderId(), order);
}
// 處理其他操作...
}
}
四、總結
讀寫分離：使用Dynamic-Datasource，配置簡單，社區(qū)支持好，比Sharding-JDBC更輕量
Redis+MQ方案：
- 適合 熱點數(shù)據(jù) 的緩存更新。
- 不適用于 大批量操作。
- 建議對需要緩存的數(shù)據(jù)做分類，只對高頻查詢的數(shù)據(jù)使用MQ同步。
建議：
- 在查詢方法上使用
@DataSource(DataSourceType.SLAVE)顯式指定，避免默認路由錯誤。 - 對于復雜查詢，可以考慮在MyBatis中使用
@Select指定數(shù)據(jù)源。 - 監(jiān)控主從延遲，避免從庫數(shù)據(jù)不一致。
- 在查詢方法上使用
?? 小技巧：在開發(fā)階段，可以在配置中添加
dynamic.datasource.log=true，這樣能打印出實際使用的數(shù)據(jù)源，方便排查問題。
到此這篇關于Spring Boot + MySQL讀寫分離實現(xiàn)方案的文章就介紹到這了,更多相關SpringBoot+MySQL讀寫分離內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
你是否曾為PDF文件傳輸?shù)牡托识鄲?？現(xiàn)在,有了這份Java實現(xiàn)高效PDF文件傳輸技巧指南,你將能夠輕松解決這個問題,我們將分享一些實用的技巧和最佳實踐,幫助你優(yōu)化文件傳輸過程,不要錯過這個提高工作效率的機會,快來閱讀這份指南吧！2024-03-03
SpringBoot前后端分離跨域問題:狀態(tài)碼403拒絕訪問解決辦法
這篇文章主要給大家介紹了關于SpringBoot前后端分離跨域問題:狀態(tài)碼403拒絕訪問的解決辦法,403是被服務器拒絕了,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-01-01
這篇文章主要介紹了Java線程實現(xiàn)的兩種方式解析,注意在構造器中啟動這個線程的話,很容易造成this逃逸的問題,這是要注意的,這是通過直接集成thread來成為線程,同時在這種情況下,你可以通過調用合適的方法來,需要的朋友可以參考下2024-01-01
這篇文章主要為大家詳細介紹了Java實現(xiàn)按行分割大文件，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-05-05
SpringBoot調用Poi-tl實現(xiàn)渲染數(shù)據(jù)并生成Word文檔
這篇文章主要為大家詳細介紹了SpringBoot如何調用Poi-tl實現(xiàn)渲染數(shù)據(jù)并生成Word文檔,文中的示例代碼講解詳細,有需要的小伙伴可以了解下2023-09-09
這篇文章主要介紹了SpringCloud微服務應用-config配置中心，包括相關知識介紹、搭建、動態(tài)刷新、測試，本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-07-07
sleep() 的作用是讓當前線程休眠，即當前線程會從“運行狀態(tài)”進入到“休眠(阻塞)狀態(tài)”。下面通過實例代碼給大家介紹Java線程休眠的知識，需要的朋友參考下吧2017-05-05
Java使用Spire.Presentation在PowerPoint中添加或刪除表格行與列
在日常開發(fā)中,Java 開發(fā)者常需自動化生成報告PPT,手動編輯PowerPoint 表格行與列效率低下,尤其批量操作時易出錯,Spire.Presentation for Java 庫提供高效解決方案,本文分享實用代碼與步驟,助你快速上手,需要的朋友可以參考下2026-02-02
使用Java7的Files工具類和Path接口來訪問文件的方法
下面小編就為大家分享一篇使用Java7的Files工具類和Path接口來訪問文件的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-11-11
Stream API提供了一種高效、聲明式的數(shù)據(jù)處理方式,是現(xiàn)代 Java 編程中不可或缺的工具,合理使用可以大幅提升代碼的可讀性和維護性,這篇文章主要介紹了java的Stream流處理,需要的朋友可以參考下2025-06-06