Spring Batch对接Azure SQL偶发SQLState:08S01连接异常及重试方案咨询

故障根因 #

该偶发08S01错误是典型的JDBC连接失效问题，触发原因包括：Azure SQL云端主动回收空闲超过阈值的连接、网络临时抖动、连接池拿到了已经被销毁的无效连接。

修复方案 #

1. 优化HikariCP连接池配置（优先解决，从根源减少无效连接问题） #

你的现有配置缺少连接有效性校验和生命周期控制，需要补充以下参数：

<bean id="hikariConfig" class="com.zaxxer.hikari.HikariConfig">
    <property name="maximumPoolSize" value="50" />
    <property name="idleTimeout" value="30000" />
    <!-- 新增配置开始 -->
    <!-- 连接最大生命周期，设置为29分钟，比Azure SQL默认30分钟的空闲回收阈值短，避免拿到云端已回收的连接 -->
    <property name="maxLifetime" value="1740000" />
    <!-- 连接有效性检测语句，每次从连接池取连接时先校验连通性 -->
    <property name="connectionTestQuery" value="SELECT 1" />
    <!-- 连接校验超时时间3秒 -->
    <property name="validationTimeout" value="3000" />
    <!-- 可选：连接泄露检测阈值，超过2秒未释放连接打印告警，排查泄漏问题 -->
    <property name="leakDetectionThreshold" value="2000" />
    <!-- 新增配置结束 -->
    <property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />
    <!-- JDBC连接串补充socketTimeout参数，避免长时间挂死在无响应连接上 -->
    <property name="url" value="jdbc:sqlserver://demo.database.windows.net:1433;database=sqldb;encrypt=true;trustServerCertificate=false;hostNameInCertificate=*.database.windows.net;loginTimeout=30;socketTimeout=60000;" />
    <property name="username" value="user1" />
    <property name="password" value="p@ssword1" />
</bean>

2. 修复现有Writer的错误逻辑 #

现有Writer存在2个严重问题：

• 吞掉异常只打印不抛出：Spring Batch的事务、重试逻辑依赖异常向上传播，吞异常会导致事务状态不一致，数据丢失
• 反复调用afterPropertiesSet()：该方法是Spring Bean初始化阶段自动调用的，业务执行阶段无需重复调用

修正后的代码如下：

public class StudentStgWriter implements ItemWriter<List<Student>> {
    private HibernateItemWriter<Student> hibernateItemWriter;

    public StudentStgWriter(HibernateItemWriter<Student> hibernateItemWriter) {
        this.hibernateItemWriter = hibernateItemWriter;
        System.out.println("Hibernate Writer instance is created..: " + hibernateItemWriter.hashCode());
    }

    @Override
    public void write(List<? extends List<Student>> items) throws Exception {
        for (List<Student> StudentStg : items) {
            hibernateItemWriter.write(StudentStg);
        }
        System.out.println(String.format("StudentStg Processing Completed %s", LocalDateTime.now()));
    }
}

3. 重试逻辑实现（不建议在Writer内手写重试） #

不要在Writer类里自己手写重试逻辑，Spring Batch自带成熟的重试机制，直接配置即可，避免自行处理事务、幂等性带来的额外问题。
修改Step的Chunk配置，增加重试规则：

<batch:chunk
        reader="StudentStgReader"
        processor="StudentStgProcessor"
        writer="StudentStgWriter"
        commit-interval="10"
        retry-limit="3">
    <!-- 配置仅对连接类瞬态异常重试 -->
    <batch:retryable-exception-classes>
        <batch:include class="org.hibernate.exception.JDBCConnectionException"/>
        <batch:include class="java.sql.SQLTransientConnectionException"/>
    </batch:retryable-exception-classes>
    <!-- 可选配置：非重试类异常直接跳过，避免整批失败
    <batch:skippable-exception-classes>
        <batch:include class="java.lang.Exception"/>
        <batch:exclude class="java.lang.IllegalArgumentException"/>
    </batch:skippable-exception-classes>
    <batch:skip-limit="100"/>
    -->
</batch:chunk>

注意：请确保你的读、处理、写逻辑都是幂等的，避免重试时出现重复写入数据的问题。

4. 可选优化 #

如果问题仍偶发，可以排查：

• Azure SQL的服务层级是否满足并发要求，有没有出现CPU、IO限流的情况
• 确认服务器到Azure SQL的网络链路质量，是否存在周期性丢包

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