Java+Hibernate+C3P0连接Azure SQL时连接中断问题求助

一、修正C3P0连接池有效性配置 #

你的acquireRetryAttempts=0仅控制获取新连接阶段的重试逻辑，但当前异常是连接已被服务器标记为不可恢复（属于已持有连接失效场景），因此需要配置连接池定期校验连接健康度，避免从池内取出失效连接：

添加以下C3P0配置：

# 每隔25分钟测试空闲连接（小于Azure SQL默认30分钟连接超时）
hibernate.c3p0.idleConnectionTestPeriod=1500
# 从连接池取出连接时强制测试有效性
hibernate.c3p0.testConnectionOnCheckout=true
# 测试连接的SQL语句（Azure SQL兼容）
hibernate.c3p0.preferredTestQuery=SELECT 1
# 获取新连接时无限重试（设为-1表示无上限）
hibernate.c3p0.acquireRetryAttempts=-1
# 重试间隔保持3秒
hibernate.c3p0.acquireRetryDelay=3000
# 禁止获取连接失败后终止连接池
hibernate.c3p0.breakAfterAcquireFailure=false

二、业务层实现连接失效重试逻辑 #

当Hibernate会话绑定的连接失效后，该会话无法复用，必须关闭重建。针对批处理任务，需捕获特定连接异常并重试当前操作：

自定义重试工具类示例 #

import com.microsoft.sqlserver.jdbc.SQLServerException;
import org.hibernate.Session;
import org.hibernate.SessionFactory;

public class RetryableOperation {
    private static final long RETRY_DELAY = 3000;

    public static <T> T execute(SessionFactory sessionFactory, RetryableTask<T> task) {
        while (true) {
            Session session = null;
            try {
                session = sessionFactory.openSession();
                session.beginTransaction();
                T result = task.run(session);
                session.getTransaction().commit();
                return result;
            } catch (Exception e) {
                // 仅针对连接不可恢复的特定异常重试
                if (e.getCause() instanceof SQLServerException) {
                    SQLServerException sqlEx = (SQLServerException) e.getCause();
                    if (sqlEx.getMessage().contains("The connection is broken and recovery is not possible")) {
                        if (session != null && session.getTransaction().isActive()) {
                            session.getTransaction().rollback();
                        }
                        Thread.sleep(RETRY_DELAY);
                        continue;
                    }
                }
                // 非连接异常直接抛出
                if (session != null && session.getTransaction().isActive()) {
                    session.getTransaction().rollback();
                }
                throw new RuntimeException("Operation failed", e);
            } finally {
                if (session != null && session.isOpen()) {
                    session.close();
                }
            }
        }
    }

    @FunctionalInterface
    public interface RetryableTask<T> {
        T run(Session session) throws Exception;
    }
}

批处理中调用重试逻辑 #

// 在批处理步骤中使用
RetryableOperation.execute(sessionFactory, session -> {
    LCatalogCategoriesTreeDAO dao = new LCatalogCategoriesTreeDAO(session);
    return dao.findByParentCategoryId(parentId);
});

三、优化Azure SQL JDBC连接配置 #

在JDBC URL中添加以下属性增强稳定性：

jdbc:sqlserver://<your-server>.database.windows.net:1433;databaseName=<your-db>;encrypt=true;trustServerCertificate=false;loginTimeout=30;socketTimeout=300000;sendStringParametersAsUnicode=false

• socketTimeout=300000：设置套接字超时为5分钟，避免无限等待
• encrypt=true：符合Azure SQL强制加密要求
• sendStringParametersAsUnicode=false：减少不必要的Unicode转换，提升性能

四、拆分长事务（关键优化） #

若批处理用单个事务持有连接超过30分钟，Azure SQL会主动断开连接。建议将大任务拆分为多个小事务，每处理部分数据就提交并释放连接，缩短连接持有时间。

五、可选：升级依赖版本 #

你的Hibernate 4.1.4是2012年的旧版本，存在较多已知bug。推荐升级到Hibernate 5.6.x（兼容Java 8），同时同步升级c3p0版本：

<dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-core</artifactId>
    <version>5.6.15.Final</version>
</dependency>
<dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-c3p0</artifactId>
    <version>5.6.15.Final</version>
</dependency>
<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.5.5</version>
</dependency>

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