Java案例如何实现动态数据源？

wen java案例 2026-06-16 1

本文目录导读：

Java案例如何实现动态数据源？

目录导读
什么是动态数据源？为什么需要它？
动态数据源的常见应用场景
核心实现原理：AbstractRoutingDataSource
Java案例：基于Spring Boot的动态数据源实现
关键代码拆解与问答环节
性能优化与注意事项
动态数据源的选型建议

Java案例如何实现动态数据源？从原理到实战的完整指南

目录导读

什么是动态数据源？为什么需要它？
动态数据源的常见应用场景
核心实现原理：AbstractRoutingDataSource
Java案例：基于Spring Boot的动态数据源实现
关键代码拆解与问答环节
性能优化与注意事项
动态数据源的选型建议

什么是动态数据源？为什么需要它？

问题：在传统的Java应用中，一个项目通常只连接一个数据库，但如果需求变化——比如需要支持多租户（每个客户一个独立库）、读写分离（主库写、从库读）或跨数据中心部署,单一的静态数据源就难以应对。

答案：动态数据源是一种设计模式，允许程序在运行时根据业务逻辑（如用户ID、请求来源、操作类型等）动态切换数据源,而无需重启应用或修改配置文件。

核心价值：

分离读写操作，提升数据库性能
实现多租户隔离，降低成本
增强系统扩展性，支持分库分表场景

动态数据源的常见应用场景

场景	具体需求	动态数据源作用
读写分离	主库负责写，从库负责读	根据方法注解（如@ReadOnly）自动切换
多租户SaaS	每个租户一个独立数据库	根据租户ID路由到对应数据源
数据分片	按业务维度（如地区、年份）分库	根据请求参数匹配数据源
灾备切换	主库宕机自动切到备库	结合健康检查动态切换

核心实现原理：AbstractRoutingDataSource

Spring框架提供了AbstractRoutingDataSource作为实现动态数据源的基类,它的工作逻辑如下：

初始化时配置多个数据源：将数据源对象以Map形式注入（如targetDataSources）。
注册一个默认数据源：当无法匹配时使用（如defaultTargetDataSource）。
运行时路由：重写determineCurrentLookupKey()方法，返回当前需要使用的数据源Key（通常是字符串标识）。
线程安全：通过ThreadLocal将Key绑定到当前线程,避免线程间污染。

Java案例：基于Spring Boot的动态数据源实现

1 项目结构概览

src/main/java/com/example/dynamic/
├── config
│   ├── DynamicDataSourceConfig.java   # 数据源配置
│   ├── DynamicDataSource.java          # 自定义路由类
│   └── DataSourceContextHolder.java    # 线程持有者
├── model/User.java
├── repository/UserRepository.java
└── service
    └── UserServiceImpl.java           # 业务切换逻辑

2 关键代码实现

步骤1：创建线程持有者（DataSourceContextHolder）

public class DataSourceContextHolder {
    private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();
    public static void setDataSource(String dataSource) {
        CONTEXT_HOLDER.set(dataSource);
    }
    public static String getDataSource() {
        return CONTEXT_HOLDER.get();
    }
    public static void clear() {
        CONTEXT_HOLDER.remove();
    }
}

步骤2：自定义数据源路由类

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSource();
    }
}

步骤3：配置多数据源（application.yml示例）

spring:
  datasource:
    master:
      url: jdbc:mysql://192.168.1.1:3306/master_db
      username: root
      password: pass1
    slave:
      url: jdbc:mysql://192.168.1.2:3306/slave_db
      username: slaveuser
      password: pass2

步骤4：动态切换业务逻辑

@Service
public class UserServiceImpl {
    @Autowired
    private UserRepository userRepository;
    public List<User> findAllFromSlave() {
        DataSourceContextHolder.setDataSource("slave");  // 切换到从库
        try {
            return userRepository.findAll();
        } finally {
            DataSourceContextHolder.clear();  // 清理线程
        }
    }
    @Transactional
    public void saveToMaster(User user) {
        DataSourceContextHolder.setDataSource("master"); // 切换到主库
        try {
            userRepository.save(user);
        } finally {
            DataSourceContextHolder.clear();
        }
    }
}