ruflo hive-mind:Queen 主导的共识式多智能体蜂群协调系统实战指南
【免费下载链接】ruflo🌊 The original agent meta-harness. Deploy intelligent multi-player swarms, coordinate autonomous workflows, and build conversational AI systems. Features adaptive memory, self-learning intelligence, RAG integration, and native Claude Code / Codex / Hermes and many more Integrated项目地址: https://gitcode.com/GitHub_Trending/cl/ruflo
本文围绕 ruflo 仓库中hive-mind命令文档展开,系统讲解 Hive Mind 集体智能系统的完整命令行用法:从初始化蜂群拓扑、选择共识算法,到批量生成 worker 智能体、以--claude模式启动 Claude Code 协调会话,再到状态监控、任务提交、共识投票、共享内存与优雅关闭。读完本文,你可以基于 ruflo 的 MCP 工具链在本地跑起一套"Queen 协调 + 多 worker 并行"的多智能体工作流,并理解每条 CLI 命令背后的源码实现与 MCP 工具调用链。
一、hive-mind 是什么
ruflo 的hive-mind是一个面向高级 swarm 协调的集体智能系统(collective intelligence system for advanced swarm coordination),其核心设计是"Queen-led consensus-based multi-agent coordination"——由一个 Queen 协调者智能体领导整个蜂群,worker 之间通过可配置的共识算法做决策。官方命令文档位于 hive-mind.md,同目录下还有 init、spawn 等子命令的详细文档,索引见 hive-mind 命令 README。
基本调用方式为:
npx claude-flow hive-mind [subcommand] [options]文档列出的核心子命令为:
| 子命令 | 作用 |
|---|---|
init | 初始化 hive mind 系统 |
spawn | 生成(spawn)hive mind 蜂群 |
status | 查看 hive mind 状态 |
resume | 恢复暂停的会话 |
stop | 停止运行中的会话 |
官方给出的典型示例:
# Initialize hive mind npx claude-flow hive-mind init # Spawn swarm npx claude-flow hive-mind spawn "Build microservices" # Check status npx claude-flow hive-mind status从源码结构看,当前 v3 CLI 的实际实现比文档骨架更丰富。hive-mind.ts 中注册的子命令共 11 个:init、spawn、status、task、join、leave、consensus、broadcast、memory、optimize-memory、shutdown,命令别名是hive。下文按"初始化 → 生成 → 监控 → 协作 → 生命周期"的顺序逐一展开。
二、init:拓扑与共识算法决定蜂群形态
init子命令通过 MCP 工具hive-mind_init创建蜂群基础设施。源码中定义了两组关键枚举(TOPOLOGIES / CONSENSUS_STRATEGIES):
拓扑(topology):
| 取值 | 含义 |
|---|---|
hierarchical | Queen 领导 + worker 的层级结构 |
mesh | 对等(peer-to-peer)协调 |
hierarchical-mesh | Queen + 对等通信,默认值,官方推荐 |
adaptive | 根据任务动态选择拓扑 |
共识策略(consensus):
| 取值 | 含义 |
|---|---|
byzantine | 拜占庭容错,2/3 多数,可应对恶意节点,默认值 |
raft | 基于 Leader 的共识 |
gossip | 最终一致性,可扩展性好 |
crdt | 无冲突复制数据类型 |
quorum | 简单多数投票 |
init的完整参数(摘自 initCommand 定义):
claude-flow hive-mind init -t hierarchical-mesh -c byzantine -m 15 -p --memory-backend hybrid| 选项 | 短写 | 说明 | 默认值 |
|---|---|---|---|
--topology <topology> | -t | 蜂群拓扑,取值见上表 | hierarchical-mesh |
--consensus <strategy> | -c | 共识策略,取值见上表 | byzantine |
--max-agents <n> | -m | 最大智能体数量 | 15 |
--persist/ 布尔 | -p | 是否持久化状态 | true |
--memory-backend <backend> | 记忆后端:agentdb、sqlite、hybrid | hybrid |
交互模式下如果不传--topology/--consensus,CLI 会弹出选择菜单让用户挑选(action 逻辑)。初始化成功后会输出 Hive ID、Queen ID、拓扑、共识策略、最大 agent 数与记忆后端的配置框,并提示"Queen agent is ready to coordinate worker agents"。--format json可直接输出hive-mind_init的原始结果,便于脚本消费。
命令文档中的--force(强制重新初始化)与--config <file>(指定配置文件)属于 init 的扩展选项,见 hive-mind-init.md。
三、spawn:从生成 worker 到启动 Claude Code 协调会话
spawn是 hive-mind 最核心的子命令。文档(hive-mind-spawn.md)描述其职责为"Spawn a Hive Mind swarm with queen-led coordination",并列出--queen-type(strategic / tactical / adaptive)、--max-workers <n>、--consensus <type>、--claude等选项。v3 源码中的实际参数表(spawnCommand 定义):
| 选项 | 短写 | 说明 | 默认值 |
|---|---|---|---|
--count <n> | -n | 生成 worker 数量 | 1 |
--role <role> | -r | worker 角色:worker/specialist/scout | worker |
--type <type> | -t | 智能体类型 | worker |
--prefix <prefix> | -p | worker ID 前缀 | hive-worker |
--claude | 生成带 hive-mind 协调提示词的 Claude Code 会话 | false | |
--objective <obj> | -o | 蜂群目标(配合--claude) | 无 |
--dangerously-skip-permissions | 跳过 Claude Code 权限确认 | true | |
--no-auto-permissions | 关闭自动跳过权限 | false | |
--dry-run | 只展示将执行的动作,不实际启动 | false | |
--non-interactive | 非交互模式运行 Claude Code | false | |
--mcp-config <path> | 传给 worker 的.mcp.json路径,可自动探测 | 自动探测 |
常用示例(源码内建 examples):
claude-flow hive-mind spawn -n 5 claude-flow hive-mind spawn -n 3 -r specialist claude-flow hive-mind spawn -t coder -p my-coder claude-flow hive-mind spawn --claude -o "Build a REST API" claude-flow hive-mind spawn -n 5 --claude -o "Research AI patterns"3.1 MCP 工具调用链
spawn先调用 MCP 工具hive-mind_spawn(传入count、role、agentType、prefix),返回spawned、workers[](含agentId、role、joinedAt)、totalWorkers等字段,CLI 随后以表格形式打印每个新 worker 的 ID、角色、状态(初始为idle)与加入时间(spawn action)。
3.2--claude模式:自动生成 Queen 协调提示词
加--claude后,CLI 会走一条完整的"提示词生成 → 落盘 → 拉起 Claude Code"链路(spawnClaudeCodeInstance):
- 生成协调提示词。generateHiveMindPrompt 生成一份完整的 "Queen coordinator" 系统提示词,内容包含:Swarm ID / 目标 / Queen Type(缺省
strategic)/ 拓扑(缺省hierarchical-mesh)/ 共识算法(缺省byzantine)、按类型分组的 worker 分布,以及一套 Hive Mind 执行协议(初始化 → 任务分发 → 协调 → 收尾四阶段)。提示词中还内嵌了可用 MCP 工具清单,如hive-mind_consensus、hive-mind_memory、hive-mind_broadcast、hive-mind_status、task_create、agent_spawn等,并要求所有编排操作优先走mcp__ruflo__*工具。 - 提示词落盘。写入
.hive-mind/sessions/hive-mind-prompt-<swarmId>.txt,这是后续resume能力的基础(见第七节)。 - MCP 配置解析。这是排障重点:源码注释记录了两个真实修复。其一,issue #1748——若不给 worker 传
--mcp-config,生成的提示词会引用 worker 根本不认识的mcp__ruflo__*工具,导致其静默退出;解析顺序为:显式--mcp-config标志 → 当前目录./.mcp.json→~/.claude.json→~/.claude/mcp.json(配置探测逻辑)。其二,issue #1780——Claude Code 的--mcp-config是可变参数,按两个 argv token 传递会把后面的提示词文本误吞成第二个配置文件路径,触发ENAMETOOLONG,因此源码改用--mcp-config=<path>等号语法。 - 权限与交互控制。
--dangerously-skip-permissions采用严格布尔判断(=== true)避免undefined被误判为跳过权限,且--no-auto-permissions是否定开关,可覆盖前者(权限判断)。--non-interactive会给子进程追加-p --output-format stream-json --verbose。 - 等待子进程退出。源码注释(issue #2297)说明:如果不 await 子进程退出,CLI 主进程会提前结束,正在初始化的
claude子进程会丢失控制终端而在启动中途被杀,表现为下一个 shell 提示符前泄漏出多余的XTVERSION回复;修复后还会让非交互路径只在 Claude Code 真正完成后才返回。
--dry-run模式下不会真正拉起进程,只打印提示词长度与前 500 字符预览,并告知完整提示词已保存的位置,适合先检查生成的 Queen 提示词是否合理。
若 PATH 中找不到 Claude Code CLI,CLI 会降级为"手动执行说明":提示npm install -g @anthropic-ai/claude-code,并给出claude < <promptFile>、cat <promptFile> | claude等手动喂入提示词的命令。即使生成协调提示词的过程抛异常,CLI 也会把提示词兜底写入hive-mind-prompt-<swarmId>-fallback.txt,保证产物不丢(fallback 分支)。
四、status:蜂群健康度与指标面板
status子命令调用 MCP 工具hive-mind_status,默认展示一块"Hive Mind Status"信息框:Hive ID、整体状态、拓扑、共识算法,以及 Queen 的状态 / 负载(百分比)/ 排队任务数(status action)。随后以表格列出所有 worker:ID、类型、状态、当前任务、已完成任务数;worker 列表为空时会提示用spawn添加。
参数与进阶输出:
claude-flow hive-mind status # 基本状态 claude-flow hive-mind status -d # 附带详细指标 claude-flow hive-mind status -w # 监听变化加-d(--detailed)后会额外输出两张面板(指标与健康检查):
- Metrics:Total Tasks、Completed、Failed、Avg Task Time(ms)、Consensus Rounds、Memory Usage;
- Health:Overall / Queen / Workers / Consensus / Memory 五维健康度,按
healthy(绿)、warning/degraded(黄)、critical(红)着色。
源码对 MCP 返回做了兼容处理:状态值兼容active | idle | degraded | offline | running | stopped,worker 条目既可能是对象也可能是纯 ID 字符串,都能正常渲染。
五、task / broadcast / consensus / join / leave:蜂群协作原语
5.1 task:向蜂群提交任务
claude-flow hive-mind task -d "Implement auth module" claude-flow hive-mind task -d "Security review" -p critical -c参数:-d任务描述(必填,也可用位置参数)、-p优先级(low/normal/high/critical,默认normal)、-c要求共识完成后才算完成、--timeout超时秒数(默认300)(taskCommand)。
这里有一个值得注意的实现细节:源码注释(issue #1791.1)指出hive-mind_task从未在捆绑的 MCP 服务器中注册过(mcp__ruflo__hive-mind_*表面只暴露 init、spawn、status、broadcast、consensus、memory、shutdown、leave 这些工具),CLI 早期直接分发到不存在的工具,报MCP tool not found: hive-mind_task。现在的做法是改道到已有的task_create工具:type固定为hive-mind,蜂群专属选项以consensus:required|none与timeout:<n>s标签形式保留在tags中,数据不丢失,等待未来的专用 hive-mind worker 工具接棒(重路由逻辑)。提交成功后提示用claude-flow hive-mind task-status <taskId>跟踪进度。
5.2 broadcast:全蜂群广播
claude-flow hive-mind broadcast -m "Switch to branch feat/x" -p high -f queen-1调用hive-mind_broadcast,参数为-m消息(必填)、-p优先级(low/normal/high/critical,默认normal)、-f发送者 agent ID;成功输出会给出消息 ID 与接收 worker 数(broadcastCommand)。
5.3 consensus:提案与投票
claude-flow hive-mind consensus -a list claude-flow hive-mind consensus -a propose -t decision --value "use raft" claude-flow hive-mind consensus -a vote -p <proposalId> -v yes --voter-id agent-2consensus子命令统一封装hive-mind_consensus工具,-a支持propose/vote/status/list四种动作(默认list,打印 Pending Proposals 表格);-v yes/no会在 CLI 侧归一化为布尔值传入(consensusCommand)。这与 init 阶段选择的共识算法(如byzantine的 2/3 多数)配合,构成蜂群的关键决策通道。
5.4 join / leave:动态调整成员
claude-flow hive-mind join -a agent-42 -r specialist claude-flow hive-mind leave -a agent-42分别调用hive-mind_join(可带-r角色,返回totalWorkers)与hive-mind_leave(返回remainingWorkers)(join/leave),对应提示词中的hive-mind_join/hive-mind_leaveMCP 工具,支持运行中增减 worker。
六、memory / optimize-memory:共享记忆与模式优化
6.1 memory:读写共享记忆
claude-flow hive-mind memory -a list claude-flow hive-mind memory -a set -k deploy.env -v "staging" claude-flow hive-mind memory -a get -k deploy.env claude-flow hive-mind memory -a delete -k deploy.envmemory子命令封装hive-mind_memory工具,-a支持get/set/delete/list(默认list,打印全部 key),-k为键、-v为值;参数校验保证 get/delete 必须带 key,set 必须同时带 key 和 value(memorySubCommand)。共享记忆是 Queen 执行协议中"COMPLETION PHASE:Store learnings in collective memory"的落地载体,配合 init 时的--memory-backend(agentdb/sqlite/hybrid)决定底层存储形态。
6.2 optimize-memory:压缩与合并模式
claude-flow hive-mind optimize-memory -a --threshold 0.7调用hive-mind_optimize-memory,参数-a(--aggressive激进优化)与--threshold(模式保留质量阈值,默认0.7)。返回 before/after 对照表(Patterns 数、Memory 占用),以及被删除、被合并的模式数与优化耗时(optimizeMemoryCommand)。长时间运行的蜂群可以定期执行该子命令控制记忆膨胀。
七、会话生命周期:暂停(pause)、恢复(resume)与关闭(shutdown)
命令文档中的resume/stop语义在 v3 实现中映射为三套机制:
- 暂停:
--claude会话运行时按Ctrl+C,CLI 注册的 SIGINT/SIGTERM 处理器会以SIGTERM终止 Claude Code 子进程,提示"Session paused",并打印提示词文件位置与恢复方式——"To resume, run claude with the saved prompt file"(SIGINT 处理)。 - 恢复:提示词已持久化在
.hive-mind/sessions/hive-mind-prompt-<swarmId>.txt,恢复即是用该文件重新启动claude会话;会话目录管理文档见 hive-mind-sessions.md。子进程以stdio: inherit继承终端、shell: false直接执行(Windows 下由resolveClaudeLaunchCommand跟随 npm shim 定位真实可执行入口),退出码 0 才算成功。 - 关闭:
shutdown子命令调用hive-mind_shutdown,参数-f(--force强制关闭)与-s(--save-state,默认true,关闭前保存状态)。非强制模式下会先弹确认框"Shutdown the hive mind? All agents will be terminated.";完成后输出终止的 agent 数、状态是否已保存、关闭时间点(shutdownCommand)。
八、MCP 工具面与源码验证
从源码结构看,CLI 只是薄封装:每个子命令的action都通过callMCPTool把参数转发给对应 MCP 工具,真正的蜂群状态、共识与记忆逻辑运行在 ruflo 的 MCP 服务器端(MCP 侧工具定义见 hive-mind-tools.ts)。hive-mind.ts源码注释中可确认的 MCP 工具面为:hive-mind_init、hive-mind_spawn、hive-mind_status、hive-mind_broadcast、hive-mind_consensus、hive-mind_memory、hive-mind_shutdown、hive-mind_join、hive-mind_leave、hive-mind_optimize-memory,任务提交则复用通用task_create工具。所有错误路径都区分MCPClientError(服务端报错,直接打印消息)与未知异常,失败时返回exitCode: 1,适合接入 CI 脚本。相关行为还有专门测试覆盖,如 hive-mind-skip-permissions.test.ts 验证权限跳过标志的边界行为。
九、完整工作流速查
# 1. 初始化:hierarchical-mesh 拓扑 + 拜占庭容错共识,最多 15 个 agent npx claude-flow hive-mind init -t hierarchical-mesh -c byzantine -m 15 # 2. 生成 5 个 worker,并以 Claude Code 启动 Queen 协调会话 npx claude-flow hive-mind spawn -n 5 --claude -o "Build microservices" # 3. 查看状态(含指标与健康度) npx claude-flow hive-mind status -d # 4. 协作操作 npx claude-flow hive-mind task -d "Implement auth module" -p high -c npx claude-flow hive-mind broadcast -m "Review style guide first" -p normal npx claude-flow hive-mind consensus -a list # 5. 收尾:优化记忆后保存状态并关闭 npx claude-flow hive-mind optimize-memory -a npx claude-flow hive-mind shutdown -s适用前提与限制:--claude模式要求本机已安装 Claude Code CLI(npm install -g @anthropic-ai/claude-code),且建议项目内有.mcp.json(或运行过ruflo init生成),否则 worker 拿不到mcp__ruflo__*工具;--dangerously-skip-permissions默认开启,在生产环境中建议显式传--no-auto-permissions恢复逐条确认。文档骨架(init/spawn/status/resume/stop)与源码实现的完整子命令集对照后,读者可以按本文路径继续深入 hive-mind.ts 源码 与同目录下的 consensus 文档、memory 文档、metrics 文档 等文件,获得参数级的细节补充。
【免费下载链接】ruflo🌊 The original agent meta-harness. Deploy intelligent multi-player swarms, coordinate autonomous workflows, and build conversational AI systems. Features adaptive memory, self-learning intelligence, RAG integration, and native Claude Code / Codex / Hermes and many more Integrated项目地址: https://gitcode.com/GitHub_Trending/cl/ruflo
创作声明:本文部分内容由AI辅助生成(AIGC),仅供参考