OpenClawDocs
View as MarkdownView this page as plain textOpen in ChatGPTAsk questions about this pageOpen in ClaudeAsk questions about this page

Messages and delivery

命令佇列

OpenClaw 透過一個小型的行程內佇列，將所有管道的傳入自動回覆執行序列化，以防止多個代理程式執行互相衝突，同時仍允許工作階段之間安全地平行處理。

原因

  • 自動回覆執行可能耗費大量資源（LLM 呼叫），而且多則傳入訊息在相近時間抵達時可能發生衝突。
  • 序列化可避免爭用共用資源（工作階段檔案、日誌、命令列介面標準輸入），並降低觸發上游速率限制的可能性。

運作方式

  • 具備通道感知能力的 FIFO 佇列，會依可設定的並行上限清空各通道（未設定的通道預設為 1；main 預設為 4，subagent 預設為 8）。
  • runEmbeddedAgent 依工作階段金鑰（通道 session:<key>）排入佇列，以確保每個工作階段同時只有一個執行中的作業。
  • 接著，每個工作階段執行會排入全域通道（預設為 main），使整體平行處理量受 agents.defaults.maxConcurrent 限制。
  • 啟用詳細日誌時，排入佇列的執行若在開始前等待超過約 2 秒，便會輸出簡短通知。
  • 輸入中指示器仍會在排入佇列時立即觸發（若管道支援），因此執行等待輪到自己期間，使用者體驗不會改變。

預設值

未設定時，所有傳入管道介面都使用：

  • mode: "steer"
  • debounceMs: 500
  • cap: 20
  • drop: "summarize"

預設採用同一回合引導。若提示在執行途中抵達，且該執行可接受引導，便會將提示注入目前的執行環境，因此不會啟動第二個工作階段執行。若目前執行無法接受引導，OpenClaw 會等候目前執行完成，再開始處理該提示。

佇列模式

/queue 控制工作階段已有執行中的作業時，一般傳入訊息的處理方式：

  • steer：將訊息注入目前的執行環境。OpenClaw 會在目前助理回合執行完工具呼叫後、下一次 LLM 呼叫前，傳遞所有待處理的引導訊息；Codex app-server 會收到一個批次的 turn/steer。若執行並未主動串流，或引導功能不可用，OpenClaw 會等候目前執行結束，再開始處理該提示。
  • followup：不進行引導。將每則訊息排入佇列，待目前執行結束後的代理程式回合處理。
  • collect：不進行引導。在靜默時間窗後，將排入佇列的訊息合併為單一後續回合。若訊息指向不同管道／討論串，則會分別清空，以保留路由。
  • interrupt：中止該工作階段目前執行中的作業，然後執行最新訊息。

如需執行環境特定的時序與相依性行為，請參閱引導佇列。如需明確的 /steer <message> 命令，請參閱引導。

透過 messages.queue 進行全域或個別管道設定：

json5
{  messages: {    queue: {      mode: "steer",      debounceMs: 500,      cap: 20,      drop: "summarize",      byChannel: { discord: "collect" },    },  },}

佇列選項

選項會套用至排入佇列的傳遞。debounceMs 也會設定 steer 模式下 Codex 引導的靜默時間窗：

  • debounceMs：清空排入佇列的後續訊息或收集批次前的靜默時間窗；在 Codex steer 模式下，則為傳送批次 turn/steer 前的靜默時間窗。單獨的數字以毫秒為單位；/queue 選項接受 ms、s、m、h 和 d 單位。
  • cap：每個工作階段可排入佇列的訊息數上限。低於 1 的值會被忽略。
  • drop: "summarize"（預設）：視需要捨棄最舊的佇列項目、保留精簡摘要，並將其注入為合成的後續提示。
  • drop: "old"：視需要捨棄最舊的佇列項目，不保留摘要。
  • drop: "new"：佇列已滿時拒絕最新訊息。

預設值：debounceMs: 500、cap: 20、drop: summarize。

引導與串流

當管道串流為 partial 或 block 時，在目前執行到達執行環境邊界的過程中，引導可能呈現為數則簡短的可見回覆：

  • partial：預覽可能提早完成，接著在引導獲接受後開始新的預覽。
  • block：草稿大小的區塊可能產生相同的連續顯示效果。
  • 若未使用串流，且執行環境無法接受同一回合引導，引導會改為在目前執行結束後進行後續處理。

steer 不會中止執行中的工具。若最新訊息應中止目前執行，請使用 /queue interrupt。

優先順序

選取模式時，OpenClaw 依下列順序解析：

  1. 內嵌或儲存的個別工作階段 /queue 覆寫值。
  2. messages.queue.byChannel.<channel>。
  3. messages.queue.mode。
  4. 預設 steer。

對於選項，內嵌或儲存的 /queue 選項優先於設定。接著依序套用管道特定的防彈跳設定（messages.queue.debounceMsByChannel）、外掛防彈跳預設值、全域 messages.queue 選項，以及內建預設值。cap 和 drop 是全域／工作階段選項，不是個別管道設定鍵。

