diff --git a/docs/superpowers/specs/2026-07-17-mqtt-pending-cleanup-retry-design.md b/docs/superpowers/specs/2026-07-17-mqtt-pending-cleanup-retry-design.md new file mode 100644 index 0000000..43572e9 --- /dev/null +++ b/docs/superpowers/specs/2026-07-17-mqtt-pending-cleanup-retry-design.md @@ -0,0 +1,53 @@ +# MQTT 待确认命令启动清理与重试间隔设计 + +## 背景 + +MQTT 待 ACK 命令保存在 Redis 中,默认保留 24 小时。应用重启后,旧命令的 +`nextRetryAt` 通常已经早于当前时间,因此重试扫描任务启动后会立即重新下发旧命令。 + +当前服务按单实例部署处理。目标是启动时清除旧待确认命令,并将新命令等待 ACK 的 +时间从 30 秒调整为 10 秒。 + +## 行为约定 + +- 应用每次启动完成后清理全部 pending 命令。 +- 清理范围包括 pending ID 集合及集合中每个命令对应的缓存对象。 +- 不清理已经收到的 ACK 历史缓存。 +- 启动清理失败只记录完整异常,不阻止应用启动。 +- 新命令首次下发后等待 10 秒才具备重试条件。 +- 重试扫描周期保持 5 秒,因此实际重发时间约为下发后的 10 至 15 秒。 +- 最大重试次数保持 3 次,不包含首次发送。 + +## 设计 + +### 清理服务 + +在 `MqttCommandAckService` 增加公开的启动清理方法。方法读取 pending ID 集合,逐一 +删除 `mqtt:command:pending:{commandId}`,然后清空 pending ID 集合,并返回清理数量。 +清理操作应可重复执行,空集合返回 0。 + +### 启动时机 + +新增 MQTT 启动清理监听器,在 `ApplicationReadyEvent` 到达后执行一次。此时 Spring、 +Redis 和 MQTT 相关 Bean 已完成初始化。监听器捕获运行时异常并记录完整异常栈,避免 +Redis 短暂不可用导致整个应用启动失败。 + +### 重试配置 + +将 `mqtt.command-ack.retry-interval-ms` 设置为 `10000`。首次发送和每次重试后均继续使用 +该配置计算 `nextRetryAt`。`scan-interval-ms` 保持 `5000`。 + +## 测试 + +- 清理方法删除集合中每个 pending 缓存并清空集合。 +- 空 pending 集合清理成功且返回 0。 +- 启动监听器在应用就绪事件后调用一次清理方法。 +- 清理异常不会从监听器继续抛出。 +- 配置绑定后的重试间隔为 10000 毫秒。 +- 保留现有命令发送和三次重试测试。 + +## 非目标 + +- 不修改 ACK 消息格式、MQTT Topic 或命令 Payload。 +- 不清理 ACK 历史缓存。 +- 不设计多实例命令归属;若后续改为多实例部署,需要重新设计启动清理策略。