当前位置:首页 > 文章列表 > 科技周边 > 人工智能 > AI 流式响应如何安全拼接工具参数:增量 JSON、半包与状态恢复

AI 流式响应如何安全拼接工具参数:增量 JSON、半包与状态恢复

来源:17golang原创 2026-08-28 14:15:02 0浏览 收藏

前端把模型的流式结果接到天气、库存或订单工具时,最容易踩到的坑不是接口没返回,而是工具参数被拆成了半截 JSON。比如第一段只有 {"city":,浏览器马上执行 JSON.parse,页面就会先报一次语法错误;后续片段到了,又可能因为重试把同一个工具调用两次。

可靠的做法是:按调用标识累积 response.function_call_arguments.deltabuffer,收到完整结束事件后再做一次 JSON.parse 和字段校验;未完成的流只恢复状态,不执行工具。

要点速览

  • 增量片段只能追加到同一个 buffer,不能逐片段解析。
  • response.function_call_arguments.done 是进入解析和校验阶段的信号。
  • 工具执行前要同时检查 call_id、参数结构和 complete 状态。
  • 断流恢复优先恢复缓冲区和阶段,超过幂等边界才允许重试。

为什么第一段参数不能直接交给 JSON.parse

流式传输把一个完整值切成多次事件,切分点可能落在字符串、数组或嵌套对象中间。{"city":"上海","days":3} 被拆成三段时,前两段都不是完整 JSON。解析失败只能说明“当前片段不完整”,并不等于模型给出了坏参数。

客户端应先绑定模型返回的调用标识,再按事件顺序追加文本。下面的适配器只关心四个稳定概念:增量字段、结束字段、调用名称和调用参数;不同 SDK 的事件对象可以在入口处转换成这组字段。

最小配方:delta 进 buffer,done 之后再解析

用一个 Map 保存不同 call_id 的片段,避免多个工具调用交错时互相污染。示例中的 tool_call 只是业务内部对象,真正的工具仍由应用自己的白名单路由决定。

const calls = new Map();

function onEvent(event) {
  const call = calls.get(event.call_id) ?? { buffer: '', complete: false };

  if (event.type === 'response.function_call_arguments.delta') {
    call.buffer += event.delta;
    calls.set(event.call_id, call);
    return { phase: 'receiving', call_id: event.call_id };
  }

  if (event.type === 'response.function_call_arguments.done') {
    call.buffer = event.arguments || call.buffer;
    call.complete = true;
    const args = JSON.parse(call.buffer);
    validateToolArgs(event.name, args);
    const tool_call = { call_id: event.call_id, name: event.name, args };
    calls.set(event.call_id, call);
    return { phase: 'ready', tool_call };
  }
}

关键点有两个:delta 只改变 buffer,而 done 才把状态推进到 complete。如果结束事件已经携带最终 arguments,以它为准可以避免客户端因丢失一段增量而继续使用残缺缓冲区。

response.function_call_arguments.delta 进入 buffer,完成后由 JSON.parse 生成 tool_call 的调用链示意图

把解析错误分成半包和坏包

不要把所有 SyntaxError 都当成重试信号。若事件还没结束,解析应根本没有发生;在 done 之后解析失败,才说明最终参数可能损坏、被截断,或服务端给了不符合约定的内容。生产代码可以把错误分为三类:

  • receiving:仍在接收,继续追加,不解析。
  • complete + parse_failed:流已结束但 JSON 损坏,记录原始调用并停止执行。
  • ready:解析和字段校验都通过,才进入工具白名单。

半包恢复:保存状态,而不是重复调用模型

网络断开后,最危险的恢复方式是从头请求一次,然后把新旧两条流都交给工具执行。更稳妥的状态至少要包含 call_idbufferdepthcompletestate。这里的 depth 是本地扫描大括号和方括号的嵌套深度,只能作为“看起来接近完整”的提示,不能替代 JSON 解析。

function recover(saved) {
  if (saved.complete === true && saved.state === 'ready') {
    return { action: 'execute-once', call_id: saved.call_id };
  }
  if (saved.state === 'receiving' && saved.retry_count 

恢复逻辑只负责决定下一步,不直接执行工具。恢复后再次收到片段,要按 call_id 去重;若供应商无法续接原流,就把旧调用标记为未完成,再发起新一轮模型请求,并给新请求一个独立的幂等键。

半包状态从 receiving 经过 depth 检查到 complete 或 retry 的状态转换示意图

工具执行前的三道门

参数拼成合法 JSON 还不够。应用应先确认工具名称来自白名单,再校验字段类型、范围和业务权限。比如库存查询可以要求 sku 是非空字符串、warehouse 属于允许的仓库编码;不能因为 JSON 结构正确就把任意字段传给后端。

  1. 调用门:call_id 未执行过,且 name 属于工具白名单。
  2. 结构门:JSON.parse 成功,字段校验通过,没有未知高风险参数。
  3. 状态门:complete 为真,当前 stateready,执行记录已落盘。

三道门中任意一道失败,都返回可观测的业务状态,不把原始参数回显到用户界面。特别是第二次收到相同结束事件时,应记录为重复事件并复用第一次结果,而不是再次访问外部系统。

浏览器端的兼容与可观测性

浏览器只适合做流的展示和轻量编排,真正涉及密钥、库存写入或订单变更的工具应放在服务端。前端可以展示 receiving、ready、retry 等状态,但不要把未完成的 buffer 当成可执行参数。

日志至少记录 call_id、事件序号、累计字节数、最终状态和失败原因,脱敏后再送入监控。不要记录访问令牌,也不要把完整参数写进 URL。针对断流、乱序、重复 done 和字段缺失分别做测试,才能证明恢复分支没有偷偷触发第二次调用。

相关问题

为什么不能每收到一段就尝试解析

因为切分点不保证落在 JSON 边界上;反复解析会制造大量正常的半包错误,还可能让错误处理误触发重试。

收到 done 但 arguments 为空怎么办

先检查本地 buffer 是否完整,再按同一 call_id 做一次解析和校验;两者都为空就停止执行并保留证据。

断流恢复后如何避免重复工具调用

call_id 和执行结果做幂等记录,恢复时先查执行状态;只有未执行且参数完成的调用才进入工具路由。

把流式参数处理收束成一个可验收结果

验收时不要只看页面最终显示了“完成”。应能从日志还原一条链:delta 按序进入 buffer,done 把状态标成 complete,JSON.parse 和字段校验得到 ready,工具凭 call_id 只执行一次。只要这条链在断流和重复事件下仍成立,流式工具调用才算真正可控。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go slog.Handler.WithAttrs 如何减少结构化日志开销:属性继承、并发安全与分组边界Go slog.Handler.WithAttrs 如何减少结构化日志开销:属性继承、并发安全与分组边界
上一篇
Go slog.Handler.WithAttrs 如何减少结构化日志开销:属性继承、并发安全与分组边界
Go regexp.QuoteMeta 怎么保护用户输入:正则字面量、拼接边界与匹配验证
下一篇
Go regexp.QuoteMeta 怎么保护用户输入:正则字面量、拼接边界与匹配验证
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • ljg-skills -
    ljg-skills
    ljg-skills 是李继刚开源的 AI 技能与提示词集合,面向大模型使用者整理了一批可复用的 prompt、角色设定和任务技能模板,适合用于学习提示词设计、搭建个人 AI 工作流和沉淀团队常用智能体能力。
    5372次使用
  • MELO音乐 - AI 音乐生成平台,支持多模态创作能力
    MELO音乐
    MELO音乐是一站式AI视频与音乐制作助手,对标suno, udio的高品质体验。提供伴奏生成、原创写词、无损导出、哼唱识曲、混音变声等全套音频与短视频编辑工具。无论是流行Kpop、电音说唱、民谣古风、摇滚儿歌还是商用轻音乐,MELO为你免费谱曲,轻松做同款!
    4885次使用
  • UniScribe - AI 免费在线音视频转文字平台
    UniScribe
    UniScribe 是一款 AI 音视频转文字与内容整理工具,支持上传音频、视频文件或粘贴 YouTube 链接,自动生成转写文本、摘要、思维导图和关键问题,并支持多格式导出,适合会议记录、课程学习、访谈整理和内容创作复盘。
    4827次使用
  • 剧云 - 免费 AI 智能中文剧本创作平台
    剧云
    剧云是专业中文剧本创作平台,安全稳定运行十余年,集成AI编剧、剧本医生审核、人物小传、剧情关系图、大纲编写、多人协作、Word导入导出、版权管控功能,数据安全防护,轻松高效创作剧本。
    5078次使用
  • 万象有声 - AI 一站式有声内容创作平台
    万象有声
    万象有声,一个专为有声创作者打造的新一代智能有声内容创作平台。平台提供专业的智能拆章、智能画本编辑、AI配音、AI生成音效、后期制作、智能对轨、智能审听等有声创作全流程工具,可以帮助创作者高效、低成本创作出引人入胜的有声作品。立即体验,让有声书制作更简单!
    5037次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码