個別工作階段覆寫

  • 將 /queue <steer|followup|collect|interrupt> 作為獨立命令傳送，以儲存目前工作階段的佇列模式。
  • 選項可合併使用：/queue collect debounce:0.5s cap:25 drop:summarize
  • /queue default 或 /queue reset 會清除工作階段覆寫值。

佇列回合取消

當提示位於後續／收集佇列中時（例如另一個回合仍在執行時抵達的終端介面或 網頁聊天 chat.send），閘道會為該用戶端 runId 保留 由閘道擁有的取消身分，直到排入佇列的內容執行或遭捨棄。此身分會隨著摺疊至 溢位摘要的內容一併保留。

  • 帶有特定 runId 的 chat.abort，可在該回合仍位於 佇列中時將其取消，前提是請求者已獲授權（與執行中作業相同的擁有權規則）。
  • 對工作階段發出不含 runId 的 chat.abort，會先取消已授權的佇列回合， 然後中止已授權的執行中作業。此順序可防止佇列清空時，將工作提升至 僅停止一半的工作階段。
  • 未逐一檢查請求者便清除整個工作階段佇列，並不是 多擁有者工作階段的停止路徑。
  • 對 sessions.list 而言，佇列等待不會投射為執行中的代理程式作業， 也不具備執行中作業的逾時語意；只有執行中階段具有此語意。

由閘道支援的用戶端（包括 openclaw tui）會轉送執行途中的提示，並 由閘道套用佇列模式。Esc／/stop 使用工作階段範圍的中止， 因此即使本機控制代碼遺失，也不會讓仍在佇列中的提示繼續執行。

openclaw chat 和 openclaw tui --local 會在 內嵌執行環境中套用相同的四種模式。當執行環境接受引導時，本機 steer 會注入執行中的內嵌作業， 否則會成為後續工作；followup 和 collect 仍是本機待處理工作；interrupt 會在開始最新訊息前 中止執行中的本機作業。明確的 /steer <message> 命令 不是本機模式命令。

範圍與保證

  • 適用於使用閘道回覆流水線的所有傳入管道之自動回覆代理程式執行（WhatsApp 網頁版、Telegram、Slack、Discord、Signal、iMessage、網頁聊天等）。
  • 預設通道（main）在整個行程中由傳入訊息與主要心跳偵測共用；設定 agents.defaults.maxConcurrent 可允許多個工作階段平行執行。
  • 可能存在其他通道（例如 cron、cron-nested、nested、subagent），讓背景工作可平行執行而不阻塞傳入回覆。隔離的排程代理程式回合會在其內部代理程式執行使用 cron-nested 時占用一個 cron 槽位。共用的非排程 nested 流程會維持自身的通道行為。這些分離的執行會作為背景工作追蹤。
  • 個別工作階段通道可保證任一時間只有一個代理程式作業會存取指定工作階段。
  • 沒有外部相依性或背景工作執行緒；僅使用 TypeScript 與 Promise。

疑難排解

  • 若命令似乎卡住，請啟用詳細日誌並尋找 “queued for ...ms” 行，以確認佇列正在清空。
  • 若 Codex app-server 執行接受回合後停止輸出進度，Codex 配接器會將其中斷，讓執行中的工作階段通道得以釋放，而不是等待外層執行逾時。
  • 啟用診斷時，若工作階段停留在 processing 的時間超過內建警告閾值，且未觀察到任何回覆、工具、狀態、區塊或 ACP 進度，會依目前活動分類：
    • 近期有進度的執行中工作會記錄為 session.long_running。由擁有者控制但無輸出的模型呼叫，在達到內建中止閾值前也會維持 session.long_running，避免過早將緩慢或非串流供應商回報為停滯。
    • 近期沒有進度的執行中工作會記錄為 session.stalled；由擁有者控制的模型呼叫、遭阻塞的工具呼叫與停滯的內嵌執行，在達到或超過中止閾值時會切換為 session.stalled。沒有擁有者的過時模型／工具活動不會被隱藏為長時間執行。
    • session.stuck 保留給可復原的過時工作階段簿記，包括含有過時且無擁有者之模型／工具活動的閒置佇列工作階段。
    • session.stuck 一律會觸發可釋放受影響工作階段通道的復原程序。超過中止閾值的 session.stalled 分類（遭阻塞的工具呼叫、停滯的模型呼叫或停滯的內嵌執行）也可觸發主動中止復原，因此兩種分類都能解除佇列卡住的狀態，而不只有 session.stuck。
    • 當工作階段維持不變時，重複的 session.stuck 和 session.long_running 警告日誌行會以指數方式退避；無論此退避如何，每次心跳偵測節拍仍會執行復原嘗試。

相關內容

Was this useful?
On this page

On this page