1. 多数据源架构的必要性与挑战在企业级应用开发中多数据源的需求非常普遍。我最近在开发一个电商平台时就遇到了需要同时访问商品数据库和用户数据库的场景。这种架构设计通常出现在以下典型场景中业务数据隔离需求如多租户系统读写分离架构实现异构数据库整合MySQLOracle等分库分表场景下的数据访问使用Spring Boot默认的单数据源配置时我们会发现当尝试配置第二个数据源时Spring的自动配置机制就会失效。这是因为Spring Boot的DataSourceAutoConfiguration类在设计上就是为单数据源场景服务的。关键问题Spring Boot启动时会自动配置第一个找到的数据源而忽略其他数据源配置。这就是为什么我们需要手动管理多个数据源。2. 技术选型为什么是DruidMyBatisPlus组合2.1 Druid连接池的优势在众多数据库连接池中Druid以其强大的监控功能和稳定性脱颖而出。我在压力测试中发现与HikariCP相比Druid在高并发场景下表现更稳定监控全面内置StatFilter提供SQL监控防御SQL注入支持WallFilter性能优异经过阿里双十一验证扩展性强支持自定义过滤器// Druid的典型配置示例 Bean ConfigurationProperties(spring.datasource.druid) public DataSource dataSource() { return DruidDataSourceBuilder.create().build(); }2.2 MyBatisPlus的实用价值MyBatisPlus在简化CRUD操作方面表现出色特别是在多数据源环境下自动分页插件简化开发强大的条件构造器乐观锁等企业级功能与Spring Boot完美集成实际踩坑在多数据源环境下MyBatisPlus的自动注入需要特别注意后面会详细说明如何避免冲突。3. 完整配置实现步骤3.1 项目依赖配置首先需要在pom.xml中添加必要的依赖dependencies !-- Spring Boot Starter -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency !-- Druid连接池 -- dependency groupIdcom.alibaba/groupId artifactIddruid-spring-boot-starter/artifactId version1.2.8/version /dependency !-- MyBatisPlus -- dependency groupIdcom.baomidou/groupId artifactIdmybatis-plus-boot-starter/artifactId version3.5.2/version /dependency !-- 数据库驱动 -- dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId version8.0.28/version /dependency /dependencies3.2 多数据源YAML配置application.yml中的关键配置spring: datasource: # 主数据源 primary: driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/primary_db username: root password: 123456 type: com.alibaba.druid.pool.DruidDataSource druid: initial-size: 5 max-active: 20 min-idle: 5 max-wait: 60000 # 从数据源 secondary: driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/secondary_db username: root password: 123456 type: com.alibaba.druid.pool.DruidDataSource druid: initial-size: 3 max-active: 15 min-idle: 3 max-wait: 300003.3 主数据源配置类Configuration MapperScan(basePackages com.example.mapper.primary, sqlSessionFactoryRef primarySqlSessionFactory) public class PrimaryDataSourceConfig { Bean(name primaryDataSource) ConfigurationProperties(prefix spring.datasource.primary) Primary public DataSource primaryDataSource() { return DruidDataSourceBuilder.create().build(); } Bean(name primaryTransactionManager) Primary public DataSourceTransactionManager primaryTransactionManager( Qualifier(primaryDataSource) DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } Bean(name primarySqlSessionFactory) Primary public SqlSessionFactory primarySqlSessionFactory( Qualifier(primaryDataSource) DataSource dataSource) throws Exception { MybatisSqlSessionFactoryBean sessionFactory new MybatisSqlSessionFactoryBean(); sessionFactory.setDataSource(dataSource); sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources(classpath:mapper/primary/*.xml)); // MyBatisPlus配置 MybatisConfiguration configuration new MybatisConfiguration(); configuration.setMapUnderscoreToCamelCase(true); sessionFactory.setConfiguration(configuration); return sessionFactory.getObject(); } }3.4 从数据源配置类Configuration MapperScan(basePackages com.example.mapper.secondary, sqlSessionFactoryRef secondarySqlSessionFactory) public class SecondaryDataSourceConfig { Bean(name secondaryDataSource) ConfigurationProperties(prefix spring.datasource.secondary) public DataSource secondaryDataSource() { return DruidDataSourceBuilder.create().build(); } Bean(name secondaryTransactionManager) public DataSourceTransactionManager secondaryTransactionManager( Qualifier(secondaryDataSource) DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } Bean(name secondarySqlSessionFactory) public SqlSessionFactory secondarySqlSessionFactory( Qualifier(secondaryDataSource) DataSource dataSource) throws Exception { MybatisSqlSessionFactoryBean sessionFactory new MybatisSqlSessionFactoryBean(); sessionFactory.setDataSource(dataSource); sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources(classpath:mapper/secondary/*.xml)); // MyBatisPlus配置 MybatisConfiguration configuration new MybatisConfiguration(); configuration.setMapUnderscoreToCamelCase(true); sessionFactory.setConfiguration(configuration); return sessionFactory.getObject(); } }4. 关键避坑指南4.1 事务管理陷阱在多数据源环境下Spring的声明式事务管理(Transactional)默认只能作用于主数据源。要实现跨数据源事务需要引入分布式事务解决方案如Seata。// 错误示例这个事务注解只能管理primaryDataSource Transactional public void updateBothDatabases() { primaryMapper.update(...); secondaryMapper.update(...); // 这里出错不会回滚primary的操作 }4.2 MyBatisPlus自动注入冲突MyBatisPlus会自动配置SqlSessionFactory这会与我们的手动配置产生冲突。解决方案是在启动类上排除自动配置SpringBootApplication(exclude { DataSourceAutoConfiguration.class, MybatisPlusAutoConfiguration.class }) public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }4.3 连接池配置优化Druid连接池参数需要根据实际业务场景调整参数建议值说明initialSize5-10初始连接数maxActive20-100最大连接数minIdle5-10最小空闲连接maxWait60000获取连接超时时间(ms)timeBetweenEvictionRunsMillis60000检查间隔(ms)4.4 监控界面配置Druid提供了强大的监控功能需要单独配置Bean public ServletRegistrationBeanStatViewServlet druidServlet() { ServletRegistrationBeanStatViewServlet reg new ServletRegistrationBean(); reg.setServlet(new StatViewServlet()); reg.addUrlMappings(/druid/*); // 添加IP白名单 reg.addInitParameter(allow, 127.0.0.1); // 添加登录账号密码 reg.addInitParameter(loginUsername, admin); reg.addInitParameter(loginPassword, admin); return reg; }5. 性能优化建议5.1 SQL监控与分析启用Druid的SQL监控功能可以帮助发现性能瓶颈spring: datasource: druid: filters: stat,wall stat-view-servlet: enabled: true url-pattern: /druid/* login-username: admin login-password: admin5.2 多数据源路由策略对于更复杂的场景可以考虑实现动态数据源路由public class DynamicDataSource extends AbstractRoutingDataSource { Override protected Object determineCurrentLookupKey() { return DataSourceContextHolder.getDataSourceType(); } } // 使用示例 public void someServiceMethod() { DataSourceContextHolder.setDataSourceType(secondary); try { // 这里会使用secondary数据源 secondaryMapper.query(...); } finally { DataSourceContextHolder.clearDataSourceType(); } }5.3 MyBatisPlus插件配置在多数据源环境下配置MyBatisPlus插件需要特别注意Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor new MybatisPlusInterceptor(); // 分页插件 interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); // 乐观锁插件 interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); return interceptor; } // 需要在每个SqlSessionFactory中单独配置 sessionFactory.setPlugins(new Interceptor[]{mybatisPlusInterceptor()});6. 测试验证策略6.1 单元测试配置多数据源环境下的测试类需要特殊处理SpringBootTest TestPropertySource(locations classpath:application-test.yml) AutoConfigureTestDatabase(replace AutoConfigureTestDatabase.Replace.NONE) public class MultiDataSourceTest { Autowired Qualifier(primaryMapper) private UserMapper primaryMapper; Autowired Qualifier(secondaryMapper) private OrderMapper secondaryMapper; Test Transactional(primaryTransactionManager) public void testPrimaryDataSource() { // 测试主数据源 } Test Transactional(secondaryTransactionManager) public void testSecondaryDataSource() { // 测试从数据源 } }6.2 集成测试建议连接泄漏测试确保所有连接都能正确关闭并发测试模拟高并发场景下的连接池表现故障转移测试断开一个数据源验证系统行为性能对比测试与单数据源配置进行性能对比7. 生产环境部署建议7.1 监控指标配置建议监控以下关键指标每个数据源的活跃连接数SQL执行时间分布连接获取等待时间事务成功率7.2 高可用设计对于生产环境建议为每个数据源配置合理的超时参数实现熔断机制防止一个数据源故障影响整个系统考虑使用数据库中间件如ShardingSphere管理复杂场景我在实际项目中遇到过因为未配置合理的超时参数导致系统挂起的情况。后来通过以下配置解决了问题spring: datasource: primary: druid: connect-timeout: 3000 socket-timeout: 10000 secondary: druid: connect-timeout: 3000 socket-timeout: 10000多数据源配置虽然增加了系统复杂性但通过合理的架构设计和参数调优完全可以获得稳定可靠的性能表现。关键在于理解每个配置项背后的原理而不是简单复制粘贴配置。
