基于 Redis 的分布式倒计时发令枪。

基于 Redis 的分布式倒计时发令枪。

如果你做过微服务架构，或者接触过事件驱动架构（EDA），你一定会遇到这样一个极其让人头疼的场景：一个主任务被拆分成了多个并行的子任务，你需要等所有子任务都执行完毕后，才能触发最终的收尾动作。

在单体架构里，我们用 Java 自带的CountDownLatch或者CompletableFuture.allOf()就能轻松搞定。但在分布式系统、跨多个独立消费者的场景下，JVM 级别的锁彻底失效了。

今天，我们就来聊聊大厂处理这种“Scatter-Gather（分散-聚集）”时序错乱问题的标准解法：基于 Redis 的分布式倒计时发令枪。

🎯 一、 经典灾难场景：谁来负责“收网”？

假设我们正在开发一个视频流媒体后台，用户上传视频后，系统会通过 Kafka 并发派发三个独立任务：

1. 封面提取（极快，约 2 秒）
2. AI 字幕识别（较慢，约 2 分钟）
3. 视频 HLS 转码切片（最慢，约 5 分钟）

最终诉求：当这三个任务全部成功写入 MySQL后，触发 Elasticsearch（ES）的数据同步，让用户能在前端搜到这个完美的视频。

痛点来了：由于三个任务在不同的服务器、不同的进程中并行执行，谁快谁慢完全无法预测（遇到网络波动，原本 2 秒的封面提取可能重试耗时 6 分钟）。 如果转码最先跑完，它立刻发通知让 ES 去同步，结果 ES 查库时发现封面和字幕都是空的——脏数据就这么产生了。