配置连接池租户告警的核心在于为每个逻辑租户分配独立的数据库连接资源，并通过监控这些资源的占用率、等待时间和创建失败次数来触发告警。具体做法是结合应用层的连接池（如 hikaricp）与数据库层面的租户标识（schema 或 database），在代码中注入动态数据源路由，同时利用 micrometer 或 jmx 暴露连接池指标，对接 prometheus + alertmanager 实现阈值告警。
如何按租户隔离连接池实例
通过动态数据源路由机制，根据请求中的租户 ID 切换底层物理连接池，确保不同租户的连接互不干扰。这种架构下，每个租户拥有独立的 HikariPool，从而可以单独监控其健康状态。
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
import javax.sql.DataSource;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class TenantRoutingDataSource extends AbstractRoutingDataSource {
private final Map<String, HikariDataSource> tenantPools = new ConcurrentHashMap<>();
@Override
protected Object determineCurrentLookupKey() {
return TenantContext.getTenantId(); // 从 ThreadLocal 获取当前租户
}
public DataSource getOrCreateTenantPool(String tenantId) {
return tenantPools.computeIfAbsent(tenantId, this::createPool);
}
private HikariDataSource createPool(String tenantId) {
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/" + tenantId);
config.setUsername("user_" + tenantId);
config.setPassword("pass_" + tenantId);
config.setMaximumPoolSize(10); // 每个租户独立限制
return new HikariDataSource(config);
}
}
上述代码展示了基于 AbstractRoutingDataSource 的动态路由实现。当请求进入时，TenantContext.getTenantId() 返回当前线程绑定的租户标识，框架自动选择对应的 HikariDataSource。每个租户的池大小由 setMaximumPoolSize 控制，避免单个租户耗尽全局资源。
立即学习“Java免费学习笔记（深入）”；
如何采集并告警连接池关键指标
使用 Micrometer 将 HikariCP 的指标绑定到 Spring Boot Actuator，重点监控 active_connections、idle_connections 和 connection_timeout_total。设置活跃连接数超过阈值（如最大池大小的 80%）或超时次数激增时发送告警。
import io.micrometer.core.instrument.MeterRegistry;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class DataSourceConfig {
@Bean
public HikariDataSource hikariDataSource(MeterRegistry registry) {
HikariDataSource ds = new HikariDataSource();
ds.setJdbcUrl("jdbc:mysql://localhost:3306/default_tenant");
ds.setMaximumPoolSize(20);
// 自动注册指标到 Micrometer
ds.setMetricRegistry(new com.codahale.metrics.MetricRegistry());
// 或通过自定义 MeterBinder 绑定
return ds;
}
}
该配置片段演示了如何将 HikariCP 与 Micrometer 集成。实际生产中需启用 spring-boot-starter-actuator，并在 application.yml 中配置 Prometheus 端点。告警规则可定义为：若 hikaricp_connections_active{pool="default"} > 16 持续 1 分钟，则触发 P2 级告警。同时应监控 hikaricp_connections_timeout_total，累计值突增表明连接争用严重。
当某租户连接池满时会发生什么
当某个租户的连接池达到最大容量且无空闲连接时，后续请求会阻塞等待可用连接，若等待时间超过 connectionTimeout（默认 30 秒），将抛出 SQLException 或 SQLTransientException。此时应用层需捕获异常并返回友好错误，同时触发告警以通知运维介入。
