如何配置MySQL多数据源_MySQL多个数据源同时连接方法

日期：2025-09-14 00:00 / 作者：雪夜

配置MySQL多数据源需明确场景如读写分离或微服务隔离，选用Spring Boot的AbstractRoutingDataSource等方案，正确配置多个数据源连接信息，通过动态路由实现切换，并注意事务管理与ThreadLocal清理，避免连接泄漏和数据源污染。

连接MySQL多个数据源，核心在于配置和管理多个数据库连接，以便在应用程序中根据需要切换和操作不同的数据库。这通常涉及到配置数据源连接池，并在代码中实现动态数据源切换逻辑。

解决方案

配置MySQL多数据源的关键在于明确你的应用场景，例如读写分离、微服务架构下的数据隔离等。之后，你需要选择合适的技术方案，例如Spring Boot的

AbstractRoutingDataSource

，或者MyBatis的动态数据源插件。

依赖引入：根据你选择的框架，引入必要的依赖。例如，在Spring Boot项目中，你需要引入
```
spring-boot-starter-jdbc
```
和MySQL驱动。

数据源配置：在

application.properties

或

application.yml

文件中配置多个数据源。

spring:
  datasource:
    dynamic:
      primary: master  # 默认数据源
      datasource:
        master:
          url: jdbc:mysql://master_host:3306/master_db?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
          username: master_user
          password: master_password
          driver-class-name: com.mysql.cj.jdbc.Driver
        slave:
          url: jdbc:mysql://slave_host:3306/slave_db?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
          username: slave_user
          password: slave_password
          driver-class-name: com.mysql.cj.jdbc.Driver

动态数据源实现：使用

AbstractRoutingDataSource

来实现动态数据源的切换。你需要创建一个类继承

AbstractRoutingDataSource

，并重写

determineCurrentLookupKey()

方法，该方法用于决定使用哪个数据源。

public class DynamicDataSource extends AbstractRoutingDataSource {

    private static final ThreadLocal contextHolder = new ThreadLocal<>();

    public DynamicDataSource(DataSource defaultTargetDataSource, Map targetDataSources) {
        super.setDefaultTargetDataSource(defaultTargetDataSource);
        super.setTargetDataSources(targetDataSources);
        super.afterPropertiesSet();
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return contextHolder.get();
    }

    public static void setDataSource(String dataSource) {
        contextHolder.set(dataSource);
    }

    public static void clearDataSource() {
        contextHolder.remove();
    }
}

数据源配置类：创建一个配置类，将多个数据源和动态数据源组装起来。

@Configuration
public class DataSourceConfig {

    @Bean
    @ConfigurationProperties("spring.datasource.dynamic.datasource.master")
    public DataSource masterDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @ConfigurationProperties("spring.datasource.dynamic.datasource.slave")
    public DataSource slaveDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Primary
    @Bean
    public DynamicDataSource dynamicDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
                                              @Qualifier("slaveDataSource") DataSource slaveDataSource) {
        Map targetDataSources = new HashMap<>();
        targetDataSources.put("master", masterDataSource);
        targetDataSources.put("slave", slaveDataSource);

        return new DynamicDataSource(masterDataSource, targetDataSources);
    }

    @Bean
    public DataSourceTransactionManager transactionManager(DynamicDataSource dynamicDataSource) {
        return new DataSourceTransactionManager(dynamicDataSource);
    }

    @Bean
    public SqlSessionFactory sqlSessionFactory(DynamicDataSource dynamicDataSource) throws Exception {
        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dynamicDataSource);
        // 配置 MyBatis 的其他属性，例如 Mapper 扫描路径等
        return factoryBean.getObject();
    }
}

使用动态数据源：在需要切换数据源的地方，调用

DynamicDataSource.setDataSource()

方法。

@Service
public class UserService {

    @Autowired
    private UserMapper userMapper;

    public User getUserFromMaster(Long id) {
        DynamicDataSource.setDataSource("master");
        User user = userMapper.selectById(id);
        DynamicDataSource.clearDataSource();
        return user;
    }

    public User getUserFromSlave(Long id) {
        DynamicDataSource.setDataSource("slave");
        User user = userMapper.selectById(id);
        DynamicDataSource.clearDataSource();
        return user;
    }
}

如何避免MySQL多数据源配置中的常见错误？

配置MySQL多数据源时，容易出现连接池配置不当、事务管理混乱、数据源切换逻辑错误等问题。为了避免这些错误，你需要：

仔细检查数据源URL、用户名、密码等配置，确保连接信息正确。
合理配置连接池参数，例如最大连接数、最小空闲连接数、连接超时时间等，避免连接耗尽或长时间等待。
使用事务管理器来保证数据一致性，尤其是在跨多个数据源进行操作时。
在数据源切换前后，务必清理ThreadLocal中的数据源标识，防止数据源污染。
使用AOP来简化数据源切换代码，避免在每个方法中手动切换数据源。

在微服务架构下，如何更好地管理MySQL多数据源？

在微服务架构下，每个服务通常拥有自己的数据库。管理这些数据源需要考虑以下几点：

使用配置中心统一管理数据源配置，例如Spring Cloud Config、Apollo等。
为每个服务创建独立的数据源，避免服务之间的数据互相影响。
使用服务发现机制来动态获取数据源的连接信息，例如Eureka、Consul等。
考虑使用分布式事务来保证跨多个服务的数据一致性，例如Seata、XA等。
监控每个数据源的性能指标，例如连接数、QPS、响应时间等，及时发现和解决问题。

如何实现MySQL多数据源的读写分离？

读写分离是一种常见的数据库优化策略，可以将读操作路由到从库，从而减轻主库的压力。实现读写分离，你需要：

配置一个主库和多个从库。
使用
```
AbstractRoutingDataSource
```
或类似的机制，根据请求类型（读或写）动态选择数据源。
在写操作时，强制使用主库。
在读操作时，可以随机选择一个从库，或者根据负载均衡策略选择从库。
考虑使用延迟复制的从库，但需要注意数据一致性问题。
可以使用MyBatis插件来实现读写分离，例如
```
mybatis-rw-separate
```
。

实现读写分离后，需要监控主从复制延迟，确保从库的数据与主库保持同步。如果延迟过高，可能会导致读取到过期数据。