Spring Boot 2 应用中持续扫描数据库并处理数据的优雅方案
本文介绍如何在 Spring Boot 2 应用中构建一个持续运行的机制，用于扫描数据库并处理符合特定条件的数据。这对于那些需要定时处理、高容错率的场景至关重要，例如文中提到的商户余额日结和退款处理，确保所有交易都被准确无误地处理。
文章首先比较了两种常见的实现方式：使用 @RestController 结合 for 或 while(true) 循环，以及 @Scheduled 注解。前者虽然简单，但容易造成资源浪费且缺乏优雅的停止机制；后者虽然定时可靠，但灵活性不足，开发者难以完全掌控任务。
相比之下，利用 Spring 的生命周期注解 @PostConstruct 和 @PreDestroy 提供了更有效的后台任务管理方案。@PostConstruct 确保任务在 Spring Boot 应用启动后立即开始运行，@PreDestroy 则保证在应用关闭前优雅地停止任务。这种方式将任务的生命周期与 Spring Boot 容器的生命周期绑定，增强了可靠性和易管理性。
以下是一个使用 @PostConstruct 和 @PreDestroy 实现持续运行任务的示例：
public class DatabaseMonitor implements Runnable {
private Thread thread;
private volatile boolean running = true; // 使用 volatile 保证线程可见性
@PostConstruct
public void start() {
thread = new Thread(this);
thread.start();
}
@PreDestroy
public void stop() {
running = false;
try {
thread.join();
} catch (InterruptedException e) {
log.error("Thread join interrupted", e);
}
}
@Override
public void run() {
while (running) {
// TODO: 在此处添加数据库扫描和业务处理逻辑
// 例如：使用JdbcTemplate查询数据库，处理符合条件的数据
// ...数据库查询操作...
// ...业务处理逻辑...
try {
Thread.sleep(5000); // 每5秒钟检查一次
} catch (InterruptedException e) {
log.error("Thread sleep interrupted", e);
Thread.currentThread().interrupt(); // 恢复中断状态
} catch (Exception e) {
log.error("An error occurred during processing", e);
}
}
}
}
在这个示例中，run() 方法包含持续运行的逻辑，running 变量控制循环状态。@PostConstruct 在应用启动时创建并启动线程，@PreDestroy 在应用关闭时设置 running 为 false 并等待线程结束，确保资源正确释放。 Thread.sleep() 的时间间隔以及具体的数据库扫描和业务处理逻辑都可根据实际需求调整。 这提供了一种更灵活、更可控的持续运行任务管理方式，避免了 @Scheduled 的黑盒操作和灵活性不足的问题。 此外，使用 volatile 关键字保证了 running 变量的线程可见性，提高了代码的健壮性。 异常处理也得到了加强，避免了单一异常导致任务崩溃。
