Agent 互联协议全景：A2A、ACP、ANP 与 MCP 的互补生态

┌───────────────────────────────────────────────────────────────┐
│                    Agent 互联协议层次模型                        │
│                                                               │
│  ┌─────────────────────────────────────────────────────────┐  │
│  │  Layer 4: ANP — 去中心化开放网络                          │  │
│  │  DID 身份 · 元协议协商 · Agent 支付 · 开放市场              │  │
│  └─────────────────────────────────────────────────────────┘  │
│  ┌─────────────────────────────────────────────────────────┐  │
│  │  Layer 3: A2A — 企业级 Agent 协作                         │  │
│  │  Agent Card · Task 生命周期 · SSE 流式 · 推送通知           │  │
│  └─────────────────────────────────────────────────────────┘  │
│  ┌─────────────────────────────────────────────────────────┐  │
│  │  Layer 2: ACP — 轻量 REST 通信（已合并入 A2A）              │  │
│  │  RESTful API · 离线发现 · 多模态消息                       │  │
│  └─────────────────────────────────────────────────────────┘  │
│  ┌─────────────────────────────────────────────────────────┐  │
│  │  Layer 1: MCP — 工具与数据访问                             │  │
│  │  Resources · Tools · Prompts · Sampling                   │  │
│  └─────────────────────────────────────────────────────────┘  │
└───────────────────────────────────────────────────────────────┘

┌─────────────────┐    JSON-RPC 2.0    ┌──────────────────┐
│                 │  ◄──────────────►  │                  │
│   MCP Client    │  (stdio / SSE /   │   MCP Server     │
│   (AI Agent)    │   HTTP Streaming)  │   (Tool Provider)│
│                 │                    │                  │
│  ┌───────────┐  │   Request:         │  ┌────────────┐  │
│  │ LLM Brain │──┼── tools/call ─────►│  │ Resources  │  │
│  │           │  │                    │  ├────────────┤  │
│  │           │◄─┼── Result/Error ◄───│  │ Tools      │  │
│  └───────────┘  │                    │  ├────────────┤  │
│                 │                    │  │ Prompts    │  │
│                 │                    │  ├────────────┤  │
│                 │                    │  │ Sampling   │  │
│                 │                    │  └────────────┘  │
└─────────────────┘                    └──────────────────┘

{
  "name": "天气预报 Agent",
  "description": "提供全球城市天气查询和预报服务",
  "url": "https://weather-agent.example.com",
  "version": "1.0.0",
  "defaultInputModes": ["text"],
  "defaultOutputModes": ["text"],
  "capabilities": {
    "streaming": true,
    "pushNotifications": false
  },
  "authentication": {
    "schemes": ["bearer"]
  },
  "skills": [
    {
      "id": "get_weather",
      "name": "查询天气",
      "description": "根据城市名称查询当前天气和未来预报",
      "tags": ["weather", "forecast"]
    }
  ]
}

submitted ──► working ──► input-required ──► working ──► completed
    │              │              │                          │
    │              │              ▼                          │
    │              │          (等待输入)                       │
    │              ▼                                         │
    │           failed ◄─────────────────────────────────────┘
    ▼
  rejected / canceled

from a2a.server.agent_execution import AgentExecutor, RequestContext
from a2a.server.events import EventQueue
from a2a.types import (
    AgentCard, AgentSkill, AgentCapabilities,
    Task, TaskState, Message, Part, TextPart
)

class WeatherAgentExecutor(AgentExecutor):
    async def execute(self, context: RequestContext, event_queue: EventQueue):
        message = context.message
        query = message.parts[0].text

        result = await get_weather(query)

        task = Task(
            id=context.task_id,
            contextId=context.context_id,
            status={"state": TaskState.COMPLETED},
            artifacts=[{
                "parts": [TextPart(text=result)]
            }]
        )
        await event_queue.enqueue_event(task)

┌─────────────────────────────────────────────────────────────┐
│              Layer 3: 应用协议层                               │
│   Agent 描述(ADP) · Agent 发现 · 支付(AP2) · 授权 · 认证      │
├─────────────────────────────────────────────────────────────┤
│              Layer 2: 身份与通信基础设施                        │
│   DID:WBA 身份 · WNS 命名 · 密钥分发 · 安全消息 · 跨域通信       │
├─────────────────────────────────────────────────────────────┤
│              Layer 1: 开放互联网基础设施                        │
│   HTTP · CA · DNS · CDN · TLS · 搜索引擎                      │
└─────────────────────────────────────────────────────────────┘

你的需求是什么？
│
├── 让 Agent 连接数据库/API/文件？
│   └── ✅ MCP
│
├── 让两个同企业的 Agent 协作完成任务？
│   └── ✅ A2A
│
├── 让不同厂商的 Agent 发现和委派任务？
│   └── ✅ A2A + Agent Card
│
├── 在开放互联网上让 Agent 被发现和交互？
│   └── ✅ ANP（未来方向）
│
└── 以上全部？
    └── ✅ MCP + A2A（当前最佳实践）

时间线（建议）：

2025 ──────── 2026 ──────── 2027 ──────── 2028+
  │              │              │              │
  ▼              ▼              ▼              ▼
 Stage 1       Stage 2       Stage 3       Stage 4
 MCP 工具      A2A 协作      ANP 网络      全栈互联
 接入          试点          探索          成熟