6大Agent协作模式 + 原生MCP集成 + User-in-the-Loop,从"对话"到"执行"只差一个流程

💡 不想看长篇文字? 文中所有功能均可在在线演示环境中亲身体验 → 电脑端打开地址立即体验:https://ai.qztechcloud.com/flow-builder

一、开篇:AI智能体走到今天,缺的不是"脑子",是"四肢"

过去两年,几乎所有企业都尝试过让AI"干活"。

从ChatGPT的惊艳亮相,到各类对话机器人的遍地开花,大家很快发现一个尴尬的现实:AI在对话框里无所不能,一碰到真实业务就寸步难行。

原因很简单——真实业务从来都不是"你问我答"。

一个完整的业务场景,往往需要经历数据获取 → 逻辑判断 → 模型推理 → 人工复核 → 系统写入等一系列长尾步骤。而传统的"一问一答"式AI,只能完成其中孤立的一环。

AI智能体要真正落地,必须拥有"流程思维"。

这也正是我们今天要介绍的核心模块——AI流程引擎的使命:它决定了智能体的"执行力",是连接"大脑"(模型)与"四肢"(业务系统)的关键骨架。

我们的AI流程引擎,从一开始就不是在做一张"高级流程图",而是在构建一个企业级的AI智能体编排与执行操作系统

下面,我们从技术架构开始,逐步拆解。

二、技术底座:为什么我们选择LangGraph + Spring AI + ReactFlow

在决定技术选型之前,我们反复问自己一个问题:市面上已经有那么多工作流引擎,为什么还要再造一个?

答案是——传统工作流引擎(如Activiti、Camunda)是为"确定性流程"设计的,每一步做什么、谁来做、做完去哪,都是人在设计阶段就定死的。但AI流程是"不确定性流程"——模型输出的结果不确定,下一步走哪个分支不确定,甚至需要让AI自己决定调用哪个工具。

这套逻辑,传统引擎无法支撑。

所以我们从底层重新设计,确定了三层的技术架构:

2.1 调度层:LangGraph —— 让AI流程"有状态、可回溯"

LangGraph是LangChain生态中专门用于构建有状态、多角色AI应用的工作流框架。

在我们的架构中,LangGraph承担了最核心的流程调度职责:

  • 状态管理:每个流程实例都有一个全局状态(State),所有节点共享读写,天然支持"上下文记忆"

  • 节点路由:根据LLM的推理结果或条件表达式,动态决定下一个执行节点

  • 多Agent协作:监督者模式、编排器模式、并行分发等复杂协作模式,都是基于LangGraph的"条件边"和"并行边"实现的

一句话总结:LangGraph让我们的流程引擎具备了"智能路由"能力,而非死板"预制路径"。

图片

2.2 处理层:Spring AI —— 统一模型接入与处理框架

Spring AI提供了统一的AI模型接入抽象层,我们的所有AI类节点(LLM调用、意图识别、文生图、TTS等)都构建在Spring AI之上。

其核心价值在于:

  • 模型无关性:同样一个LLM节点,可以在配置中无缝切换GPT-4、Claude、通义千问或本地模型,无需修改流程定义

  • 流式响应:配合 SSE(Server-Sent Events)+ Flux 技术,实现AI响应的实时流式推送,用户端能"逐字看到"AI的思考过程,而非等待完整响应

2.3 前端层:React + ReactFlow —— 可视化编排 + 运行时观测

前端采用React + ReactFlow技术栈,实现了真正的可视化流程编排

  • 拖拽即构建:从左侧节点库拖拽任意类型的处理器到画布,连线即建立执行依赖

  • 所见即所得:每个节点可独立配置输入/输出Schema、模型参数、提示词、MCP服务等

  • 导入/导出:流程定义支持JSON格式的导入导出,便于版本管理和跨环境迁移

  • 实时测试:在画布上直接点击"运行",填入测试数据,即可看到流程的完整执行轨迹

  • 运行数据可观测:每个节点的输入、输出、耗时、状态都可追溯,真正做到"白盒"运行

图片

三、节点能力全景:一套完整的"智能体功能组件库"

我们的AI流程引擎目前内置了 17大类、60+个 处理器节点,覆盖从数据输入到AI处理、从流程控制到人机交互的全链路。

3.1 输入类节点 —— 让流程"听得见、看得懂"

| 节点类型

|

功能说明

意图识别

基于规则+LLM+向量三重引擎的混合意图识别,支持多意图输出、置信度分级

| | 关键词过滤 |

基于预设关键词的敏感词/内容过滤

| | 向量查询 |

执行向量相似性搜索,适用于RAG语义检索场景

| | 网络搜索 |

基于MCP协议实现联网搜索,支持缓存和表格/JSON等多种输出格式

| | HTTP请求 |

通用的RESTful API调用,支持各种请求方法和鉴权

