流式会话中断后本地状态回滚与一致性保障

在大模型应用日常交互中用户点击“停止生成Stop Generating”或者因网络信号抖动如进出电梯、Wi-Fi 切换 5G导致 SSEServer-Sent Events长连接异常中断是一种极其常态化的物理场景。很多初级产品在处理中断时往往手忙脚乱暴露出严重的状态脏写Dirty State与数据不一致问题未闭合结构导致页面白屏大模型刚好吐出了一半的 Markdown 代码块typescript \n const a 或未闭合的 JSON前端直接中止接收Markdown 解析器在下一次状态渲染时解析失败本地对话历史与服务端不同步前端本地把这半句残缺不全的内容保存进了 IndexedDB下一次用户发起追问时带着这个半截残篇作为上下文发给后端大模型直接理解错乱产生幻觉按钮状态死锁“停止生成”点击后输入框依然处于disabled禁用状态用户不得不手动 F5 刷新整个页面。构建一套具备**“主动与异常中断状态机捕获”、“未决数据结构就地安全缝合”与“增量版本对齐”**的高可用容灾体系是 AI 产品工程的底层安全气囊。流式中断状态机与物理生命周期stateDiagram-v2 [*] -- Generating: 正在流式接收 Chunk 数据 Generating -- UserAbort: 用户主动点击 停止生成 (AbortController.abort()) Generating -- NetworkError: 网络异常断联 (SSE onError / Timeout) UserAbort -- RepairSanitize: 进入中止缝合拦截器 NetworkError -- RepairSanitize: 进入异常处理拦截器 RepairSanitize -- RollbackOrCommit{判定截断内容有效性} RollbackOrCommit --|有效内容不足 5 个字符| Rollback: 彻底回滚丢弃该轮残片 RollbackOrCommit --|包含有效实质回答| AutoSeal: 自动补齐闭合标记并标记 [生成已中止] AutoSeal -- SyncDB: 写入本地快照并通知服务端同步 Context Rollback -- ResetUI: 恢复输入框焦点与可用状态 SyncDB -- ResetUI生产级流式中断安全缝合管理器实战export class StreamInterruptionManager { private abortController: AbortController | null null; private isInterrupted false; createAbortSignal(): AbortSignal { this.abortController new AbortController(); this.isInterrupted false; return this.abortController.signal; } // 1. 用户主动触发中止 triggerUserAbort() { if (this.abortController) { this.isInterrupted true; this.abortController.abort(USER_ABORT); console.log( 用户主动打断了大模型流式生成); } } // 2. 状态缝合与自愈处理 sanitizeInterruptedContent(rawPartialText: string): { finalContent: string; shouldKeep: boolean; } { const trimmed rawPartialText.trim(); // 若有效内容过短如仅吐出 正在为您... 几个字彻底丢弃回滚 if (trimmed.length 8) { return { finalContent: , shouldKeep: false }; } let sealedText trimmed; // 自动补齐未闭合的 Markdown 代码块 const codeBlockCount (sealedText.match(//g) || []).length; if (codeBlockCount % 2 ! 0) { sealedText \n\n; } // 自动补齐未闭合的 LaTeX 块级数学公式 const mathBlockCount (sealedText.match(/\$\$/g) || []).length; if (mathBlockCount % 2 ! 0) { sealedText \n$$\n; } // 注入优雅的中止提示标签 sealedText \n\n*(已由用户手动停止生成)*; return { finalContent: sealedText, shouldKeep: true }; } }本地持久化与服务端 Context 契约同步在中断发生后必须完成前后端上下文的严格对齐前端 IndexedDB 更新将缝合好的安全文本写回本地会话存储异步通知后端剪枝通过POST /api/chat/sync-abort将最终保留的truncatedLength或messageId同步给后端对话状态机确保在下一轮对话时大模型接收到的历史上下文与用户屏幕上看到的文字完全一致严防死守流式中断的每一个边界缝隙才能让生成式界面在任何突发网络故障与用户打断下始终保持严密自洽。