Java 数据库连接池怎么配置连接池高可用
通过配置连接池的自动重试、健康检查以及多数据源切换来实现高可用。核心做法是启用 testonborrow 或 validationquery 确保获取的连接有效，并设置合理的 maxlifetime 和 minidle 防止连接失效。若需应对单点故障，可结合主从切换逻辑或引入支持动态路由的中间件。
如何配置 HikariCP 的健康检查与超时参数
HikariCP 默认已具备较强的可用性保障，主要通过 connectionTimeout、idleTimeout 和 maxLifetime 三个参数控制。配置这些参数可以防止应用因等待无效连接而阻塞，同时定期清理过期连接以维持池内连接的健康状态。
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
public class PoolConfig {
public static void main(String[] args) {
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/testdb");
config.setUsername("user");
config.setPassword("password");
// 获取连接超时时间，毫秒
config.setConnectionTimeout(3000);
// 空闲连接最大存活时间，毫秒
config.setIdleTimeout(600000);
// 连接最大生命周期，毫秒
config.setMaxLifetime(1800000);
// 最小空闲连接数
config.setMinimumIdle(5);
// 最大连接数
config.setMaximumPoolSize(10);
HikariDataSource dataSource = new HikariDataSource(config);
System.out.println("Pool initialized with HA settings.");
}
}
如何实现多数据源的主从切换逻辑
在单点故障场景下，仅靠连接池内部机制无法实现故障转移。需要应用层或中间件层实现主从切换逻辑。常见做法是使用 AbstractRoutingDataSource 动态切换目标数据源，或在连接失败时尝试备用地址。以下示例展示了基于简单规则的主从切换模拟。
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class HaDataSourceRouter extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
// 简单模拟：根据线程上下文或异常状态切换
// 实际生产中应结合监控和故障检测
return "master";
}
public static void main(String[] args) {
// 模拟主库
DataSource master = new MockDataSource("master");
// 模拟从库
DataSource slave = new MockDataSource("slave");
HaDataSourceRouter router = new HaDataSourceRouter();
router.setTargetDataSources(
java.util.Collections.singletonMap("master", master),
java.util.Collections.singletonMap("slave", slave)
);
router.setDefaultTargetDataSource(master);
try {
Connection conn = router.getConnection();
System.out.println("Connected to: " + conn.getMetaData().getURL());
} catch (SQLException e) {
e.printStackTrace();
}
}
}
class MockDataSource implements DataSource {
private String name;
public MockDataSource(String name) { this.name = name; }
public Connection getConnection() throws SQLException {
return new MockConnection(name);
}
// 其他方法省略...
}
class MockConnection implements Connection {
private String source;
public MockConnection(String source) { this.source = source; }
public java.sql.DatabaseMetaData getMetaData() throws SQLException {
return new java.sql.DatabaseMetaData() {
public String getURL() { return "jdbc:mysql://" + source + ":3306/db"; }
// 其他方法省略...
};
}
// 其他方法省略...
}
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
