Vert.x连接AWS RDS SQL Server出现ClosedConnectionException求助

针对你在AWS RDS SQL Server使用Vert.x插入数据时出现的间歇性连接异常（升级前Fail to read any response from the server，升级后io/vertx/sqlclient/ClosedConnectionException），可以从以下几个方向排查：

1. 连接池配置缺失，失效连接未及时清理 #

AWS RDS默认会主动断开闲置超过30分钟的连接，而你的当前连接池配置仅设置了maxSize，没有配置闲置超时、连接验证等机制，导致连接池保留了已被RDS断开的无效连接，使用时触发异常。

解决措施：
在PoolOptions中添加闲置超时、连接超时和自动清理规则，同时在MSSQLConnectOptions中配置连接验证查询：

• 设置idleTimeout让连接池主动回收闲置连接（建议短于RDS的闲置超时，比如10分钟）
• 添加testQuery让连接池在分配连接前验证连接有效性
• 配置connectionTimeout避免获取连接时无限等待
• 设置cleanerPeriod定期清理池内失效连接

2. Vert.x版本升级后的连接状态检测逻辑变更 #

Vert.x 4.4.0对连接状态的检测更加严格，相比4.3.8会直接抛出ClosedConnectionException来标记已断开的连接，而不是模糊的连接丢失报错。这意味着之前隐藏的无效连接问题被明确暴露出来。

解决措施：
确保连接池启用连接验证机制（即上述的testQuery配置），同时调整连接池的超时参数适配RDS的连接策略。

3. AWS RDS侧的网络或配置异常 #

• 检查RDS实例的CloudWatch监控：查看连接数、CPU使用率、内存使用率等指标，确认是否存在实例性能瓶颈或连接数耗尽的情况
• 核对RDS安全组和NACL规则：是否有临时变更导致网络间歇性中断
• 查看RDS参数组配置：确认remote_login_timeout、connect_timeout等参数是否合理，是否存在过短的超时设置
• 检查RDS维护记录：是否有自动备份、版本升级等操作导致连接短暂断开

4. 代码层面的连接使用不当 #

确认代码中是否存在未正确释放连接的情况：比如异步操作中未在回调里关闭连接、事务未正确提交/回滚导致连接被占用或处于无效状态。

优化后的连接池创建代码示例：

import java.util.concurrent.TimeUnit;

public static MSSQLPool createMssqlDbPool(Vertx vertx, ConfigModel configModel) {

    MSSQLConnectOptions connectOptions = new MSSQLConnectOptions()
      .setHost(System.getenv().getOrDefault("DB_HOST", configModel.getDbConfig().getHost()))
      .setPort(Integer.parseInt(System.getenv().getOrDefault("DB_PORT", configModel.getDbConfig().getPort())))
      .setDatabase(System.getenv().getOrDefault("DB_NAME", configModel.getDbConfig().getDatabase()))
      .setUser(System.getenv().getOrDefault("DB_USER", configModel.getDbConfig().getUser()))
      .setPassword(System.getenv().getOrDefault("DB_PASSWORD", configModel.getDbConfig().getPassword()))
      .setConnectTimeout(10000) // 10秒连接超时
      .setTestQuery("SELECT 1"); // 获取连接前验证有效性

    // Pool options
    PoolOptions poolOptions = new PoolOptions()
      .setMaxSize(4)
      .setIdleTimeout(10) // 闲置10分钟后回收连接
      .setIdleTimeoutUnit(TimeUnit.MINUTES)
      .setConnectionTimeout(5000) // 获取连接超时5秒
      .setCleanerPeriod(30) // 每30秒清理一次失效连接
      .setCleanerPeriodUnit(TimeUnit.SECONDS);

    LOG.info("DB connection : {}", connectOptions.toJson());

    return MSSQLPool.pool(vertx, connectOptions, poolOptions);

}

内容的提问来源于stack exchange，提问作者Sudhanshu Gupta