Wildfly定时任务抛出ResultSet已关闭SQLException异常求助

核心异常原因分析 #

java.sql.SQLException: Operation not allowed after ResultSet closed异常在AWS测试环境频繁出现，但本地正常，结合环境差异与代码逻辑，核心诱因集中在以下几点：

• Aurora Serverless连接特性：Aurora Serverless会自动暂停闲置连接、回收资源，若Hibernate尚未完成ResultSet读取，底层JDBC连接已被回收，直接导致ResultSet失效。
• 延迟加载与连接占用：Hibernate默认延迟加载ResultSet数据，而MongoDB Atlas的远程操作耗时远高于本地MongoDB，导致JDBC连接被长时间占用，触发连接池的超时回收机制。
• 事务边界冲突：若Store实现类的delete方法使用了@TransactionAttribute(REQUIRES_NEW)，会触发事务切换，原事务的JDBC连接被提前释放，导致未读取完成的ResultSet关闭。
• 连接池配置不合理：测试环境连接池未配置连接有效性验证，分配了已被Aurora回收的失效连接。

针对性解决方案 #

1. 调整Aurora适配的连接池配置 #

修改Wildfly数据源配置，适配Aurora Serverless的连接特性，避免分配失效连接：

<datasource jndi-name="java:jboss/datasources/YourDS" pool-name="YourDS">
    <connection-url>jdbc:mysql://your-aurora-endpoint:3306/dbname</connection-url>
    <driver>mysql</driver>
    <pool>
        <max-pool-size>20</max-pool-size>
        <min-pool-size>5</min-pool-size>
        <max-idle>10</max-idle>
        <test-on-borrow>true</test-on-borrow>
        <test-while-idle>true</test-while-idle>
        <remove-abandoned-timeout>60</remove-abandoned-timeout>
        <log-abandoned>true</log-abandoned>
    </pool>
    <validation>
        <valid-connection-checker class-name="org.jboss.jca.adapters.jdbc.extensions.mysql.MySQLValidConnectionChecker"/>
        <background-validation>true</background-validation>
        <background-validation-millis>60000</background-validation-millis>
        <exception-sorter class-name="org.jboss.jca.adapters.jdbc.extensions.mysql.MySQLExceptionSorter"/>
    </validation>
</datasource>

关键配置说明：

• test-on-borrow/test-while-idle：分配连接前、空闲时验证连接有效性
• background-validation：定期后台检查连接状态
• remove-abandoned-timeout：回收长时间未释放的连接并记录日志

2. 强制ResultSet立即加载到内存 #

修改Store.find方法的实现，将查询结果一次性加载到内存，脱离对JDBC连接的依赖：

// 在Store的find方法中，将查询结果转为ArrayList，强制立即加载
CriteriaQuery<Entity> query = criteriaBuilder.createQuery(Entity.class);
// ... 构建查询逻辑
List<Entity> rawResults = entityManager.createQuery(query).getResultList();
// 转为ArrayList确保所有数据被读取到内存
List<Entity> results = new ArrayList<>(rawResults);
return new FindResult<>(results.size(), results);

3. 统一事务边界 #

检查TokenConsumptionsQueueEntryStore和JobQueueEntryStore的delete方法，若使用了@TransactionAttribute(REQUIRES_NEW)，改为REQUIRED，确保查询与删除操作在同一个事务中执行，避免事务切换导致连接提前释放：

@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void delete(List<Entity> entities) {
    // 删除逻辑
}

4. 优化并发控制逻辑 #

将AbstractOneByOneWorker的信号量改为更安全的compareAndSet实现，避免并发场景下的信号量计数错误：

public abstract class AbstractOneByOneWorker extends AbstractJobWorker {
    private static final AtomicInteger semaphore = new AtomicInteger(0);

    @Override
    public final String process() throws Exception {
        // 原子性判断并设置信号量，避免并发抢占
        if (!semaphore.compareAndSet(0, 1)) {
            return BatchStatus.ABANDONED.toString();
        }
        try {
            oneByOneProcess();
            return BatchStatus.COMPLETED.toString();
        } finally {
            semaphore.set(0);
        }
    }
    
    public abstract void oneByOneProcess() throws Exception;
}

5. 优化MongoDB操作效率 #

减少远程调用耗时，避免JDBC连接被长时间占用：

• 批量处理MongoDB的创建/更新操作，将单条操作改为批量操作
• 若业务允许，将MongoDB操作移到JDBC事务提交之后执行（需保证数据一致性，可引入补偿机制）

验证步骤 #

1. 优先调整连接池配置，开启连接验证，观察异常是否消失
2. 强制ResultSet立即加载，测试是否解决ResultSet关闭问题
3. 检查事务边界，确保所有JDBC操作在同一事务内执行

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