Spring Boot数据库连接重试配置失效，请求修复方案

问题原因分析 #

Spring Retry的重试触发逻辑是捕获到异常时才会执行重试，你当前代码中在连接失败时返回null，RetryTemplate会认为这是执行成功的结果，因此不会触发重试流程。

修复方案 #

修改CustomDataSourceConfiguration中的重试逻辑，将连接失败时的return null改为抛出异常，让RetryTemplate识别到失败并触发重试。同时可以添加日志记录重试过程，便于排查问题。

修改后的CustomDataSourceConfiguration代码

package backend.configuration.dbconnection;

import lombok.extern.java.Log;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.retry.support.RetryTemplate;

import javax.sql.DataSource;
import java.sql.SQLException;

@Log
@Configuration
@EnableRetry
public class CustomDataSourceConfiguration {
    @Autowired
    private RetryTemplate retryTemplate;

    @Bean
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3307/db");
        dataSource.setUsername("user");
        dataSource.setPassword("password");

        return retryTemplate.execute(context -> {
            try {
                log.info("尝试数据库连接，第" + (context.getRetryCount() + 1) + "次");
                // 获取连接后立即关闭，避免资源泄漏
                dataSource.getConnection().close();
                log.info("数据库连接成功");
                return dataSource;
            } catch (SQLException e) {
                log.warning("第" + (context.getRetryCount() + 1) + "次连接失败：" + e.getMessage());
                // 抛出异常触发重试
                throw e;
            }
        });
    }
}

可选优化：精准控制重试异常类型

如果需要只针对数据库连接相关异常重试，可以修改RetryConfiguration，配置特定异常的重试策略：

package backend.configuration.dbconnection;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.retry.backoff.FixedBackOffPolicy;
import org.springframework.retry.policy.SimpleRetryPolicy;
import org.springframework.retry.support.RetryTemplate;

import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

@Configuration
@EnableRetry
public class RetryConfiguration {
    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate retryTemplate = new RetryTemplate();

        // 仅针对SQLException触发重试
        Map<Class<? extends Throwable>, Boolean> retryableExceptions = new HashMap<>();
        retryableExceptions.put(SQLException.class, true);
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(5, retryableExceptions);
        retryTemplate.setRetryPolicy(retryPolicy);

        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(1000); // 重试间隔1秒
        retryTemplate.setBackOffPolicy(backOffPolicy);

        return retryTemplate;
    }
}

核心要点总结 #

• Spring Retry依赖异常抛出识别执行失败，返回null无法触发重试
• 必须在连接失败时抛出异常，确保RetryTemplate捕获到失败信号
• 获取连接后及时关闭，避免数据库连接资源泄漏
• 可通过配置异常映射，实现精准的重试范围控制

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