深度解析gh_mirrors/cl/claude-code-by-agents的多智能体通信机制与实现原理【免费下载链接】claude-code-by-agentsDesktop app and API created in public for multi-agent Claude Code orchestration - coordinate local and remote agents through mentions.项目地址: https://gitcode.com/gh_mirrors/cl/claude-code-by-agents在当今AI智能体协作的浪潮中Claude Code Agentrooms项目以其独特的多智能体通信架构脱颖而出。这个桌面应用和API为多智能体Claude Code编排提供了完整的解决方案让本地和远程智能体能够通过mention机制进行高效协作。本文将深入探讨这一系统的通信机制与实现原理为您揭示其背后的技术架构。项目概述与核心架构Claude Code Agentrooms是一个基于OpenAgents Go框架的SwiftUI原生应用支持macOS 15和iOS 18平台。它的核心使命是为多个编码智能体提供一个统一的协作空间让开发者能够像管理团队成员一样管理不同的AI助手。图1Claude Code Agentrooms的macOS界面采用iMessage风格的双面板布局系统采用三层架构设计知识层OpenAgents工作空间后端负责事件存储、通道管理和历史记录交互层Agentrooms应用本身负责路由消息、渲染UI并维护线程状态智能体层通过openagents-org/agent-connector运行的各种运行时智能体多智能体通信的核心机制1. 基于事件的通信模型项目的通信核心围绕事件系统构建。在OpenAgents/Networking/WorkspaceAPI.swift中sendEvent方法定义了事件发送的基本结构func sendEvent( type: String, source: String, target: String, payload: [String: any Encodable Sendable]? nil, visibility: String? nil ) async throws - ONMEvent事件类型包括workspace.message.posted用户或智能体发送的消息workspace.agent.control控制智能体的操作停止、重启等network.channel.join/leave智能体加入或离开通道workspace.tool_resultUI交互结果回传2. mention路由机制智能体路由的核心是agent-name提及系统。当用户在聊天中输入backend 添加健康检查端点时系统会解析消息内容识别所有提及的智能体名称通过mentions字段将消息路由到指定智能体智能体接收到消息后在自己的上下文中处理请求这种设计允许用户同时与多个智能体协作例如前端 更新登录页面然后后端 连接新的认证路由。3. 自适应轮询策略智能体状态和消息更新采用智能轮询机制在OpenAgents/State/WorkspaceStore.swift中实现private func startPolling() { pollTask Task { [weak self] in while !Task.isCancelled { let interval await self.hasActiveAgents ? 5 : 15 try? await Task.sleep(for: .seconds(interval)) await self.refreshDiscovery() await self.refreshPreviews() } } messagePollTask Task { [weak self] in while !Task.isCancelled { let interval: Double await self.hasActiveAgents ? 1.5 : 3 try? await Task.sleep(for: .seconds(interval)) if let id self.currentSessionId { await self.pollNewMessages(channel: id) } } } }轮询策略特点活跃智能体消息轮询1.5秒发现轮询5秒非活跃状态消息轮询3秒发现轮询15秒根据智能体在线状态动态调整平衡实时性与资源消耗4. 智能体发现与状态管理系统通过/v1/discover端点定期发现可用智能体。在OpenAgents/Models/Agent.swift中定义的智能体模型包含agentName智能体唯一标识符role角色master/participantstatus在线状态serverHost服务器地址lastHeartbeatAt最后心跳时间图2iOS版应用界面展示智能体列表和会话管理消息传递与状态同步1. 乐观更新机制为了提高用户体验系统采用乐观更新策略。当用户发送消息时立即在本地UI中显示然后异步发送到后端func sendMessage(_ content: String, attachments: [PendingAttachment] []) async { let optimistic Message( messageId: optimistic-\(UUID().uuidString), sessionId: channel, senderType: human, senderName: user, content: content, mentions: mentions, messageType: chat, timestamp: Int64(Date().timeIntervalSince1970 * 1000), attachment: nil ) // 立即添加到本地消息列表 pagesBySession[channel]?.messages.append(optimistic) // 异步发送到后端 let event try await api.sendMessage(channel: channel, content: finalContent) }2. 消息分页与历史记录系统支持消息分页加载在OpenAgents/State/WorkspaceStore.swift中实现func loadHistory(channel: String) async { let batch try await api.loadMessages( channel: channel, sort: desc, limit: initialPageSize, // 初始加载50条 ) } func pollNewMessages(channel: String) async { let batch try await api.loadMessages( channel: channel, after: page.newestId, // 只获取新消息 sort: asc, limit: 50 ) }3. 智能体控制命令系统提供多种智能体控制命令通过sendAgentControl方法实现停止命令向所有智能体发送停止信号重启命令清除智能体的会话状态状态查询获取智能体运行状态例行程序列出智能体的活动任务生成式UI与交互反馈1. A2UI规范渲染智能体可以发送结构化UI规范payload.spec客户端通过OpenAgents/Rendering/A2UIRendererView.swift渲染struct A2UIAttachment: Sendable, Equatable { let json: String // 原始UI规范 let toolCallId: String? // 工具调用ID }2. 工具结果回传当用户与渲染的UI交互时系统通过sendToolResult方法将结果传回智能体func sendToolResult( channel: String, toolCallId: String?, actionId: String, value: JSONValue? ) async { _ try await api.sendToolResult( channel: channel, toolCallId: toolCallId, actionId: actionId, value: value ) }会话管理与智能体协调1. 会话状态维护每个会话在OpenAgents/Models/Session.swift中定义sessionId会话唯一标识participants参与智能体列表master主智能体starred是否星标lastEventAt最后活动时间2. 智能体加入/离开机制系统支持动态调整会话参与者func addAgentToSession(sessionId: String, agentName: String) async { // 乐观更新本地状态 sessions[idx] Session( participants: s.participants [agentName], // ... 其他字段 ) // 发送网络事件 _ try await api.addAgentToChannel( channelName: sessionId, agentName: agentName ) }错误处理与恢复机制1. 网络错误处理系统采用多层错误处理策略网络传输错误重试机制HTTP状态码错误适当降级解码错误日志记录并跳过无效数据2. 状态一致性保证通过乐观更新与后端验证相结合确保状态一致性本地立即更新UI异步发送到后端轮询时验证并修正状态失败时回滚并显示错误性能优化策略1. 智能轮询间隔根据智能体活跃状态动态调整轮询频率活跃会话1.5秒消息轮询非活跃会话3秒消息轮询智能体发现5-15秒自适应2. 消息批处理系统批量处理消息更新减少不必要的UI重绘for new in newOnes { if let idx page.messages.firstIndex(where: { $0.messageId new.messageId }) { page.messages[idx] new // 更新现有消息 } else { page.messages.append(new) // 添加新消息 } }3. 内存优化消息分页加载避免内存膨胀智能体状态缓存减少网络请求图片和文件懒加载安全与认证机制1. 工作空间令牌认证所有API请求都包含X-Workspace-Token头if !token.isEmpty { request.setValue(token, forHTTPHeaderField: X-Workspace-Token) }2. 智能体身份验证每个智能体通过agent-connector进行身份验证Claude智能体OAuth流程自定义智能体API密钥或令牌工作空间级别的访问控制扩展性与未来展望1. 多运行时支持架构设计支持多种运行时Claude Code当前主要支持Codex智能体自定义运行时MCP支持的智能体2. 多平台适配macOS原生应用iOS移动端支持统一的SwiftUI代码库响应式布局设计3. 插件系统规划未来的扩展方向包括自定义UI组件第三方工具集成工作流自动化数据分析插件总结Claude Code Agentrooms的多智能体通信机制代表了现代AI协作平台的前沿设计。通过基于事件的通信模型、智能路由机制、自适应轮询策略和生成式UI渲染系统实现了高效、可靠、可扩展的智能体协作环境。核心优势去中心化架构每个智能体独立运行无单点故障实时协作自适应轮询确保及时的状态同步灵活扩展支持多种运行时和自定义智能体优秀体验乐观更新、生成式UI、多平台支持技术亮点SwiftUI原生应用性能优异三层架构职责分离清晰事件驱动的通信模型智能的状态管理策略随着AI智能体技术的不断发展这种基于工作空间的多智能体协作模式将为开发者提供更强大、更灵活的编码助手生态系统。无论是个人开发者还是团队协作Claude Code Agentrooms都提供了一个理想的平台来协调和管理多个AI助手的工作流程。【免费下载链接】claude-code-by-agentsDesktop app and API created in public for multi-agent Claude Code orchestration - coordinate local and remote agents through mentions.项目地址: https://gitcode.com/gh_mirrors/cl/claude-code-by-agents创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考