本文详解如何解决 javafx 应用中多个数据库任务串行阻塞问题——核心在于摒弃单连接模式，改用 hikaricp 连接池，使每个 task 独立获取连接，真正实现并行执行。
本文详解如何解决 javafx 应用中多个数据库任务串行阻塞问题——核心在于摒弃单连接模式，改用 hikaricp 连接池，使每个 task 独立获取连接，真正实现并行执行。
在 JavaFX 开发中，使用 Task 在后台线程执行数据库操作是避免 UI 冻结的标准实践。但若所有数据库调用共享同一个 JDBC Connection 实例（如原代码中 DataHandler.conn 为静态单例），即使任务在不同线程中启动，底层仍会因连接被独占而被迫串行化——这就是为何 CALL 1（7秒）未完成时，CALL 2（550ms）虽已进入 RUNNING 状态，却实际处于连接等待队列中，无法真正并发执行。
根本原因在于：JDBC Connection 不是线程安全的，且多数数据库驱动默认不允许多线程复用同一连接实例。原 DAO 设计中全局静态 Connection conn 是性能瓶颈与并发障碍的根源。
✅ 正确解法：引入 HikariCP 连接池，为每次数据库操作动态分配独立连接，彻底解除线程间连接争用。
一、迁移至 HikariCP 的关键步骤
-
添加依赖（Maven）：
<dependency> <groupId>com.zaxxer</groupId> <artifactId>HikariCP</artifactId> <version>5.0.1</version> </dependency>
-
重构 DAO 类：移除静态 Connection，改用 HikariDataSource 管理连接池：
private static HikariDataSource dataSource = null;
private void dbConnection(String ipPort) { String dbUrl = "jdbc:mysql://" + ipPort + "/database?serverTimezone=UTC"; HikariConfig config = new HikariConfig(); config.setJdbcUrl(dbUrl); config.setUsername("user"); config.setPassword("password"); config.setMaximumPoolSize(30); // 根据并发需求调整 config.setAutoCommit(true); config.addDataSourceProperty("cachePrepStmts", "true"); config.addDataSourceProperty("prepStmtCacheSize", "250"); // ... 其他优化配置（见原文）
dataSource = new HikariDataSource(config);
}
3. **按需获取连接（关键！）**：每次数据库操作必须通过 `dataSource.getConnection()` 获取新连接，并**严格使用 try-with-resources 自动释放**：
```java
public ObservableList<ProduitVendu> getProduitsVendusParPeriode(
LocalDate dateDebut, LocalDate dateFin,
boolean isEspece, boolean isDebit, String nomSearch) {
String sql = buildDynamicQuery(isEspece, isDebit); // 构建 SQL（略）
try (Connection conn = dataSource.getConnection(); // ✅ 每次调用获取独立连接
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, "%" + nomSearch + "%");
stmt.setString(2, dateDebut.toString());
stmt.setString(3, dateFin.toString());
try (ResultSet rs = stmt.executeQuery()) {
ObservableList<ProduitVendu> result = FXCollections.observableArrayList();
while (rs.next()) {
result.add(new ProduitVendu(/*...*/));
}
return result;
}
} catch (SQLException ex) {
ex.printStackTrace();
return FXCollections.emptyObservableList();
}
}⚠️ 注意事项：
- 绝不缓存 Connection：Connection 必须在方法内创建、使用、关闭；静态或成员变量持有连接会导致资源泄漏和线程安全问题。
- 务必使用 try-with-resources：确保 Connection、PreparedStatement、ResultSet 在作用域结束时自动关闭，归还连接至池中。
- 合理设置连接池大小：maximumPoolSize 应略大于预期并发请求数（如 20–50），过小导致排队，过大增加数据库负载。
二、验证并发效果
改造后，loadHistoriqueVentesData() 中的 Task 将真正并行执行：
// CALL 1 和 CALL 2 可同时触发，各自从连接池获取连接 exec.execute(() -> db.getProduitsVendusParPeriode(...)); // 7s 查询 exec.execute(() -> db.getAdherents()); // 550ms 查询
此时两个任务不再相互阻塞——CALL 2 将在约 550ms 后完成，而非等待 CALL 1 的 7 秒。
总结
- ❌ 错误模式：单 Connection 全局共享 → 伪异步，实为串行。
- ✅ 正确模式：HikariCP 连接池 + 每次操作独立连接 + 自动资源回收 → 真正的高并发。
- ? 额外建议：对高频查询启用 PreparedStatement 缓存（HikariCP 已配置）、使用 executeAsync() 替代手动 Executor 管理（JavaFX 17+），并监控连接池活跃数（dataSource.getHikariPoolMXBean().getActiveConnections()）以持续优化。
通过这一重构，你的 JavaFX 应用不仅能保持 UI 流畅，更能充分发挥数据库并发能力，显著提升多任务场景下的响应速度。
