Agent Communication Hub v2.2

多智能体实时通信、任务编排、记忆共享与协同进化基础设施

共享记忆，共同进化

让两个或多个独立 AI 智能体实现实时双向通信、任务自动调度、记忆共享和协同进化。基于 MCP 协议 + SSE 推送，消息零丢失，延迟 \x3C 50ms。

架构

┌──────────────┐         ┌──────────────────────────┐         ┌──────────────┐
│   Agent A    │  SSE    │   Agent Communication     │  SSE    │   Agent B    │
│  (Hermes)    │◄───────►│         Hub v2.2          │◄───────►│  (WorkBuddy) │
│              │  MCP    │    (localhost:3100)        │  MCP    │              │
└──────────────┘◄───────►│                          │◄───────►└──────────────┘
                       └──────────┬───────────────┘
                                  │
                             SQLite (WAL)

三层协议：

46 个 MCP 工具一览

1. Identity 身份管理（6 个）

2. Message 消息（5 个）

3. Task 任务（4 个）

4. Memory 记忆（5 个）

5. Evolution 进化引擎（11 个）

6. Orchestration 编排（10 个）

7. Token 管理（2 个）

权限模型

任务状态机

inbox → assigned → waiting → in_progress → completed
                                └──→ failed
                                └──→ cancelled

• waiting：有未完成的上游依赖，自动阻塞
• in_progress：Agent 开始执行
• 状态变更自动通过 SSE 通知相关 Agent

信任评分

base = 50
+ verified_capabilities × 3
+ approved_strategies × 2
+ positive_feedback（排除自评）× 1
- negative_feedback × 2
- rejected_applications × 3
- revoked_tokens × 10
→ clamp(0, 100)

信任分影响策略审批 tier：trust≥90 可自动通过，trust≥60 可 peer 审批。

SSE 事件

SSE 支持断线重连：客户端发送 Last-Event-ID，Hub 从该 ID 之后补发。

快速开始

1. 安装 Hub 服务器

# 运行一键安装脚本（从 GitHub 克隆 + 构建）
bash ~/.workbuddy/skills/agent-comm-hub/scripts/install.sh

# 或手动安装
git clone \x3Crepo-url> ~/agent-comm-hub
cd ~/agent-comm-hub
npm install && npm run build
npm start           # 生产模式，端口 3100
# 或 npm run dev     # 开发模式（热重载）

2. 注册 Agent

# 使用自动化脚本
bash ~/.workbuddy/skills/agent-comm-hub/scripts/setup_agent.sh "my-agent" "mcp,message,memory"

# 输出：agent_id + api_token，保存到 .env

3. 配置 MCP 连接（推荐）

在 Agent 的 MCP 配置中添加：

{
  "mcpServers": {
    "agent-comm-hub": {
      "url": "http://localhost:3100/mcp"
    }
  }
}

Agent 的 LLM 可以直接调用全部 46 个工具。

4. SDK 接入（可选）

Python（零外部依赖）：

from hub_client import SynergyHubClient

hub = SynergyHubClient(hub_url="http://localhost:3100", agent_id="my-agent")
hub.set_token("your-api-token")
hub.heartbeat()
hub.send_message(to="other-agent", content="Hello!")
hub.store_memory(content="重要信息", scope="collective")
hub.share_experience(title="踩坑记录", content="...", category="experience")
hub.on_message = lambda msg: print(f"收到: {msg}")
hub.connect_sse()  # 阻塞，SSE 长连接

TypeScript：

import { AgentClient } from "./client-sdk/agent-client.js";
const client = new AgentClient({
  agentId: "my-agent",
  hubUrl: "http://localhost:3100",
  onTaskAssigned: async (task) => { /* 处理任务 */ },
  onMessage: async (msg) => { /* 处理消息 */ },
});
await client.start();

5. 验证

# 健康检查
curl http://localhost:3100/health

# Prometheus 指标
curl http://localhost:3100/metrics

文件结构

agent-comm-hub/                    # Skill 目录（轻量，\x3C 1MB）
├── SKILL.md                       # 本文件
├── scripts/
│   ├── install.sh                 # 一键安装 Hub 服务器
│   └── setup_agent.sh             # Agent 注册 + 认证自动化
├── client-sdk/
│   ├── hub_client.py              # Python SDK（39 个 async 方法，零依赖）
│   ├── agent-client.ts            # TypeScript SDK（35 个公开方法）
│   └── agent-client.js            # 编译后的 JS
├── docs/
│   ├── API_REFERENCE.md           # 完整 API 文档 v2.2
│   ├── SETUP_GUIDE.md             # 详细部署指南
│   ├── orchestrator-guide.md      # 进阶编排指南
│   ├── evolution-guide.md         # 进化引擎指南
│   └── TROUBLESHOOTING.md         # 踩坑经验
└── examples/
    ├── workbuddy-mcp.json         # WorkBuddy MCP 配置示例
    ├── hermes-mcp.json            # Hermes MCP 配置示例
    └── qclaw_bridge.py            # QClaw 桥接示例

环境变量

运维端点

安全特性（Phase 5a）

• RBAC 权限：public / member / group_admin / admin 四级
• 审计哈希链：audit_log 表 prev_hash → record_hash，触发器写保护
• 信任评分：多维度自动计算，影响策略审批 tier
• CORS 白名单：默认拒绝跨域
• 安全响应头：X-Frame-Options / CSP / HSTS / X-XSS-Protection
• 请求追踪：每请求 traceId，响应头 X-Trace-Id
• 优雅关闭：SIGTERM → drain SSE → 关闭 DB → 退出

踩坑经验速查

技术依赖

Hub 服务器：Node.js 18+、@modelcontextprotocol/sdk、express、better-sqlite3、zod

Python SDK：Python 3.9+，零外部依赖（纯标准库）

TS SDK：Node.js 18+，零外部依赖（原生 fetch）

许可

MIT