Agent技能设计模式实战：ADK开发者必知的5大核心模式

7次阅读

共计 1957 个字符，预计需要花费 5 分钟才能阅读完成。

最近在开发智能语音助手时，我遇到了一个典型问题：当用户说 ” 播放音乐并设置闹钟 ” 时，音乐技能和闹钟技能会因为共享同一个状态管理器而互相干扰。比如音乐暂停时意外触发了闹钟关闭，这种紧耦合的架构让调试变得异常痛苦。更糟的是，每次新增技能都需要修改核心调度器代码，团队迭代效率直线下降。

模式名称	适用场景	优势	劣势
Observer/ 观察者	技能间事件通知（如天气触发穿衣建议）	解耦事件源和接收方	需注意内存泄漏
Strategy/ 策略	多算法切换（如 NLP 解析引擎）	运行时动态替换	增加对象数量
State/ 状态	技能生命周期管理（如空闲 / 忙碌）	状态转移显式化	复杂状态类爆炸
Decorator/ 装饰器	技能功能叠加（如日志 + 权限校验）	灵活组合功能	调用栈过深
Chain of Responsibility/ 责任链	意图识别流水线	动态调整处理顺序	可能漏处理

/**
 * 事件总线接口（核心契约）* @template T 事件类型约束
 */
interface IEventBus<T> {subscribe(observer: IObserver<T>): void;
  unsubscribe(observer: IObserver<T>): void;
  notify(event: T): Promise<void>;
}

// 具体实现（含 DI 示例）class SkillEventBus implements IEventBus<SkillEvent> {private observers = new Set<IObserver<SkillEvent>>();

  constructor(@inject(Logger) private logger: ILogger) {}

  async notify(event: SkillEvent) {
    try {
      await Promise.all([...this.observers].map(obs => 
          obs.update(event).catch(e => this.logger.error(e))
        )
      );
    } catch (e) {this.logger.error(`Notification failed: ${e}`);
    }
  }
}

相关单元测试片段：

it('should handle observer errors gracefully', async () => {const faultyObserver = { update: () => Promise.reject('mock error') };
  bus.subscribe(faultyObserver);
  await expect(bus.notify(testEvent)).resolves.not.toThrow();});

UML 简图：

[Context] <>-- [IProcessingStrategy]
                      ^
                      |
        --------------------------
        |                        |
[FastTextStrategy]      [BERTStrategy]

关键实现：

// 策略接口
interface IProcessingStrategy {parse(utterance: string): Promise<Intent>;
}

// 上下文类（含热加载支持）class NLPCore {
  private strategy: IProcessingStrategy;

  // 使用工厂方法注入策略
  reloadStrategy(newStrategy: IProcessingStrategy) {
    // 双缓冲确保线程安全
    this.strategy = newStrategy;
  }
}