A2A 协议与 Agent 互操作 · Task 生命周期

🏠 返回 07-README ｜ ⬅️ 13-跨语言混合栈 ｜ ➡️ 15-MCP生产宿主

定位：Agent↔Agent 任务委托 的 Staff 专章——Task 生命周期、JSON-RPC/SSE、与 MCP/gRPC 分工。机制散见 04 §8、05 §A2A。

§0 面试前 30 分钟 Checklist

时间动作
5 min背 三协议分工：A2A / MCP / gRPC
5 min画 Task 状态机 submitted→working→completed/failed
5 min口述 Artifact vs Tool 结果
5 min链 release_id 与 11 Registry
5 min准备 §11 STAR 超时雪崩
5 min过 §12 Runbook + Q1–Q10

开场金句（90s）：

「A2A 解决 Agent 之间派活：有状态 Task、可流式进度、可取消；MCP 解决 调工具——单步、无状态。我们 Java Supervisor 对内用 gRPC Task（13），对外联盟伙伴用 A2A；无论哪种，都绑 release_id，Worker 不信对方传来的订单金额。」

L1 · 是什么

1.1 一句话

A2A（Agent2Agent） = 开放 Agent 互操作 协议：用标准 Task 抽象把「请另一个 Agent 完成目标」变成可审计、可版本化、可跨厂商的 API——编排层，不替代 MCP。

1.2 三协议对照（必背）

协议抽象状态典型传输本库章节
MCPTool / Resource无状态单步stdio / SSE15
A2ATask / Message / Artifact有状态多步HTTP JSON-RPC + SSE本篇
gRPC Task内部 Protobuf有状态gRPC13

A2A Task

gRPC

MCP tools/call

Supervisor Agent

Partner Agent

Python Worker

Order MCP Server

1.3 何时用 A2A

用 A2A不用 A2A
跨团队 / 跨云 Agent 能力外包同进程 Multi-Agent（内存总线）
需要 任务进度流式推送单次查库存（MCP）
联盟生态互认强同步低延迟内网（gRPC）

1.4 与 Multi-Agent 拓扑的关系

拓扑A2A 角色
Supervisor–WorkerSupervisor 对外发 A2A Task
对等协商双向 Task，需冲突解决
流水线上游 Artifact 作下游 Task context

对照：05-Multi-Agent、demo multi-agent-supervisor-springai。

L2 · Task 生命周期（深展）

2.1 状态机

worker accepts

artifact ready

error

cancel RPC

policy deny

submitted

working

completed

failed

cancelled

rejected
状态含义Supervisor 动作
submitted已创建未执行可取消
working执行中订阅 SSE / 轮询 get
completed终态成功取 Artifact
failed终态失败降级 / 转人工
cancelled用户或上游取消清理副作用
rejected策略拒绝记录 audit，不 retry send

2.2 核心对象

对象字段（示意）说明
Taskid, goal, context, metadata.release_id委托请求
Messagerole, parts[]对话片段
Artifactparts[], structured_output交付物（非 Tool 日志）

与 [13] gRPC 对齐：AgentTask / AgentArtifact 是内部实现；对外 A2A 用 JSON 字段名遵循开放规范。

2.3 JSON-RPC 方法矩阵

方法幂等用途
tasks/send是（同 task_id）创建并可选立即执行
tasks/get是轮询状态
tasks/cancel是取消 working
tasks/subscribe只读流SSE 进度

Staff：send 必须客户端生成 全局唯一 task_id；服务端以 task_id 去重。

2.4 SSE 事件类型

event含义客户端处理
status-updateworking 进度更新 UI
artifact-update部分交付增量展示
error可恢复错误退避重连
done流结束再 get 确认终态

2.5 非法迁移 Golden

case期望
completed → workingreject
cancel 后 MCP 写无写
重复 send 同 id返回同一 Task

L3 · 生产落地

3.1 安全与信任

规则原因
Task 只带 case_id / 槽位防 PII、防篡改金额
Worker 重查权威服务不信 Supervisor 转述
mTLS + tenant_id联盟多租户
release_id 在 metadata对齐 11

3.2 超时与背压

层策略
Client总 deadline（如 120s）
Server队列深度上限 → rejected
重试仅 get 幂等；不盲重发 send