|

3.2 AI处理类节点 —— 让流程"会思考、能创造"

| 节点类型

|

功能说明

AI大模型(LLM)

核心LLM调用节点,支持流式/异步、多模型切换、提示词模板

| | MCP Server |

原生MCP协议服务调用,让流程直接对接遵循MCP标准的工具和数据源

| | AI图片生成 |

文生图,支持多种风格、尺寸和水印配置

| | AI视频生成 |

文生视频/图生视频,支持Sora等主流模型

| | AI音频生成 |

文生音乐/音效,支持多种风格和乐器

| | 文本转语音(TTS) |

文本转自然语音,支持多音色、语速语调调节

| | 视频合成 |

多片段合成完整视频,支持转场效果和字幕

| | 音频增强 |

降噪、清晰化、音量均衡等音频优化处理

|

3.3 数据处理类节点 —— 让流程"会整理、能转换"

| 节点类型

|

功能说明

格式转换

JSON/XML/CSV/YAML等结构化数据互转

| | 字段映射 |

字段名/结构转换,支持嵌套字段和批量映射规则

| | 数据清洗 |

处理空值/重复/异常值,支持自定义清洗规则

| | 数据聚合 |

多源数据合并/分组/统计,支持自定义聚合函数

| | 模板渲染 |

基于Handlebars等模板引擎动态生成文本/HTML/报表

|

3.4 流程控制类节点 —— 让流程"会决策、能协同"

| 节点类型

|

功能说明

条件分支

根据条件表达式决定流程走向,支持多分支和默认路径

| | 循环控制 |

对数据集进行forEach/while/repeat循环处理

| | 并行处理 |

将列表项并行分发到多个分支执行,支持结果合并

| | 监督者模式(Supervisor) |

监督者Agent循环决策,动态调度Worker执行,直到任务完成

| | 编排器模式(Orchestrator) |

编排器Agent一次性分析任务,路由到对应Worker执行

| | 子流程 |

调用并执行另一个已定义的流程作为子流程

| | 延迟等待 |

暂停流程指定时间或直到条件满足

| | 流程中断 |

强制终止流程,支持错误码和终止消息

|

3.5 人机交互类节点 —— 让流程"会求助、能协同"

| 节点类型

|

功能说明

信息卡片

展示普通信息通知

| | 图表卡片 |

展示数据图表(折线/柱状/饼图等)

| | 结果卡片 |

展示任务执行结果(成功/警告/错误)

| | 列表卡片 |

展示结构化数据列表

| | 审批卡片 |

等待用户通过/拒绝,用于高风险操作确认

| | 表单卡片 |

等待用户填写结构化表单数据

| | 选项卡片 |

等待用户从预设选项中选择

| | 确认卡片 |

简单的是/否确认,用于危险操作二次确认

| | 等待用户操作 |

暂停流程执行,等待用户交互后继续

|

3.6 数据操作类节点 —— 让流程"能落地、会存储"

| 节点类型

|

功能说明

添加数据

数据源的插入操作

| | 查询数据 |

数据源的复杂查询操作

| | 更新数据 |

数据源的更新操作

| | 删除数据 |

数据源的删除操作(软/硬删除)

|

3.7 消息与集成类节点 —— 让流程"会通知、能扩展"

| 节点类型

|

功能说明

发射消息

发送消息到接收方

| | 消息组装 |

更新和修改现有消息内容

| | Skill执行器 |

执行Java本地/OpenClaw/工作流/Python/HTTP等多种Skill(后续专文详解)

|

四、核心亮点:三个"人无我有"的能力

4.1 原生MCP集成——让"模型"和"数据源"在流程层原生对话

MCP(Model Context Protocol)是当前AI领域最受关注的热门协议,它标准化了AI模型与外部工具/数据源的交互方式。

我们的流程引擎对MCP的支持有两个层面:

  • 独立MCP Server节点:在流程中直接配置MCP端点、工具名称和参数,调用符合MCP标准的外部服务

  • LLM节点内嵌MCP:在LLM节点的配置中,可以直接绑定MCP工具列表,让模型自主决策何时调用哪个工具,实现真正的"Function Calling"级别的智能路由

这意味着,你不用在流程画布上手动编排每一个API调用,只需要告诉模型"你能用哪些工具",模型自己会判断什么时候该用

比如我们内置的网络搜索节点,正是基于MCP协议实现的——它调用符合MCP标准的搜索服务,流程内一行额外代码都不用写。

图片

4.2 六大Agent协作模式——从"单兵作战"到"集团军协同"

基于LangGraph的底层能力,我们原生支持六种Agent协作模式:

| 模式

|

适用场景

|

核心机制

条件分支

根据阈值/置信度走不同路径

|

条件表达式路由

| | 循环 |

批量处理数据列表

|

