本文介绍如何在 Spring Boot 应用中实现启动即运行、周期性（如每 5 分钟）自动执行数据库查询与邮件通知的任务，重点使用 @Scheduled 注解替代原始 Timer/TimerTask 方案，确保任务受 Spring 容器管理、支持依赖注入与事务控制。
本文介绍如何在 spring boot 应用中实现启动即运行、周期性（如每 5 分钟）自动执行数据库查询与邮件通知的任务，重点使用 `@scheduled` 注解替代原始 `timer`/`timertask` 方案，确保任务受 spring 容器管理、支持依赖注入与事务控制。
在 Spring Boot 中实现定时任务，核心在于 启用调度支持 并 将任务方法声明为 Spring 托管的 Bean。你当前代码中使用 java.util.Timer 和手动实例化的 TimerTask 存在两个关键问题：一是 @Autowired 在非 Spring 管理对象（如 ScheduledTaskSevenDays）中无效，导致 adminService 为 null；二是 Timer 生命周期脱离应用上下文，无法感知应用启停，存在资源泄漏与不可靠调度风险。
✅ 正确做法是：启用 Spring 的声明式调度机制，通过 @EnableScheduling + @Scheduled 实现轻量、可靠、可维护的定时任务。
✅ 第一步：启用调度支持
在 Spring Boot 主启动类上添加 @EnableScheduling 注解：
@SpringBootApplication
@EnableScheduling // ← 关键：开启定时任务支持
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}⚠️ 注意：@EnableScheduling 必须作用于被 @SpringBootApplication 标注的主配置类，或任意 @Configuration 类，否则调度不会生效。
✅ 第二步：定义可调度的组件类
创建一个 @Component 类，并在其方法上使用 @Scheduled。该类由 Spring 管理，因此可安全注入 AdminService、EmailService 等 Bean：
@Component
public class NotificationScheduler {
private final AdminService adminService;
public NotificationScheduler(AdminService adminService) {
this.adminService = adminService;
}
/**
* 每 5 分钟执行一次七天预警邮件发送
* fixedDelay 表示上一次执行完成后，延迟 5 分钟再次执行（推荐用于耗时不确定的任务）
*/
@Scheduled(fixedDelay = 5, timeUnit = TimeUnit.MINUTES)
public void sendSevenDayNotifications() {
try {
boolean success = adminService.SevenDayNotification();
if (success) {
System.out.println("✅ 七天预警邮件任务执行成功");
} else {
System.err.println("⚠️ 七天预警邮件任务执行失败");
}
} catch (Exception e) {
System.err.println("❌ 七天预警任务异常：" + e.getMessage());
e.printStackTrace();
}
}
}? 补充说明调度策略：
- fixedDelay: 上次执行结束后再等待指定时间执行下一次（推荐，避免任务重叠）；
- fixedRate: 按固定频率执行（无论上次是否完成），可能并发执行，需谨慎；
- cron: 支持复杂表达式（如 "0 0 */5 * * ?" 表示每 5 小时整点执行），适合精确时间点调度。
✅ 第三步：确保服务层方法具备事务与异常健壮性（最佳实践）
建议优化 AdminService.SevenDayNotification() 方法，加入事务控制与日志结构化：
@Service
public class AdminService {
private final SurveyParticipationRepository surveyParticipationRepository;
private final EmailService emailService;
public AdminService(SurveyParticipationRepository surveyParticipationRepository,
EmailService emailService) {
this.surveyParticipationRepository = surveyParticipationRepository;
this.emailService = emailService;
}
@Transactional(readOnly = true) // 明确只读事务，提升性能
public boolean SevenDayNotification() {
try {
List<String> emails = surveyParticipationRepository.findAllParticipantEmailSevenDays();
System.out.printf("? 查询到 %d 位参与者待发送七天提醒\n", emails.size());
for (String email : emails) {
emailService.sendMessage(
email,
"Notice: Survey will end soon",
"This survey is set to end in 7 days, please be sure to complete and submit it before the due date."
);
}
return true;
} catch (Exception e) {
log.error("Failed to send 7-day notifications", e);
return false;
}
}
}⚠️ 重要注意事项
- 线程安全：@Scheduled 默认使用单线程 TaskScheduler，同一任务不会并发执行；如需并行，需自定义 ThreadPoolTaskScheduler。
- 应用生命周期绑定：任务随 Spring Context 启动而启动，随应用关闭而优雅终止（Timer 无法保证）。
- 测试友好：可通过 @MockBean 或 @TestConfiguration 轻松隔离测试定时逻辑。
-
生产增强建议：
- 使用 @Scheduled(cron = "0 0 */5 * * ?") 替代 fixedDelay 可更好对齐系统时钟；
- 集成 Actuator（spring-boot-starter-actuator）暴露 /actuator/scheduledtasks 端点，实时查看所有调度任务状态；
- 对邮件发送等外部调用添加重试机制（如 @Retryable）和降级处理。
通过以上改造，你的定时邮件任务将真正融入 Spring Boot 生态——启动即就绪、依赖可注入、异常可捕获、运维可观测。告别裸 Timer，拥抱声明式、容器化、生产就绪的调度方案。
