┌─────────────────────────────────────────────┐
│              协调器代理                      │
│  （协调工作流，分配任务）                    │
└─────────────────┬───────────────────────────┘
                  │
        ┌─────────┼─────────┐
        │         │         │
        ▼         ▼         ▼
   ┌────────┐ ┌────────┐ ┌────────┐
   │研究代理 │ │写作代理 │ │审查代理 │
   └────────┘ └────────┘ └────────┘

代理 A → 代理 B: "研究主题 X"
代理 B → 代理 A: "这是 10 个来源..."

代理 A → 消息总线："文章完成"
代理 B ← 消息总线：（被通知，接收文章）
代理 C ← 消息总线：（被通知，开始审查）

┌─────────────────────────────────┐
│         共享黑板                 │
│  - 研究发现                     │
│  - 草稿内容                     │
│  - 审查意见                     │
│  - 最终文章                     │
└─────────────────────────────────┘
         ▲         ▲         ▲
         │         │         │
    研究代理   写作代理   审查代理

研究 → 写作 → 审查 → 发布
 ↓      ↓      ↓      ↓
代理 A  代理 B  代理 C  代理 D

           ┌─→ 代理 B（研究）─┐
主代理 ──┼─→ 代理 C（大纲）─┼→ 合成
           └─→ 代理 D（示例）─┘

        主代理
           │
    ┌──────┴──────┐
    │             │
  研究          写作
    │             │
  ┌─┴─┐         ┌─┴─┐
  │   │         │   │
Web  DB      草稿 编辑

工作流:
  触发器："发布关于 X 的文章"

  步骤:
    1. 协调器接收请求
    2. 研究代理搜索网络（10 个来源）
    3. 写作代理起草文章（1500 字）
    4. 翻译代理创建中文版本
    5. 审查代理检查质量
    6. 发布代理保存到数据库
    7. 通知代理发送确认

工作流:
  触发器：创建拉取请求

  步骤:
    1. 安全代理检查漏洞
    2. 风格代理检查代码格式
    3. 测试代理运行测试套件
    4. 性能代理分析复杂度
    5. 协调器汇总发现
    6. 评论代理发布审查意见

# ✅ 好：职责清晰
研究代理：只收集信息
写作代理：只生成内容
审查代理：只检查质量

# ❌ 坏：职责重叠
代理 A：研究和写作
代理 B：写作和审查
# 造成混乱和冲突

# 定义标准消息格式
class AgentMessage:
    def __init__(self, sender, recipient, action, payload):
        self.sender = sender      # 谁发送的
        self.recipient = recipient # 谁应该处理
        self.action = action       # 做什么
        self.payload = payload     # 需要的数据
        self.timestamp = time.time()

class AgentOrchestrator:
    def execute_with_retry(self, agent, task, max_retries=3):
        for attempt in range(max_retries):
            try:
                return agent.execute(task)
            except AgentError as e:
                if attempt == max_retries - 1:
                    # 升级给人类或备用代理
                    return self.handle_failure(e)
                time.sleep(2 ** attempt)  # 指数退避

class AgentMonitor:
    def log_execution(self, agent_name, task, result, duration):
        log_entry = {
            'agent': agent_name,
            'task': task,
            'result': result,
            'duration': duration,
            'timestamp': datetime.now(),
        }
        self.save_log(log_entry)

# 关键决策需要人类批准
工作流:
  - 代理起草内容
  - 代理审查内容
  - 如果 置信度 < 90%:
      → 通知人类审查
  - 否则:
      → 自动发布
  - 人类可以随时覆盖