10.1 多智能体通信拓扑与协作范式：集中式、流水线与辩论博弈

// multi-agent-cluster.ts
import { OpenAI } from 'openai';
 
export interface WorkerResult {
  role: string;
  output: string;
}
 
export class MultiAgentCluster {
  private client = new OpenAI();
 
  /**
   * 集中式并发派发与汇总
   */
  async executeComplexProject(taskGoal: string): Promise<string> {
    console.log(`[Manager Agent] 接收到大型项目需求: "${taskGoal}"，开始并发分派专业子任务...`);
 
    // 并发启动两个垂直专业子智能体
    const [frontendResult, backendResult] = await Promise.all([
      this.runWorker('Frontend_Dev', '你是一位前端专家，请设计 Next.js 页面结构与交互表单。', taskGoal),
      this.runWorker('Backend_Dev', '你是一位后端专家，请设计 PostgreSQL 表结构与 REST API 规范。', taskGoal),
    ]);
 
    console.log('[Manager Agent] 各专业子任务已交付，开始执行综合集成审查...');
 
    // 汇总收敛
    const finalReport = await this.synthesizeResults(taskGoal, [frontendResult, backendResult]);
    return finalReport;
  }
 
  private async runWorker(role: string, systemPrompt: string, task: string): Promise<WorkerResult> {
    const res = await this.client.chat.completions.create({
      model: 'gpt-4o-mini',
      messages: [
        { role: 'system', content: systemPrompt },
        { role: 'user', content: task },
      ],
    });
    return { role, output: res.choices[0].message.content || '' };
  }
 
  private async synthesizeResults(goal: string, results: WorkerResult[]): Promise<string> {
    const prompt = `
项目总体目标: ${goal}
 
以下是下属专业工程师分别交付的子方案：
${results.map((r) => `=== [角色: ${r.role}] ===\n${r.output}`).join('\n\n')}
 
请作为 Tech Lead 进行全局综合评审，消除前后端接口不一致的矛盾点，输出最终统一的工程实施方案。
`;
    const res = await this.client.chat.completions.create({
      model: 'gpt-4o',
      messages: [{ role: 'user', content: prompt }],
    });
    return res.choices[0].message.content || '';
  }
}