怎么利用 AbstractRoutingDataSource 实现多租户场景下的动态数据源切换-java教程-PHP中文网

核心就三件事：线程级租户标识绑定、路由键动态返回、数据源map预加载；需通过过滤器提取x-tenant-id或jwt tenant字段存入threadlocal，并在finally中清除，determinecurrentlookupkey()须返回与targetdatasources注册key完全一致的字符串，且不可为null。

怎么利用 abstractroutingdatasource 实现多租户场景下的动态数据源切换

直接结论：用 AbstractRoutingDataSource 做多租户数据源切换，核心就三件事——线程级租户标识绑定、路由键动态返回、数据源 Map 预加载。漏掉任一环，要么切换失效，要么内存泄漏。

怎么把租户 ID 绑定到当前线程

多租户场景下，每次请求都带租户上下文（比如 HTTP Header 里的 X-Tenant-ID 或 JWT 中的 tenant 字段），你得在进入业务逻辑前把它存进 ThreadLocal，且必须确保每次请求结束时清除。

常见错误现象：

没清 ThreadLocal → 后续请求复用前一个租户的数据源，查错库
用完不 remove() → 线程池复用导致内存泄漏（ThreadLocal 的 key 是弱引用，value 不会自动回收）

实操建议：

用过滤器（OncePerRequestFilter）或网关统一提取租户 ID，调用 DynamicDataSourceContextHolder.setTenantId("tenant_001")
务必在 finally 块里调用 DynamicDataSourceContextHolder.clearTenantId()
不要在异步线程（如 @Async）里直接复用该上下文，需手动传递并重设

determineCurrentLookupKey() 返回什么才对

这个方法不是返回数据库连接，也不是返回 URL，它只负责返回一个 Object 类型的 lookup key，这个 key 必须和你配置时注册进 targetDataSources 的 key 完全一致（包括大小写、空格）。

使用场景：

租户 ID 直接当 key：如 "tenant_a" 对应数据库 db_tenant_a
带前缀的 key：如 "ds-tenant_b"，此时 targetDataSources 里也得用同样前缀注册

容易踩的坑：

返回 null → Spring 报 No qualifying bean of type 'javax.sql.DataSource'，因为找不到默认数据源
返回未注册的 key（如 "tenant_x" 但没配）→ 报 IllegalStateException: Cannot determine target DataSource for lookup key [tenant_x]
返回 Integer 但配置用 String 当 key → 类型不匹配，路由失败（建议统一用 String）

示例片段：

@Override
protected Object determineCurrentLookupKey() {
    String tenantId = DynamicDataSourceContextHolder.getTenantId();
    if (tenantId == null) {
        return "default"; // 必须有兜底，不能返回 null
    }
    return tenantId;
}

targetDataSources 怎么初始化才安全

Spring 初始化 AbstractRoutingDataSource 时，会调用 afterPropertiesSet()，此时 targetDataSources 必须已加载完成，否则启动报错或后续路由为空。

性能与兼容性影响：

如果租户数上千，别在启动时一次性全加载；改用懒加载 + 缓存（比如 ConcurrentHashMap + computeIfAbsent）
Druid 连接池要为每个租户单独配置（maxActive、minIdle 等），避免共用连接池引发跨租户连接污染
MyBatis 的 SqlSessionFactory 只需一个，因为它依赖的是 DataSource 接口，不感知底层是哪个物理库

实操建议：

用 @ConfigurationProperties(prefix = "multi.tenant") 加载租户配置，结构类似：multi.tenant.tenant_001.url=...
在 DynamicDataSource 构造器里遍历配置，构建 Map<object datasource></object>，再调用 setTargetDataSources(...)
设置 setDefaultTargetDataSource(...) 指向一个“默认租户”或监控库，防止 lookup key 缺失时崩掉