[058][调度模块]任务生命周期事件与监听器机制

摘要

在需要接入监控、审计，或与其他业务系统做状态联动的场景下，框架通过定义 ChangeStatusEvent 事件与 ChangeStatusEventConsumer 接口，提供了可订阅的任务状态变更扩展入口。

下面将围绕事件如何产生、如何被消费，以及如何基于这套机制继续扩展展开说明。

1. 事件定义

@Builderpublic record ChangeStatusEvent(Instant timestamp,String taskName,TaskStatusEnum taskStatus,TaskCondition lastTaskCondition,String message,Throwable throwable) { }

状态包括：CREATED、STARTED、COMPLETED、STOPPED、CANCELLED、EXCEPTION。

2. 事件触发点

在 ScheduleTaskManager 中，每个关键操作都会调用 notifyListeners()。

private void startEvent(String taskName) { notifyListeners(taskName, TaskStatusEnum.STARTED, null, null);}private void stopEvent(String taskName, String message) { doCancelTask(taskName);notifyListeners(taskName, TaskStatusEnum.STOPPED, message, null);}// 类似地，completeEvent, failureEvent, cancelEvent...

例如，任务启动时会触发 STARTED 事件；任务停止时会先执行取消逻辑，再通知监听器。

3. 消费者注册

ScheduleTaskManager 的构造函数会注入 ObjectProvider，并在初始化过程中收集所有实现该接口的 Bean。

public ScheduleTaskManager(TaskRepository taskRepository, List consumers) { this.taskRepository = taskRepository;this.consumers = consumers;}

消费者可以是任何 Spring Bean，例如：

@Component@Slf4jpublic class LoggingEventConsumer implements ChangeStatusEventConsumer { @Overridepublic void consumer(ChangeStatusEvent event) { log.info("任务 {} 状态变为 {}", event.taskName(), event.taskStatus());}}

4. 扩展点

• 持久化事件到数据库，用于历史追踪。

• 通过消息队列将事件转发到其他微服务。

• 结合监控系统（如 Prometheus）实时上报任务执行情况。

5. 设计优势

• 解耦：任务调度核心不关心事件被如何使用，只需广播。

• 多监听器：支持任意数量的消费者，且异常隔离（单个消费者异常不影响其他消费者）。

《夸克》非常好用的免费AI浏览器

下载APP查看