forEach/while/repeat

| | 并行 |

多任务同时执行,结果合并

|

并行分发 + 多策略合并

| | 监督者模式 |

复杂任务需要多轮"思考-执行-反思"

|

Supervisor循环决策,动态调度Worker

| | 编排器模式 |

一次性任务分解,路由到对应Worker

|

Orchestrator一次性分析 + 精准路由

| | 子流程 |

复用已有流程,模块化构建

|

流程嵌套调用

|

这六种模式覆盖了从"简单RAG问答"到"复杂多Agent协同"的全部场景。

真实流程佐证:我们基于监督者模式构建的 AppBuilder流程(从一句话需求自动推导应用架构→详细设计→生成低代码平台Schema),正是多Agent协作的典型实践。该流程包含4个子流程(需求提取→架构推导→详细设计→Schema生成),由监督者Agent根据当前状态循环决策下一步调用哪个Worker,实现了"需求→可执行应用"的端到端自动化。(该流程即将上线,敬请期待)

图片

4.3 User-in-the-Loop——AI决策不了的时候,优雅地"求助"用户

AI不是万能的。

当模型置信度低于阈值、当需要人工审批、当需要用户补充信息时,流程不应该"硬着头皮往下走"。

我们的流程引擎内置了 8种人机交互节点(审批卡片、表单卡片、选项卡片、确认卡片、等待用户操作等),可以在流程的任意节点插入"人工介入点":

  • 审批场景:高风险操作(如数据删除、大额交易)自动生成审批卡片,等待管理者通过/驳回

  • 信息补全:AI识别到信息不足时,自动弹出表单卡片,让用户补充关键字段

  • 低置信度转人工:意图识别置信度低于阈值时,自动路由到人工处理节点

这就是我们所说的"人机协同" ——不是AI替代人,也不是人指挥AI,而是AI和人各自做最擅长的事,在流程层面无缝衔接。

真实流程佐证:在我们的视频生成流程中,AI大模型节点会根据用户的一句话描述,自动生成包含项目元数据、分镜素材、口播脚本、音频配置的完整视频制作JSON规范;随后流程暂停,弹出确认卡片等待用户审批;用户确认后,流程自动进入视频项目组装节点,将规范文件交由视频编辑器执行。AI负责"规划",人负责"决策",各司其职。

五、真实流程速览:三个例子,三种侧重点

以上所有能力不是写在PPT上的概念,而是已经在真实流程中跑通的交付物。

下面是三个基于本平台构建的真实流程示例,它们分别代表了不同的应用场景和技术侧重点。

【配图建议 #5】三个流程全景缩略图

位置:第五章开头

系统截图:以缩略图/卡片形式展示三个流程在画布上的全景

  • 卡片1:智能客服对话流程(节点数较少,线性结构,展示简洁性)

  • 卡片2:视频生成流程(中间包含确认卡片阻断点,展示人机协同)

  • 卡片3:AppBuilder流程(包含监督者节点 + 4个子流程嵌套,展示复杂度)

  • 三个流程并排展示,形成"从简单到复杂"的视觉梯度

建议:截取三个流程画布的缩略俯视图,标注"入门级"、“进阶级”、“专家级”

流程一:智能客服对话流程 —— RAG + 提示词工程

一句话定位:基于产品手册的智能售前顾问

这是一个典型的RAG(检索增强生成)应用场景。流程从用户输入的问题开始,首先调用向量查询节点,在已导入的产品手册知识库中检索最相关的文档片段;检索结果连同用户原始问题一并送入AI大模型节点,由模型基于系统提示词(内置了售前顾问的三种回答模式和风格约束)生成专业回复;最后通过消息组装节点将回复内容推送给用户端。

整个流程中,向量查询的阈值(0.3)和TopK(5)决定了检索的召回精度,而提示词中的"场景匹配模式"“引导式介绍模式"“对比决策模式"三种回答模板,则确保了AI回复的专业性和一致性。

  • 节点链:开始 → 向量查询 → AI大模型 → 消息组装 → 结束

  • 核心能力:RAG检索增强 + 提示词工程 + 事件流式推送

  • 配置要点:向量查询阈值0.3、TopK=5、指定知识库文档ID;LLM节点系统提示词含三种回答模式

图片

流程二:视频生成流程 —— AI结构化输出 + 人机协同确认

一句话定位:一句话生成视频制作项目文件

