企业多智能体协同架构：任务交接（Hand-off）与上下文隔离实践

【两大主流多智能体交接协作拓扑对比】

• 1. 中心化路由主管模式（Supervisor / Orchestrator Pattern）：
  由中央主管 Agent（Supervisor）负责全流程统筹。用户请求首先进入 Supervisor，由其分解为子目标并依次调度分配给指定的专业 Worker Agent（如知识检索 Agent、ERP 录入 Agent、风控审查 Agent）。Worker 完成局部任务后，必须将结构化结果汇报给 Supervisor，由 Supervisor 决定是否继续交接或终止交付。
  适用场景：业务逻辑确定性强、审计合规要求高、存在严密前后置依赖的审批流与集成操作。
• 2. 对等网络协作移交模式（Peer-to-Peer Hand-off Pattern）：
  智能体之间具备明确的交接工具函数（如 transfer_to_finance_agent()）。当前 Agent 在识别到自身职责无法覆盖或满足交接条件时，直接主动调用交接函数将控制权移交给下游专业 Agent，下游 Agent 接管与用户的会话通道。
  适用场景：跨业务导流、多专业领域客服转接、动态人机双人复核。

【Hand-off 最小状态载荷四要素规范】

1. 全局会话与追踪凭证（Trace Context）：包含 traceId、correlationId、当前父节点 Span ID 与发起人凭据，确保分布式链路可追踪。
2. 业务核心状态集（Verified Business State）：经过 Schema 严格校验与业务规则锁定的强类型数据（如经过校验的订单号、已锁定的物料编码、已确认的金额）。
3. 交接意图与明确目标（Explicit Target Objective）：用清晰的一句话声明下游 Agent 需要履行的具体职责（例如：“请根据已校验的采购项执行 ERP PR 单据创建，并返回生成单号”），杜绝下游自行猜测上游意图。
4. 私有黑盒数据截断（Private Context Stripping）：上游 Agent 内部多轮试错的中间过程、Prompt 模板、草稿向量检索结果全部清除，仅输出标准化产物。

// 多智能体任务交接契约与调度引擎核心实现
import { z } from 'zod';

// 1. 定义标准 Hand-off 任务交接载荷 Schema
export const HandoffPayloadSchema = z.object({
  traceId: z.string().uuid({ message: "链路追踪 ID 必须为合法 UUID" }),
  sourceAgentId: z.string().min(1),
  targetAgentId: z.string().min(1),
  hopCount: z.number().int().min(0).max(5, { message: "交接跳转超出最大限制 (5 跳)，触发熔断" }),
  objective: z.string().min(5, { message: "交接目标必须明确详实" }),
  // 最小强类型业务状态，避免全量上下文蔓延
  state: z.record(z.any()),
  visitedHistory: z.array(z.string()),
});

export type HandoffPayload = z.infer<typeof HandoffPayloadSchema>;

// 2. 专业子智能体接口规范
export interface SubAgent {
  agentId: string;
  agentName: string;
  description: string;
  executeTask(payload: HandoffPayload): Promise<HandoffResult>;
}

export interface HandoffResult {
  isComplete: boolean;
  nextHandoff?: HandoffPayload;
  finalOutput?: string;
}

// 3. 多智能体交接编排调度器（Supervisor Orchestrator）
export class MultiAgentOrchestrator {
  private registeredAgents = new Map<string, SubAgent>();
  private maxAllowedHops = 5;

  // 注册专业子智能体
  public registerAgent(agent: SubAgent): void {
    this.registeredAgents.set(agent.agentId, agent);
  }

  // 执行协同任务调度主循环
  public async dispatchHandoff(initialPayload: HandoffPayload): Promise<string> {
    let currentPayload = HandoffPayloadSchema.parse(initialPayload);

    while (currentPayload.hopCount <= this.maxAllowedHops) {
      const targetAgent = this.registeredAgents.get(currentPayload.targetAgentId);
      if (!targetAgent) {
        throw new Error(`目标智能体 [${currentPayload.targetAgentId}] 未注册或离线，调度中断`);
      }

      // 防范死循环交接（检测路径环路）
      const cycleCount = currentPayload.visitedHistory.filter(id => id === currentPayload.targetAgentId).length;
      if (cycleCount >= 2) {
        throw new Error(`检测到交接环路：智能体 [${currentPayload.targetAgentId}] 访问频次异常，触发熔断保护`);
      }

      console.log(`[Hand-off 转移] 第 ${currentPayload.hopCount + 1} 跳: ${currentPayload.sourceAgentId} -> ${currentPayload.targetAgentId}`);

      // 执行子智能体专业任务（仅注入最小必要状态）
      const result: HandoffResult = await targetAgent.executeTask(currentPayload);

      // 任务圆满完成，跳出循环
      if (result.isComplete) {
        return result.finalOutput || '协同任务执行完毕';
      }

      // 任务需继续向下游移交
      if (!result.nextHandoff) {
        throw new Error(`智能体 [${currentPayload.targetAgentId}] 既未标记完成，亦未提供下一移交载荷`);
      }

      // 组装并校验下一跳载荷（更新跳数与路径栈）
      currentPayload = HandoffPayloadSchema.parse({
        ...result.nextHandoff,
        hopCount: currentPayload.hopCount + 1,
        visitedHistory: [...currentPayload.visitedHistory, currentPayload.targetAgentId],
      });
    }

    throw new Error('协同调度超出最大跳数安全限制，强制降级至人工审核');
  }
}