核心内容摘要
5步实现小说推文自动化：TaleStreamAI全流程解决方案
在企业级微服务开发中多数据源场景主从分离、多业务库协同十分常见默认 Spring Boot 单数据源配置无法满足需求且多数据源下的事务一致性、动态切换、读写分离路由等问题是生产级开发的核心痛点。
本文基于 Spring Boot
2.
x结合dynamic-datasource-spring-boot-starter实现动态多数据源配置落地主从分离读写分离、多数据源事务控制、跨库事务解决方案兼顾实用性与专业性适配生产环境复杂数据源场景。
核心认知多数据源场景与核心痛点
常见多数据源应用场景主从分离读写分离主库负责写入操作从库负责查询操作提升数据库并发处理能力多业务库隔离不同业务模块数据存储在不同数据库如订单库、用户库、商品库实现数据隔离与权限管控跨库联合查询单个业务需从多个数据库获取数据需动态切换数据源完成查询分库分表辅助配合分库分表框架实现不同分片库的动态访问。
生产级核心痛点数据源切换繁琐传统多数据源需手动配置多个 DataSource切换逻辑侵入业务代码读写分离路由不灵活无法按方法 / 注解自动路由主从库易出现 “读主库” 性能浪费多数据源事务难控制单数据源事务Transactional无法覆盖多库操作跨库事务一致性难以保障配置冗余多数据源连接池、驱动配置重复维护成本高动态扩容困难新增数据源需重启服务无法热加载。
核心技术选型选用dynamic-datasource-spring-boot-starter简称动态数据源核心优势零侵入基于 Spring AOP 实现数据源切换无需修改业务代码注解驱动支持DS注解指定数据源灵活适配多场景自动适配兼容 Spring 事务、MyBatis/MyBatis-Plus、JPA 等框架功能丰富支持主从分离、负载均衡、动态新增数据源、事务嵌套。
实战 1动态多数据源基础配置主从分离 多业务库
环境准备引入核心依赖xml!-- Spring Boot 核心依赖 -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency !-- 动态多数据源核心依赖 -- dependency groupIdcom.baomidou/groupId artifactIddynamic-datasource-spring-boot-starter/artifactId version
3.
1/version /dependency !-- MyBatis-Plus 依赖适配持久层 -- dependency groupIdcom.baomidou/groupId artifactIdmybatis-plus-boot-starter/artifactId version
3.
5.
1/version /dependency !-- MySQL 驱动 -- dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId scoperuntime/scope /dependency !-- 连接池HikariCP 原生适配 -- dependency groupIdcom.zaxxer/groupId artifactIdHikariCP/artifactId /dependency
多数据源配置application.yml支持主从分离 多业务库配置默认数据源为master主从库通过slave_xxx命名自动识别。
yamlspring: # 动态多数据源核心配置 datasource: dynamic: primary: master # 默认数据源主库 strict: false # 非严格模式未匹配到数据源时使用默认数据源 datasource: # 主库写入操作 master: url: jdbc:mysql://
127.
0.
1:3306/db_master?useUnicodetruecharacterEncodingutf8rewriteBatchedStatementstrueuseSSLfalse username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver # HikariCP 连接池配置 hikari: maximum-pool-size: 15 minimum-idle: 5 connection-timeout: 30000 idle-timeout: 600000 # 从库1查询操作 slave_1: url: jdbc:mysql://
127.
0.
1:3307/db_slave1?useUnicodetruecharacterEncodingutf8rewriteBatchedStatementstrueuseSSLfalse username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver hikari: maximum-pool-size: 20 minimum-idle: 8 # 从库2查询操作负载均衡 slave_2: url: jdbc:mysql://
127.
0.
1:3308/db_slave2?useUnicodetruecharacterEncodingutf8rewriteBatchedStatementstrueuseSSLfalse username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver hikari: maximum-pool-size: 20 minimum-idle: 8 # 业务库1订单库 order_db: url: jdbc:mysql://
127.
0.
1:3306/db_order?useUnicodetruecharacterEncodingutf8rewriteBatchedStatementstrueuseSSLfalse username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver # 业务库2用户库 user_db: url: jdbc:mysql://
127.
0.
1:3306/db_user?useUnicodetruecharacterEncodingutf8rewriteBatchedStatementstrueuseSSLfalse username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver
数据源切换核心用法DS 注解通过DS注解灵活指定数据源支持类级别全局生效和方法级别优先级更高。
1默认数据源主库无需注解java运行// 无DS注解默认使用master主库写入操作 Service public class ProductServiceImpl implements ProductService { Resource private ProductMapper productMapper; // 写入操作主库执行 Override Transactional(rollbackFor Exception.class) public boolean saveProduct(Product product) { return productMapper.insert(product) 0; } }2指定从库 / 业务库方法级注解java运行Service public class ProductServiceImpl implements ProductService { Resource private ProductMapper productMapper; Resource private OrderMapper orderMapper; Resource private UserMapper userMapper; // 读取操作指定slave_1从库 Override DS(slave_
public Product getProductById(Long id) { return productMapper.selectById(id); } // 读取操作主从负载均衡注解指定slave自动轮询slave_1/slave_2 Override DS(slave) public ListProduct listProduct() { return productMapper.selectList(null); } // 跨库查询分别访问订单库和用户库 DS(order_db) public Order getOrderById(Long orderId) { return orderMapper.selectById(orderId); } DS(user_db) public User getUserById(Long userId) { return userMapper.selectById(userId); } }3类级注解统一指定数据源java运行// 类级DS该类所有方法默认使用order_db订单库 Service DS(order_db) public class OrderServiceImpl implements OrderService { Resource private OrderMapper orderMapper; // 默认使用order_db无需重复注解 public Order getOrder(Long id) { return orderMapper.selectById(id); } // 方法级注解覆盖类级指定master主库执行写入 Override DS(master) Transactional(rollbackFor Exception.class) public boolean createOrder(Order order) { return orderMapper.insert(order) 0; } }
实战 2主从分离读写分离自动路由无注解方案通过 AOP 自定义规则实现 “写入自动走主库读取自动走从库”无需手动加DS注解降低开发成本。
自定义读写分离路由规则java运行package com.example.datasource.config; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Pointcut; import org.aspectj.lang.reflect.MethodSignature; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.stereotype.Component; import java.lang.reflect.Method; /** * 读写分离自动路由AOP无需DS注解自动路由主从库 */ Aspect Component public class ReadWriteSplitAop { // 切点所有Service层方法 Pointcut(execution(* com.example.datasource.service.*.*(..))) public void servicePointcut() {} Around(servicePointcut()) public Object around(ProceedingJoinPoint joinPoint) throws Throwable { //
优先判断方法/类是否有DS注解有则直接使用不执行自动路由 MethodSignature signature (MethodSignature) joinPoint.getSignature(); Method method signature.getMethod(); DS methodDs AnnotationUtils.findAnnotation(method, DS.class); DS classDs AnnotationUtils.findAnnotation(joinPoint.getTarget().getClass(), DS.class); if (methodDs ! null || classDs ! null) { return joinPoint.proceed(); } //
无DS注解按方法名判断读写操作 String methodName method.getName().toLowerCase(); try { // 写入方法走主库master if (methodName.startsWith(save) || methodName.startsWith(insert) || methodName.startsWith(update) || methodName.startsWith(delete) || methodName.startsWith(create)) { DynamicDataSourceContextHolder.push(master); } else { // 读取方法走从库slave自动负载均衡 DynamicDataSourceContextHolder.push(slave); } return joinPoint.proceed(); } finally { //
清除数据源上下文避免污染 DynamicDataSourceContextHolder.poll(); } } }
启用 AOP 路由确保 Spring Boot 开启 AOP 支持引入 spring-boot-starter-aop 依赖默认已包含无需额外配置启动后自动生效。
实战 3多数据源事务控制单库 / 跨库多数据源场景下事务控制分单数据源事务和跨数据源事务需针对性处理。
单数据源事务直接使用 Transactional单个数据源内的操作直接使用 Spring 原生Transactional注解完全兼容。
java运行// 单数据源order_db事务正常生效 Service DS(order_db) public class OrderServiceImpl implements OrderService { Resource private OrderMapper orderMapper; Resource private OrderItemMapper orderItemMapper; // 单库事务订单订单项插入同属order_db事务生效 Override Transactional(rollbackFor Exception.class) public boolean createOrder(Order order, ListOrderItem items) { // 插入订单 orderMapper.insert(order); // 插入订单项 items.forEach(item - { item.setOrderId(order.getId()); orderItemMapper.insert(item); }); return true; } }
跨数据源事务分布式事务解决方案跨多个数据源的操作单Transactional无法保证一致性需结合分布式事务框架Seata实现核心步骤如下1引入 Seata 依赖xmldependency groupIdcom.alibaba.cloud/groupId artifactIdspring-cloud-starter-alibaba-seata/artifactId version
2021.
0.
0/version /dependency2配置 Seata 事务分组yamlseata: tx-service-group: order_tx_group # 事务分组 registry: type: nacos nacos: server-addr:
127.
0.
1:8848 namespace: dev group: SEATA_GROUP config: type: nacos nacos: server-addr:
127.
0.
1:8848 namespace: dev group: SEATA_GROUP3跨库事务实现GlobalTransactionaljava运行Service public class CrossDbService { Resource private OrderService orderService; // 操作order_db Resource private UserService userService; // 操作user_db // 跨库事务订单创建用户积分更新通过Seata保证一致性 GlobalTransactional(rollbackFor Exception.class, timeoutMills
public boolean createOrderWithUserPoint(Order order, Long userId, Integer point) { //
订单库操作order_db boolean orderSuccess orderService.createOrder(order); if (!orderSuccess) { throw new RuntimeException(订单创建失败); } //
用户库操作user_db boolean pointSuccess userService.updateUserPoint(userId, point); if (!pointSuccess) { throw new RuntimeException(用户积分更新失败); } return true; } }
生产级优化与避坑指南
性能优化要点连接池优化主库侧重写入连接池大小适中
从库侧重读取连接池可稍大
从库负载均衡动态数据源默认支持slave关键字轮询负载均衡高并发可配置权重避免跨库查询尽量减少跨库联合查询可通过数据同步如 Canal将数据同步到统一查询库数据源懒加载开启dynamic-datasource.lazy: true按需加载数据源减少启动耗时。
常见坑点与解决方案注解优先级问题方法级DS 类级DS 默认数据源避免注解冲突事务与数据源冲突Transactional需与DS作用于同一数据源跨库事务必须用GlobalTransactional从库延迟问题主从同步存在延迟核心业务读取可临时走主库避免数据不一致动态数据源切换失效确保 AOP 切面生效避免方法内部调用内部调用不触发 AOP连接泄露确保连接池配置合理避免长时间占用连接及时释放数据源上下文。
六、
总结Spring Boot 结合dynamic-datasource-spring-boot-starter实现多数据源管理
核心价值在于零侵入、灵活切换、兼容主流框架配合 AOP 可实现读写分离自动路由结合 Seata 可解决跨库事务一致性问题。
生产落地时需根据业务场景选择合适的数据源策略兼顾性能与一致性同时规避注解冲突、事务失效等坑点保障多数据源场景下的服务稳定性。