3.3 与 Registry / Eval

绑定说明
metadata.release_id全链归因
Golden测非法状态迁移、cancel 后无写
Gatetask_failed_rate 阈值；非 Tool 层指标

3.4 Java 实现要点

组件建议
入口Spring MVC /a2a + SseEmitter
鉴权Gateway OAuth2 + scope a2a:invoke
执行线程池隔离；Worker 池 bulkhead
审计每个 Task 写 trace_id

3.5 Python Worker 要点

组件建议
框架FastAPI + Pydantic Task 模型
引擎LangGraph 子图作 Worker
取消cooperative cancel token 传 Tool
Worker Agent A2A Server Supervisor Worker Agent A2A Server Supervisor tasks/send task_id dispatch SSE status-update SSE forward artifact tasks/get completed

L7 · 失败模式目录（A2A）

现象根因止血根治
重复 send 风暴把 send 当非幂等熔断+只重试 getGolden 重复 send
SSE 断连丢终态只靠 SSE断连后 get终态以 get 为准
Artifact 含 PIITool 日志直出结构化脱敏Schema 审查
跨租户 Taskmetadata 未校验rejectedGateway 强制 tenant
release 漂移未 pin WorkerRegistry 门禁双组件 release_id

L8 · 迁移路径（四阶段）

阶段动作验收
P0内网 gRPC Task 稳定[13] Golden 绿
P1只读 A2A 查询伙伴无写 Tool
P2写路径 MCP 白名单illegal_tool_rate=0
P3联盟 SSE + SLAtask_failed_rate 达标

L9 · 与 Browser / VIP 场景

场景A2A 用法
Browser外包「复杂填表」给伙伴 Agent；本库主路径 05b
VIP外包「私人造型」Agent；金额承诺仍在 Java 控制面

L10 · Runnable 对照

工件路径
Java Supervisormulti-agent-supervisor-springai
Golden 校验validate_golden.py
知识库地图AGENT-KNOWLEDGE-BASE-MAP

L11 · Staff 答辩

STAR：A2A 重试风暴

要素内容
S联盟 Worker 429，Supervisor 重试 tasks/send 放大流量
A改幂等 task_id；指数退避；熔断；只重试 get
M把 send 当非幂等导致重复副作用
P限流恢复；Golden 增重复 send 负例

STAR：SSE 断连误判失败

要素内容
S移动端 SSE 断连，Supervisor 当 failed 触发补偿写
A终态以 get 为准；补偿前再 get；写操作幂等
M补偿写重复发货
P关闭自动补偿；Runbook 强制 get 二次确认

Q1 · A2A 和 MCP？

标准答案：编排 vs Tool；Task 有状态 vs tools/call 单步。

追问：MCP 能否承载多步？→ 可以但不推荐，审计差。

Q2 · 为何不全用 A2A 替代 gRPC？

标准答案：内网延迟、Protobuf 演进、团队边界。

追问：联盟伙伴只支持 REST 怎么办？→ Gateway 翻译。

Q3 · Artifact 放什么？

标准答案：结构化结论+引用；不放全量 Tool 日志。

追问：需要中间推理链吗？→ 进 Trace，不进 Artifact。

Q4 · 如何版本化？

标准答案：metadata.release_id + capability 协商。

追问：伙伴未升级 schema？→ rejected + 降级路径。

Q5 · OpenClaw 能当 A2A Server？

标准答案：不适合生产；见 12。

追问：个人 Agent 数据驻留？→ 企业禁。

Q6 · cancel 后副作用？

标准答案：Worker cooperative cancel；MCP 写需幂等。

追问：已写一半怎么办？→ saga 补偿。

Q7 · 多 Task 并行？

标准答案：Supervisor 预算分配；每 Task 独立 task_id。

追问：共享上下文？→ context_slice 最小化。

Q8 · A2A 指标？

标准答案：task_failed_rate、P99 latency、cancel 成功率。

追问：与 Eval acc 关系？→ 正交，都过才发版。

Q9 · 谁生成 task_id？

标准答案：调用方 Supervisor，UUIDv7 推荐。

追问：服务端生成？→ 不利于幂等重试。

Q10 · 与 Temporal？

标准答案：Temporal 长流程；A2A 短委托；见 04-java/04。

