智能体循环(OpenClaw?

智能体循环是智能体的完整”真实”运行:接??上下文组??模型推理 ? 工具执行 ?流式回复 ?持久化。它是将消息转化为动作和最终回复的权威路径,同时保持会话状态一致?

?OpenClaw 中,循环是每个会话的单一序列化运行,当模型思考、调用工具和流式输出时发出生命周期和流事件。本文档解释了这个真实循环是如何端到端连接的?

入口?

  • 网关 RPC:agent ?agent.wait?
  • CLI:agent 命令?

工作原理(高级)

  1. agent RPC 验证参数,解析会话(sessionKey/sessionId),持久化会话元数据,立即返?{ runId, acceptedAt }?
  2. agentCommand 运行智能体:
    • 解析模型 + 思?详细默认?
    • 加载技能快?
    • 调用 runEmbeddedPiAgent(pi-agent-core 运行时)
    • 如果嵌入循环未发出,则发?生命周期结束/错误*
  3. runEmbeddedPiAgent?
    • 通过每个会话 + 全局队列序列化运?
    • 解析模型 + 认证配置文件并构?pi 会话
    • 订阅 pi 事件并流式传输助?工具增量
    • 强制超时 ?超时则中止运?
    • 返回有效载荷 + 使用元数?
  4. subscribeEmbeddedPiSession ?pi-agent-core 事件桥接?OpenClaw agent 流:
    • 工具事件 => stream: "tool"
    • 助手增量 => stream: "assistant"
    • 生命周期事件 => stream: "lifecycle"phase: "start" | "end" | "error"?
  5. agent.wait 使用 waitForAgentJob?
    • 等待 runId ?生命周期结束/错误*
    • 返回 { status: ok|error|timeout, startedAt, endedAt, error? }

队列 + 并发

  • 运行按会话键(会话车道)序列化,可选地通过全局车道?
  • 这防止了工具/会话竞态并保持会话历史一致?
  • 消息频道可以选择队列模式(收?引导/后续),这些模式馈入此车道系统? 参见 命令队列?

会话 + 工作区准?

  • 工作区被解析并创建;沙盒运行可能重定向到沙盒工作区根目录?
  • 技能被加载(或从快照重用)并注入到环境和提示中?
  • 引导/上下文文件被解析并注入到系统提示报告中?
  • 在流式传输之前获取会话写锁;SessionManager 被打开并准备就绪?

提示组装 + 系统提示

  • 系统提示?OpenClaw 的基础提示、技能提示、引导上下文和每运行覆盖构建?
  • 强制执行模型特定限制和压缩保留令牌?
  • 参见 系统提示 了解模型看到的内容?

钩子点(你可以拦截的地方?

OpenClaw 有两个钩子系统:

  • 内部钩子(网关钩子):用于命令和生命周期事件的驱动脚本?
  • 插件钩子:智能体/工具生命周期和网关管道内的扩展点?

内部钩子(网关钩子)

  • agent:bootstrap:在系统提示最终确定之前构建引导文件时运行? 使用它添?删除引导上下文文件?
  • 命令钩子/new/reset/stop 和其他命令事件(参见钩子文档)?

参见 Hooks 了解设置和示例?

插件钩子(智能体 + 网关生命周期?

这些在智能体循环或网关管道内运行?

  • before_model_resolve:在会话前运行(?messages),在模型解析前确定性覆盖提供商/模型?
  • before_prompt_build:在会话加载后运行(?messages),在提示提交前注入 prependContext/systemPrompt?
  • before_agent_start:遗留兼容性钩子,可能在任一阶段运行;优先使用上述明确钩子?
  • agent_end:完成后检查最终消息列表和运行元数据?
  • before_compaction / after_compaction:观察或注释压缩周期?
  • before_tool_call / after_tool_call:拦截工具参?结果?
  • tool_result_persist:在写入会话记录之前同步转换工具结果?
  • message_received / message_sending / message_sent:入?+ 出站消息钩子?
  • session_start / session_end:会话生命周期边界?
  • gateway_start / gateway_stop:网关生命周期事件?

参见 Plugins 了解钩子 API 和注册详情?

流式传输 + 部分回复

  • 助手增量?pi-agent-core 流式传输并作?assistant 事件发出?
  • 块流式传输可以在 text_end ?message_end 上发出部分回复?
  • 推理流式传输可以作为单独的流或块回复发出?
  • 参见 流式传输 了解分块和块回复行为?

工具执行 + 消息工具

  • 工具开?更新/结束事件?tool 流上发出?
  • 工具结果在记?发出前被清理大小和图片有效载荷?
  • 消息工具发送被跟踪以抑制重复的助手确认?

回复整形 + 抑制

  • 最终有效载荷由以下组装?
    • 助手文本(和可选推理)
    • 内联工具摘要(当详细 + 允许时)
    • 模型错误时的助手错误文本
  • NO_REPLY 被视为静默令牌并从出站有效载荷中过滤?
  • 消息工具重复项从最终有效载荷列表中移除?
  • 如果没有可渲染的有效载荷且工具出错,则发出回退工具错误回复 (除非消息工具已发送用户可见的回复)?

压缩 + 重试

  • 自动压缩发出 compaction 流事件并可能触发重试?
  • 在重试时,重置内存缓冲区和工具摘要以避免重复输出?
  • 参见 压缩 了解压缩管道?

事件流(当前?

  • lifecycle:由 subscribeEmbeddedPiSession发出(并作为回退?agentCommand 发出?
  • assistant:从 pi-agent-core 流式传输的增?
  • tool:从 pi-agent-core 流式传输的工具事?

聊天频道处理

  • 助手增量被缓冲到聊天 delta 消息?
  • 聊天 final ?*生命周期结束/错误**时发出?

超时

  • agent.wait 默认?0s(仅等待)。timeoutMs 参数覆盖?
  • 智能体运行时:agents.defaults.timeoutSeconds 默认 600s;在 runEmbeddedPiAgent 中止计时器中强制执行?

可以提前结束的地?

  • 智能体超时(中止?
  • AbortSignal(取消)
  • 网关断开连接?RPC 超时
  • agent.wait 超时(仅等待,不停止智能体)