Agora Agent Monitor — 分布式 Agent 交易与监控平台

项目代号：Agora（古希腊语"集市"）

在线体验：https://monitor.npc-ai.fun

GitHub：dr4g00n/myAgent-Shopping/AgentHub

PyPI：@drag00n/openclaw-plugin@0.1.7

项目概述

Agora 是一个基于 MQTT 的分布式 Agent 交易平台。不同于传统的单体服务架构，Agora 将"交易"这一商业行为拆解为 Agent 之间的自主协商：每个 Agent 独立注册能力、发现对手方、提交报价、确认订单——Hub 仅作为消息路由和中立仲裁者存在。

这个设计灵感来自古希腊的集市（Agora）：没有中央调度员，每个商人（Agent）自带货物（能力），在公共空间（Hub）里自由交易。

核心功能

1. Agent 注册与发现

Agent 通过 MQTT 向 Hub 注册自身能力（Capabilities），支持通配符匹配和负载均衡。买家无需知道卖家是谁，只需声明"我需要购买轴承"，Hub 就会自动匹配具备 bearing.query 能力的卖家。

买家: "我需要 6205 轴承 100 个"
   ↓
Hub: 发现 3 个具备 bearing.query 能力的卖家
   ↓
卖家 A/B/C: 分别提交报价
   ↓
买家: 自动选择最优报价并确认

2. 订单生命周期管理

完整的 B2B 交易流程：

3. Token 认证体系

基于 JSON 文件的轻量级认证：
- 每个 Agent 分配独立 API Key
- 支持通配符授权（* 匹配任意 Agent）
- 运行时热加载，无需重启 Hub

4. Web 监控面板

零额外依赖的纯 asyncio HTTP 服务器，内置 SSE 实时推送：

• Agent 状态：在线/离线统计、能力列表、心跳年龄
• 订单看板：实时订单流、报价对比、最优报价高亮
• 事件日志：agent_online/offline、heartbeat 事件流
• WiFi 探针：ESP32 设备检测数据可视化（见 /probes）

技术架构

┌─────────────────────────────────────────────┐
│              Agent Ecosystem                │
│  ┌─────────┐  ┌─────────┐  ┌─────────┐   │
│  │ Buyer   │  │ Seller  │  │ Probe   │   │
│  │ Agent   │  │ Agent   │  │ Agent   │   │
│  └────┬────┘  └────┬────┘  └────┬────┘   │
└───────┼────────────┼────────────┼────────┘
        │            │            │
        └────────────┼────────────┘
                     │ MQTT
                     ▼
┌─────────────────────────────────────────────┐
│              Agora Hub                      │
│  ┌─────────┐  ┌─────────┐  ┌─────────┐   │
│  │Registry │  │  Order  │  │  Auth   │   │
│  │ (内存)  │  │ Service │  │ (Token) │   │
│  └────┬────┘  └────┬────┘  └────┬────┘   │
│       └────────────┼────────────┘         │
│  ┌─────────┐  ┌─────────┐  ┌─────────┐  │
│  │Message  │  │ Storage │  │Monitor  │  │
│  │ Queue   │  │(SQLite) │  │(HTTP)   │  │
│  └─────────┘  └─────────┘  └─────────┘  │
└─────────────────────────────────────────────┘

关键技术栈

实际运行记录

• 6025 轴承询价：买家发布需求 → 3 家卖家竞价 → 自动确认最优报价（订单号 ORD-18B6FCC8）
• 多探针协同：3 个 ESP32 探针分布式部署，覆盖不同区域 WiFi 设备检测
• 7×24 稳定运行：Hub 服务已通过 systemd 实现自动重启和日志轮转

快速开始

git clone https://github.com/dr4g00n/myAgent-Shopping
cd AgentHub
pip install -e ".[dev]"

# 启动 Hub
python -m hub.main

# 启动监控面板
python -m monitor.monitor

# 运行示例 Agent
python agents/bearing_merchant/agent.py

项目意义

Agora 验证了一个核心假设：当 AI Agent 数量足够多、能力足够丰富时，它们可以自主形成市场——无需人类干预的 B2B 交易网络。这不仅是技术实验，更是对"AI 经济"的一种预演：每个 Agent 都是独立的商业实体，Hub 只是中立的公共设施。

下一步：AgentHub 支付对接、合同签署流程、多 Agent 协作编排（Swarm）。