这是一个"AI打工,人把关"的典型场景。用户只需输入一句话描述(如"做一个产品宣传视频”),流程启动后,AI大模型节点会根据预设的复杂JSON Schema,自动生成包含项目元数据、分镜素材(封面图+4张功能展示图+3个视频片段)、口播脚本、背景音乐、动画参数、转场效果等完整规范的视频制作项目文件。

但AI生成的内容不一定完美——所以流程在LLM节点之后插入了格式转换节点(将LLM输出的JSON字符串解析为对象),然后弹出确认卡片,流程在此暂停,等待用户审批。用户确认无误后,流程继续执行视频项目组装节点,将项目文件交付给视频编辑器执行。

如果用户觉得AI生成的方案不合适,可以拒绝并让AI重新生成。AI负责规划,人负责决策

  • 节点链:开始 → AI大模型(结构化输出)→ 格式转换 → 消息组装 → 确认卡片 → 视频项目组装 → 消息组装 → 结果卡片 → 结束

  • 核心能力:LLM结构化输出 + 人机协同确认 + 项目文件产出

  • 配置要点:LLM节点按JSON Schema约束输出、确认卡片阻断流程等待用户操作、视频项目组装节点产出可被视频编辑器直接打开的项目文件

图片

流程三:AppBuilder流程 —— 多Agent协作(即将上线)

一句话定位:从自然语言需求到可执行应用Schema的端到端自动化

这是最能体现平台"多Agent协作"深度的流程,目前即将上线。

流程从用户的自然语言需求描述(或PRD文档)开始,首先经过意图识别节点,判断用户意图属于"新建应用(有文档)““新建应用(无文档)““变更请求"“确认"“拒绝"“咨询"中的哪一类,并输出置信度。

确认新建意图后,流程进入监督者模式节点。该节点内部包含4个子流程(需求提取→架构推导→详细设计→Schema生成),每个子流程自身又是一个完整的AI流程——包含LLM调用、格式转换、确认卡片等节点。监督者Agent会根据当前全局状态(requirements、architecture、pageDesigns、schema)循环决策下一步调用哪个Worker,直到Schema生成完成。

图片

图片

图片

整个过程中,每个子流程完成后都会等待用户确认再进入下一步,实现了**“多Agent协同 + 人在回路”**的完美结合。

  • 节点链:开始 → 意图识别 → 监督者模式(内含4个子流程)→ 结束

  • 核心能力:多Agent协作 + 复杂任务分解 + 状态管理 + 意图识别前置

  • 配置要点:监督者模式含4个Worker(需求提取/架构推导/详细设计/Schema生成),各Worker通过全局状态变量传递数据

图片

三个流程覆盖了从"简单RAG问答"到"AI规划+人把关”,再到"多Agent复杂协同"的全场景梯度。

这三个流程的具体拆解——包括设计思路、节点配置详解、运行数据解读——我们将在后续文章中逐一展开,敬请关注。

六、部署与接入:两种模式,覆盖全场景

企业级产品,绕不开"怎么部署"这个问题。

我们的AI流程引擎支持两种部署模式,覆盖从初创团队到大型企业的全部需求:

| 模式

|

适用场景

|

特点

SaaS模式

中小团队快速验证、初创企业降本增效

|

开箱即用,无需运维,按量付费,分钟级上线

| | 私有化部署 |

金融/政务/大型企业等高安全要求场景

|

全量代码交付、内网部署、数据不出域、支持信创环境

|

两种模式共享同一套流程定义规范——您在SaaS环境下调试好的流程,导出的JSON定义可以直接导入私有化环境运行,迁移成本几乎为零。

此外,私有化部署模式下,平台支持作为企业中台统一提供AI编排能力,供各业务线在线接入,实现流程、模型、权限的集中治理。

图片

七、结语:流程引擎是智能体的"骨架”,但我们远不止于此

以上就是我们AI智能体平台核心模块之一——AI流程引擎的全景介绍。

60+个节点类型、6种Agent协作模式、原生MCP集成、User-in-the-Loop、SaaS+私有化双模部署……所有这些努力,只为了回答一个问题:

如何让AI真正"干成事”,而不是"只会说”。

流程引擎构建了智能体的"骨架”——它定义了AI能走哪些路、遇到岔路口怎么选、遇到走不通的路怎么求助。但光有骨架还不够,一个完整的智能体还需要:

  • 大脑:模型LLM管理,统管所有AI模型的接入、路由与调度

  • 神经:MCP服务管理,让模型与外部世界的连接标准化、可治理

  • 记忆:提示词管理,让每个场景的"沟通方式"可沉淀、可复用

  • 四肢延伸:Skill执行器,让流程能调用Java/Python/HTTP等多种形态的企业存量能力

这些,都会在后续的文章中逐一拆解。

下一期预告:《提示词管理——如何让AI的"沟通方式"不再靠口口相传?》

在线演示

以上所有功能均可在在线演示环境中亲身体验。无需注册,点击下方链接即可试用本文提到的智能客服对话流程和视频生成流程:

👉 https://ai.qztechcloud.com/flow-builder/

(演示环境包含智能客服、视频生成两个完整流程,您可以直接输入测试数据,实时查看流程执行轨迹和节点运行日志。)