用途:该技能面向使用 Server-Sent Events(SSE)推送的服务端场景,解决流静默失败、完成事件丢失、流健康度不可见以及废弃流导致资源泄漏等问题。
主要能力:提供流注册表(在 Redis 中跟踪所有活跃流)、心跳监控(识别孤儿流)、完成存储(持久化终态事件以便恢复)、流守护进程(后台清理)。核心常量包括 STREAM_TTL=3600、STALE_THRESHOLD=30、COMPLETION_TTL=300。
使用方式:在 TypeScript 中实现 StreamRegistry、CompletionStore、StreamGuardian 三类组件;SSE 端点先查询已有完成记录以支持恢复,再注册新流,并每 15 秒发送心跳;客户端通过恢复接口检查完成状态,失败时以指数退避重连,最多 3 次。
适用场景:需要可靠推送生成结果、任务进度或长连接事件的服务。
限制:资料未提供具体安装命令、依赖版本、收费与平台信息;示例代码为 TypeScript,需自行接入 Redis 与框架。