SpringBoot多数据源配置:tech-pdai-spring-demos中的主从分离与读写分离实现
【免费下载链接】tech-pdai-spring-demosSpring Framework5/SpringBoot 2.5.x Demos项目地址: https://gitcode.com/gh_mirrors/te/tech-pdai-spring-demos
在现代应用开发中,数据库性能是系统稳定性的关键因素之一。随着业务增长,单一数据库往往难以承受高并发访问压力。SpringBoot多数据源配置通过主从分离与读写分离策略,能有效提升系统吞吐量和数据安全性。本文将以tech-pdai-spring-demos项目为基础,详解如何在SpringBoot中实现这一架构。
📌 核心概念:什么是主从分离与读写分离?
主从分离是指将数据库分为主库(Master)和从库(Slave):
- 主库:负责处理写操作(INSERT/UPDATE/DELETE)
- 从库:负责处理读操作(SELECT)
读写分离则是在应用层实现SQL操作的路由逻辑,自动将写请求分发到主库,读请求分发到从库。这种架构的优势在于:
- 减轻主库压力,避免读写冲突
- 从库可水平扩展,提升读操作并发能力
- 数据备份更安全,支持故障自动切换
🔍 项目中的实现方案:Sharding-JDBC集成
tech-pdai-spring-demos项目通过Sharding-JDBC实现多数据源管理,这是一款轻量级分布式数据库中间件,无需额外部署服务即可实现读写分离。核心实现位于246-springboot-demo-shardingjdbc-jpa-masterslave模块。
1️⃣ 数据源配置(application.yml)
在配置文件中定义主从数据源信息及路由规则:
spring: shardingsphere: datasource: names: master,slave0 # 数据源名称列表 master: # 主库配置 type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/test_db_sharding_master?allowPublicKeyRetrieval=true&useSSL=false username: test password: bfXa4Pt2lUUScy8jakXf slave0: # 从库配置 type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/test_db_sharding_slave0?allowPublicKeyRetrieval=true&useSSL=false username: test password: bfXa4Pt2lUUScy8jakXf master-slave: # 主从规则配置 name: ms # 主从数据源名称 load-balance-algorithm-type: round_robin # 负载均衡算法:轮询 master-data-source-name: master # 主库数据源名称 slave-data-source-names: slave0 # 从库数据源名称列表 props: sql: show: true # 显示SQL执行日志2️⃣ 关键配置解析
✅ 数据源命名与类型
- 通过
names属性定义所有数据源标识(master/slave0) - 使用HikariCP连接池(SpringBoot默认),提供高效连接管理
✅ 负载均衡策略
load-balance-algorithm-type: round_robin支持的算法包括:
ROUND_ROBIN:轮询从库RANDOM:随机选择从库- 自定义算法:实现
MasterSlaveLoadBalanceAlgorithm接口
✅ SQL日志开关
props: sql: show: true开启后可在控制台查看SQL执行详情,包括路由到的数据源信息,便于调试。
🚀 快速上手:项目实战步骤
1️⃣ 环境准备
# 克隆项目 git clone https://gitcode.com/gh_mirrors/te/tech-pdai-spring-demos cd tech-pdai-spring-demos/246-springboot-demo-shardingjdbc-jpa-masterslave2️⃣ 数据库配置
- 创建主库
test_db_sharding_master和从库test_db_sharding_slave0 - 配置主从复制(参考MySQL官方文档)
- 修改
application.yml中的数据库连接信息
3️⃣ 核心依赖
项目通过Maven管理依赖,关键依赖如下(pom.xml):
<!-- Sharding-JDBC核心依赖 --> <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>4.1.1</version> </dependency> <!-- JPA支持 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency>4️⃣ 业务代码示例
实体类定义
@Entity @Table(name = "tb_user") public class User extends BaseEntity { private String username; private String password; // getter/setter省略 }DAO层接口
public interface IUserDao extends JpaRepository<User, Long>, JpaSpecificationExecutor<User> { // 继承JpaRepository后自动获得CRUD能力 Optional<User> findByUsername(String username); }Service层实现
@Service @Transactional public class UserDoServiceImpl extends BaseDoServiceImpl<User, Long> implements IUserService { @Autowired private IUserDao userDao; @Override public User saveUser(User user) { // 写操作自动路由到主库 return userDao.save(user); } @Override public Optional<User> findByUsername(String username) { // 读操作自动路由到从库 return userDao.findByUsername(username); } }⚙️ 高级特性与扩展
1️⃣ 多从库扩展
如需增加从库,只需在配置中添加新数据源并更新从库列表:
spring: shardingsphere: datasource: names: master,slave0,slave1 # 新增slave1 # slave1数据源配置省略 master-slave: slave-data-source-names: slave0,slave1 # 添加新从库2️⃣ 自定义路由策略
通过实现MasterSlaveLoadBalanceAlgorithm接口自定义负载均衡逻辑:
public class CustomLoadBalanceAlgorithm implements MasterSlaveLoadBalanceAlgorithm { @Override public String getDataSource(String name, String masterDataSourceName, List<String> slaveDataSourceNames) { // 自定义路由规则 return slaveDataSourceNames.get(ThreadLocalRandom.current().nextInt(slaveDataSourceNames.size())); } }在配置中引用自定义算法:
master-slave: load-balance-algorithm-class-name: tech.pdai.springboot.shardingjdbc.jpa.masterslave.config.CustomLoadBalanceAlgorithm📝 总结与最佳实践
tech-pdai-spring-demos项目中的246-springboot-demo-shardingjdbc-jpa-masterslave模块提供了完整的主从分离实现,通过Sharding-JDBC实现零侵入式的读写分离。实际应用中建议:
- 监控主从延迟:定期检查从库同步状态,避免读取到过期数据
- 合理设置连接池:根据业务压力调整HikariCP参数(如
maximum-pool-size) - 读写分离注解:对特殊场景使用
@Master注解强制走主库读 - 性能测试:通过JMeter等工具验证读写分离效果
通过这种架构,应用可轻松应对高并发场景,同时为后续分库分表扩展奠定基础。更多实现细节可参考项目源码中的src/main/java/tech/pdai/springboot/shardingjdbc/jpa/masterslave目录。
【免费下载链接】tech-pdai-spring-demosSpring Framework5/SpringBoot 2.5.x Demos项目地址: https://gitcode.com/gh_mirrors/te/tech-pdai-spring-demos
创作声明:本文部分内容由AI辅助生成(AIGC),仅供参考