ruflo hive-mind:Queen 主导的共识式多智能体蜂群协调系统实战指南
2026/9/8 19:37:58 网站建设 项目流程

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 个:initspawnstatustaskjoinleaveconsensusbroadcastmemoryoptimize-memoryshutdown,命令别名是hive。下文按"初始化 → 生成 → 监控 → 协作 → 生命周期"的顺序逐一展开。

二、init:拓扑与共识算法决定蜂群形态

init子命令通过 MCP 工具hive-mind_init创建蜂群基础设施。源码中定义了两组关键枚举(TOPOLOGIES / CONSENSUS_STRATEGIES):

拓扑(topology)

取值含义
hierarchicalQueen 领导 + worker 的层级结构
mesh对等(peer-to-peer)协调
hierarchical-meshQueen + 对等通信,默认值,官方推荐
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>记忆后端:agentdbsqlitehybridhybrid

交互模式下如果不传--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>-rworker 角色:worker/specialist/scoutworker
--type <type>-t智能体类型worker
--prefix <prefix>-pworker 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 Codefalse
--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(传入countroleagentTypeprefix),返回spawnedworkers[](含agentIdrolejoinedAt)、totalWorkers等字段,CLI 随后以表格形式打印每个新 worker 的 ID、角色、状态(初始为idle)与加入时间(spawn action)。

3.2--claude模式:自动生成 Queen 协调提示词

--claude后,CLI 会走一条完整的"提示词生成 → 落盘 → 拉起 Claude Code"链路(spawnClaudeCodeInstance):

  1. 生成协调提示词。generateHiveMindPrompt 生成一份完整的 "Queen coordinator" 系统提示词,内容包含:Swarm ID / 目标 / Queen Type(缺省strategic)/ 拓扑(缺省hierarchical-mesh)/ 共识算法(缺省byzantine)、按类型分组的 worker 分布,以及一套 Hive Mind 执行协议(初始化 → 任务分发 → 协调 → 收尾四阶段)。提示词中还内嵌了可用 MCP 工具清单,如hive-mind_consensushive-mind_memoryhive-mind_broadcasthive-mind_statustask_createagent_spawn等,并要求所有编排操作优先走mcp__ruflo__*工具。
  2. 提示词落盘。写入.hive-mind/sessions/hive-mind-prompt-<swarmId>.txt,这是后续resume能力的基础(见第七节)。
  3. 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>等号语法。
  4. 权限与交互控制--dangerously-skip-permissions采用严格布尔判断(=== true)避免undefined被误判为跳过权限,且--no-auto-permissions是否定开关,可覆盖前者(权限判断)。--non-interactive会给子进程追加-p --output-format stream-json --verbose
  5. 等待子进程退出。源码注释(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|nonetimeout:<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-2

consensus子命令统一封装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.env

memory子命令封装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-backendagentdb/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 实现中映射为三套机制:

  1. 暂停--claude会话运行时按Ctrl+C,CLI 注册的 SIGINT/SIGTERM 处理器会以SIGTERM终止 Claude Code 子进程,提示"Session paused",并打印提示词文件位置与恢复方式——"To resume, run claude with the saved prompt file"(SIGINT 处理)。
  2. 恢复:提示词已持久化在.hive-mind/sessions/hive-mind-prompt-<swarmId>.txt,恢复即是用该文件重新启动claude会话;会话目录管理文档见 hive-mind-sessions.md。子进程以stdio: inherit继承终端、shell: false直接执行(Windows 下由resolveClaudeLaunchCommand跟随 npm shim 定位真实可执行入口),退出码 0 才算成功。
  3. 关闭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_inithive-mind_spawnhive-mind_statushive-mind_broadcasthive-mind_consensushive-mind_memoryhive-mind_shutdownhive-mind_joinhive-mind_leavehive-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),仅供参考

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询