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

SpringBoot集成Dynamic-Datasource实现多数据源读写分离与事务管理

news 2026/5/28 15:18:52

1. 为什么需要多数据源读写分离？

做过电商系统的朋友应该都遇到过这样的场景：大促期间用户疯狂刷新商品详情页，数据库查询压力暴增，而订单提交量却相对平稳。这时候如果所有请求都打到同一个数据库上，很容易造成连接池耗尽、响应变慢甚至服务不可用。

我去年参与过一个社区团购项目就遇到过类似问题。最初我们只用了一个MySQL实例，结果晚上8点抢购时段经常出现数据库CPU飙到90%以上，页面加载需要5-6秒。后来我们做了读写分离改造，把查询请求分散到3个从库，写操作走主库，系统吞吐量直接提升了3倍。

读写分离的核心思想其实很简单：像MySQL这样的关系型数据库，读操作（SELECT）通常比写操作（INSERT/UPDATE/DELETE）多得多。通过配置多个数据源，让读请求分散到不同的数据库节点上，既能减轻主库压力，又能利用从库的水平扩展能力。

2. Dynamic-Datasource核心特性解析

2.1 框架优势对比

在Java生态中实现多数据源有多种方案，比如：

手动配置多个DataSource Bean
使用AbstractRoutingDataSource
MyBatis插件拦截
ShardingSphere等分布式方案

但经过实际项目验证，Dynamic-Datasource有几点独特优势：

近乎零侵入：只需要加个@DS注解就能切换数据源，不需要改现有SQL
事务友好：原生支持Spring事务，跨库事务也不在话下
动态管理：运行时可以动态增减数据源，特别适合云环境
生态完善：完美兼容MyBatis、Hibernate、JPA等主流ORM框架

2.2 核心工作机制

框架底层原理其实很有意思，它通过AOP在方法调用前后织入数据源切换逻辑。具体流程是这样的：

方法调用前，解析@DS注解确定目标数据源
将数据源key绑定到当前线程（ThreadLocal）
执行SQL时，从线程上下文中获取数据源
方法结束后，清理线程上下文

这种设计保证了即使在多线程环境下，每个请求都能正确路由到对应的数据库。我画个简单示意图：

[客户端请求] -> [@DS注解解析] -> [数据源绑定] -> [SQL执行] -> [结果返回] -> [上下文清理]

3. 实战：SpringBoot集成指南

3.1 环境准备

先准备两个MySQL实例（主从或者两个独立库都行），我这里用Docker快速搭建：

# 主库 docker run -p 3306:3306 --name mysql-master \ -e MYSQL_ROOT_PASSWORD=123456 \ -d mysql:8.0 # 从库 docker run -p 3307:3306 --name mysql-slave \ -e MYSQL_ROOT_PASSWORD=123456 \ -d mysql:8.0

建表语句参考：

-- 主库 CREATE DATABASE write_db; CREATE TABLE write_db.product ( id BIGINT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(100), price DECIMAL(10,2) ); -- 从库 CREATE DATABASE read_db; CREATE TABLE read_db.product ( id BIGINT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(100), price DECIMAL(10,2) );

3.2 项目配置

pom.xml关键依赖：

<dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>3.5.2</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.28</version> </dependency>

application.yml配置示例：

spring: datasource: dynamic: primary: master # 默认数据源 strict: true # 严格匹配模式 datasource: master: url: jdbc:mysql://localhost:3306/write_db username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver slave1: url: jdbc:mysql://localhost:3307/read_db username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver

3.3 注解使用技巧

基础用法：

@Service public class ProductService { @DS("slave1") // 指定数据源 public Product getById(Long id) { return productMapper.selectById(id); } @DS("master") public void save(Product product) { productMapper.insert(product); } }

高级技巧：

类级别注解作为默认数据源
方法注解会覆盖类注解
支持SpEL表达式动态切换：

@DS("#header.datasource") // 从请求头获取数据源 public List<Product> list() { return productMapper.selectList(); }

4. 事务管理深度解析

4.1 单数据源事务

常规写法即可：

@DS("master") @Transactional // 标准Spring事务 public void updatePrice(Long id, BigDecimal price) { Product product = getById(id); product.setPrice(price); update(product); }

4.2 跨数据源事务

这里有个大坑要注意：@Transactional会导致@DS失效！解决方案有两种：

方案一：XA分布式事务（适合强一致性场景）

@DSTransactional // 使用框架提供的事务注解 public void multiUpdate() { updateMaster(); // 操作主库 updateSlave(); // 操作从库 }

方案二：最终一致性（推荐）

public void eventualConsistency() { try { TransactionTemplate masterTx = new TransactionTemplate(masterTxManager); masterTx.execute(status -> { updateMaster(); return null; }); TransactionTemplate slaveTx = new TransactionTemplate(slaveTxManager); slaveTx.execute(status -> { updateSlave(); return null; }); } catch (Exception e) { // 补偿逻辑 compensation(); } }

5. 性能优化实战

5.1 连接池配置

建议为不同业务设置独立的连接池：

spring: datasource: dynamic: datasource: order-master: url: jdbc:mysql://localhost:3306/order hikari: maximum-pool-size: 20 connection-timeout: 30000 product-master: url: jdbc:mysql://localhost:3306/product hikari: maximum-pool-size: 10 connection-timeout: 10000

5.2 读写分离策略

实现智能路由：

@DS("#isReadOnly ? 'slave' : 'master'") public List<Product> queryProducts(Boolean isReadOnly) { return productMapper.selectList(); }

5.3 监控与运维

集成Druid监控：

@Bean public ServletRegistrationBean<StatViewServlet> druidServlet() { ServletRegistrationBean<StatViewServlet> reg = new ServletRegistrationBean<>(); reg.setServlet(new StatViewServlet()); reg.addUrlMappings("/druid/*"); return reg; }