Spring Boot+Hibernate中数据库状态监听器实现问题咨询

首先，你给出的DatabaseClosedListener implements ApplicationListener<ContextClosedEvent>没法直接实现需求——ContextClosedEvent是Spring容器关闭时触发的事件，和数据库自身的异常（比如ResultSet操作异常、数据库意外关闭）完全无关，没法捕捉到这类数据库状态变化。

要实现你的需求，有两种可行思路：结合Spring事件机制自定义数据库异常事件，或者用AOP拦截数据库操作捕获异常。下面是具体实现方案：

方案一：自定义数据库异常事件 + ApplicationListener #

这种方式通过Spring的事件发布/监听机制，在数据库操作出现异常时触发事件，再由监听器处理关闭定时任务的逻辑。

1. 定义自定义数据库异常事件 #

public class DatabaseFailureEvent extends ApplicationEvent {
    private final Exception cause;

    public DatabaseFailureEvent(Object source, Exception cause) {
        super(source);
        this.cause = cause;
    }

    public Exception getCause() {
        return cause;
    }
}

2. 在数据库操作中捕获异常并发布事件 #

在DAO层或者数据库操作工具类里，捕获ResultSet异常、数据库连接异常等，并发布自定义事件：

@Service
public class UserDao {
    @Autowired
    private ApplicationEventPublisher eventPublisher;
    @Autowired
    private JdbcTemplate jdbcTemplate;

    public List<User> queryUsers() {
        try {
            return jdbcTemplate.query("SELECT id, name FROM users", (rs, rowNum) -> {
                // 模拟数据库关闭导致的ResultSet异常
                if (rs.isClosed()) {
                    throw new SQLException("ResultSet closed because database was shutdown");
                }
                return new User(rs.getLong("id"), rs.getString("name"));
            });
        } catch (SQLException e) {
            // 发布数据库失败事件
            eventPublisher.publishEvent(new DatabaseFailureEvent(this, e));
            throw new RuntimeException("Database operation failed", e);
        }
    }
}

3. 编写监听器处理事件并关闭定时任务 #

实现ApplicationListener监听自定义的DatabaseFailureEvent，在事件回调里关闭定时任务：

@Component
public class DatabaseFailureListener implements ApplicationListener<DatabaseFailureEvent> {
    // 假设你的定时任务是通过自定义Bean管理的，比如有stop方法
    @Autowired
    private MyScheduledTask scheduledTask;

    // 如果是用ScheduledTaskRegistrar注册的定时任务，也可以注入它调用destroy方法
    // @Autowired
    // private ScheduledTaskRegistrar taskRegistrar;

    @Override
    public void onApplicationEvent(DatabaseFailureEvent event) {
        // 关闭定时任务
        scheduledTask.stop();
        // 如果是ScheduledTaskRegistrar的方式：taskRegistrar.destroy();
        System.err.println("Stopped scheduled task due to database failure: " + event.getCause().getMessage());
    }
}

方案二：用AOP拦截数据库操作捕获异常 #

如果不想用事件机制，也可以直接用AOP拦截所有数据库操作方法，捕获目标异常后直接关闭定时任务：

@Aspect
@Component
public class DatabaseOperationInterceptor {
    @Autowired
    private MyScheduledTask scheduledTask;

    // 拦截DAO层所有方法，根据你的包路径调整表达式
    @Around("execution(* com.yourproject.dao.*.*(..))")
    public Object interceptDatabaseCalls(ProceedingJoinPoint joinPoint) throws Throwable {
        try {
            return joinPoint.proceed();
        } catch (SQLException e) {
            // 判断是否是数据库关闭相关的异常（可根据SQL状态码或异常信息判断）
            if ("08006".equals(e.getSQLState()) || e.getMessage().contains("closed")) {
                scheduledTask.stop();
                System.err.println("Scheduled task stopped because database connection failed");
            }
            throw e;
        }
    }
}

总结 #

ApplicationListener是可行的，但不能监听ContextClosedEvent，而是要监听你自定义的数据库异常事件；或者用AOP直接拦截处理，两种方式都能实现“数据库异常时关闭定时任务”的需求。

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