追问：二选一？→ 组合。

L12 · Oncall Runbook（task_failed_rate 告警）

  1. 按 release_id 分组失败率
  2. 抽样 5 条 Task trace 看 failed 原因
  3. 若 429 → 降并发 + 退避
  4. 若 schema → 回滚 Registry tool_schema 或 Worker
  5. 恢复后跑 Golden illegal 迁移

§15 Checklist

  • 三协议分工
  • Task 六状态
  • SSE vs 轮询
  • send 幂等 task_id
  • 不信转述金额
  • release_id 透传
  • cancel 无写
  • Golden 非法迁移

§16 导航

关联路径
跨语言 gRPC13
MCP15
Multi-Agent05
完整知识库AGENT-KNOWLEDGE-BASE-MAP

L1

L2

L4 · 参数与容量（深展）

2.6 生产参数卡 #1

参数推荐值说明
task_timeout_sec65单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks21Worker 背压
retry_get_max3仅 get 重试

2.7 生产参数卡 #2

参数推荐值说明
task_timeout_sec70单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks22Worker 背压
retry_get_max3仅 get 重试

2.8 生产参数卡 #3

参数推荐值说明
task_timeout_sec75单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks23Worker 背压
retry_get_max3仅 get 重试

2.9 生产参数卡 #4

参数推荐值说明
task_timeout_sec80单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks24Worker 背压
retry_get_max3仅 get 重试

2.10 生产参数卡 #5

参数推荐值说明
task_timeout_sec85单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks25Worker 背压
retry_get_max3仅 get 重试

2.11 生产参数卡 #6

参数推荐值说明
task_timeout_sec90单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks26Worker 背压
retry_get_max3仅 get 重试

2.12 生产参数卡 #7

参数推荐值说明
task_timeout_sec95单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks27Worker 背压
retry_get_max3仅 get 重试

2.13 生产参数卡 #8

参数推荐值说明
task_timeout_sec100单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks28Worker 背压
retry_get_max3仅 get 重试

2.14 生产参数卡 #9

参数推荐值说明
task_timeout_sec105单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks29Worker 背压
retry_get_max3仅 get 重试

2.15 生产参数卡 #10

参数推荐值说明
task_timeout_sec110单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks30Worker 背压
retry_get_max3仅 get 重试

2.16 生产参数卡 #11

参数推荐值说明
task_timeout_sec115单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks31Worker 背压
retry_get_max3仅 get 重试

2.17 生产参数卡 #12

参数推荐值说明
task_timeout_sec120单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks32Worker 背压
retry_get_max3仅 get 重试

2.18 生产参数卡 #13

参数推荐值说明
task_timeout_sec125单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks33Worker 背压
retry_get_max3仅 get 重试

2.19 生产参数卡 #14

参数推荐值说明
task_timeout_sec130单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks34Worker 背压
retry_get_max3仅 get 重试

2.20 生产参数卡 #15

参数推荐值说明
task_timeout_sec135单 Task 上限
sse_heartbeat_sec15保活
max_concurrent_tasks35Worker 背压
retry_get_max3仅 get 重试
# qt # 开发语言
Logo
MCP技术社区

欢迎加入 MCP 技术社区！与志同道合者携手前行，一同解锁 MCP 技术的无限可能！

更多推荐

cover

Windows 下部署 New API 中转站全过程实录（含 6 个真实踩坑）

avatar MCP技术社区

Google能索引，AI却抓不到

很多技术团队有个错觉：只要Google能正常收录，内容就没问题。但现实是，你的页面在Google搜索结果里好好的，在ChatGPT、Perplexity、Claude的答案里却像从未存在过一样。

avatar MCP技术社区

初识智能体

在过去两年中，几乎所有人都体验过大语言模型（如 ChatGPT、Claude、DeepSeek）的强大能力：写周报、润色邮件、解答编程疑难。被动响应：你问一句，它答一句。如果你的 Prompt 没有写清楚约束条件，它无法主动追问或修正目标。知行脱节：大模型能用流畅的文字告诉你“如何部署一个高可用 K8s 集群”，但它无法替你登录服务器敲下命令、查看报错日志并自动回滚。信息孤岛：大模型的知识止步于预

avatar MCP技术社区