如何捕获Spring Boot Data JPA数据库连接拒绝异常并返回503状态码

你在服务层捕获不到数据库连接异常，核心原因是Spring Data/JPA的声明式事务由AOP代理托管：如果业务方法加了@Transactional注解，调用Repository方法时不会立刻触发事务提交，底层数据库连接异常不会在userRepository.incrementReputationByOne(userUid)这一行抛出，而是会在整个业务方法执行完成、Spring代理执行事务commit操作时才抛出。你写在方法内部的try-catch块覆盖不到代理层的异常抛出点，自然无法捕获异常。

不要在单个业务方法内零散编写try-catch逻辑，直接通过Spring全局异常处理器统一识别数据库连接类异常，返回指定状态码即可，实现逻辑如下：

• 首先明确异常识别规则：Spring会将所有底层数据库异常统一转换为DataAccessException子类，其中属于可重试连接故障的场景包括无法获取JDBC连接、数据库通信链路中断、连接超时、数据库连接池耗尽等，注意不要把SQL语法错误、数据约束冲突这类不可重试的异常误判为连接故障。
• 编写全局异常拦截器，示例代码：

import org.springframework.dao.DataAccessException;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.jdbc.CannotGetJdbcConnectionException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import java.net.ConnectException;
import java.sql.SQLException;
import java.sql.SQLTransientConnectionException;

@RestControllerAdvice
public class GlobalExceptionHandler {

    @ExceptionHandler({
            CannotGetJdbcConnectionException.class,
            SQLTransientConnectionException.class,
            DataAccessException.class,
            SQLException.class
    })
    public ResponseEntity<Void> handleDbFault(Exception e) {
        Throwable rootCause = getRootCause(e);
        if (isConnectionRecoverableError(rootCause)) {
            // 可根据需要添加故障日志
            return ResponseEntity.status(HttpStatus.SERVICE_UNAVAILABLE).build();
        }
        // 非连接类数据库异常返回500，不触发上游重试
        return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
    }

    @ExceptionHandler(Exception.class)
    public ResponseEntity<Void> handleOtherException(Exception e) {
        return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
    }

    private Throwable getRootCause(Throwable throwable) {
        Throwable cause = throwable.getCause();
        if (cause == null) {
            return throwable;
        }
        return getRootCause(cause);
    }

    private boolean isConnectionRecoverableError(Throwable rootCause) {
        if (rootCause instanceof ConnectException || rootCause instanceof SQLTransientConnectionException) {
            return true;
        }
        String errMsg = rootCause.getMessage() == null ? "" : rootCause.getMessage().toLowerCase();
        return errMsg.contains("communications link failure")
                || errMsg.contains("connection refused")
                || errMsg.contains("connection timed out")
                || errMsg.contains("too many connections")
                || errMsg.contains("connection reset");
    }
}

如果你确实需要在单个业务方法内部处理异常，不要依赖声明式事务自动提交，改用TransactionTemplate编程式控制事务边界，让异常在try块覆盖范围内抛出即可，示例代码：

import org.springframework.stereotype.Service;
import org.springframework.transaction.support.TransactionTemplate;

@Service
public class UserService {

    private final UserRepository userRepository;
    private final TransactionTemplate transactionTemplate;

    // 构造器注入
    public UserService(UserRepository userRepository, TransactionTemplate transactionTemplate) {
        this.userRepository = userRepository;
        this.transactionTemplate = transactionTemplate;
    }

    public void updateUserReputation(Long userUid) {
        try {
            transactionTemplate.execute(status -> {
                userRepository.incrementReputationByOne(userUid);
                return null;
            });
        } catch (DataAccessException e) {
            // 此处可正常捕获到所有数据库层抛出的异常，按业务逻辑处理即可
            throw new RuntimeException("数据库访问故障", e);
        }
    }
}

服务A侧收到503 Service Unavailable响应时，建议配置指数退避重试策略，不要无间隔高频重试，避免数据库恢复后被瞬间涌入的重试请求打垮。

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