周昌凡

@TaskExecutor 注解(兼 @Component 注册 Spring Bean)声明式注册,impl 类上注解 = 录入注册表,新增任务只需建类加注解。启动时 ApplicationListener<ContextRefreshedEvent> 扫描 @TaskExecutor → 构建 TaskRegistry(ConcurrentHashMap)类型安全路由,无中央枚举。调度骨架 BaseTask 以 Redis ZSET 承载三类集合:task:due(待执行,score=执行时间戳)、task:processing(执行中,score=抢占时间戳)、task:dead(死信)。唯一 @Scheduled 每秒获取到期任务,通过 CLAIM Lua 脚本一步完成 ZREM due+ZADD processing,原子抢占执行权——多节点并发仅一个返回 1 抢到,其余跳过,天然保证集群恰好执行一次。任务在异步线程执行,结束(成功/失败)即从 processing 移除;失败按次数退避重试(min(retryCount×60s,30min))。看门狗每 1min 扫描 processing 中 score 超 10min 的残留任务(节点崩溃未清理),原子回收后重新入队或转死信(超 MAX_RETRY=5)。init 阶段用单 leader 锁(task:init-lock,NODE_ID 防互删)仅 leader 执行 reseed,期间按 (type,key) 去重,避免滚动发布后重复 enqueue。三种调度模型:循环(execute 返回新时间重新入队)、延迟(返回 null 一次消费)、恢复(init 加载 DB 未完成任务计算剩余时间 addTask)。异常残留 key 形成隐式重试。