Agent Skills
返回列表
Agent 集群通讯系统 v2

Agent 集群通讯系统 v2

AI Agent 更新于 2026.08.29

将以下提示词粘贴到你的 AI 对话框中：

请根据 https://skillhub.cn/install/skillhub.md，安装 @user_0816acf6/agent-cluster-v2。

技能介绍

要解决什么问题

多个 Agent 协作时，进程可能随时重启、处理失败或暂时离线。若只靠内存管道或临时文件传话，消息容易丢、重复难控，也很难知道「对方到底有没有处理完」。本技能提供一套基于 SQLite 的轻量级消息队列，把 Agent 之间的往来做成可持久、可确认、可重试的队列语义，而不是一次性 RPC。

核心机制与用法

消息写入本地 SQLite（默认库文件如 agent_messages.db），重启后仍在。发送方发出消息后，接收方处理完毕需显式确认；失败会按配置自动重试（默认最多 3 次），超限则进入死信队列，便于人工排查而不是无限循环。

运行时通常围绕 SQLiteMessageQueue：发送、轮询待处理消息、确认已完成项，并可查统计或重置卡住的消息。队列侧可配 poll_interval、batch_size 等以控制轮询节奏与并发批量；多 Agent 场景下通过 agents 配置启用/命名各参与者。此外支持 Agent 间状态同步与消息上的统一时间信息，便于对齐日志与排查顺序。

适用边界与注意点

这是单机文件库上的队列，适合同机或共享数据库路径的多进程 Agent，不是分布式 Kafka 类中间件；高吞吐、跨机房 fan-out 需自行评估 SQLite 锁与磁盘 IO。消息体宜简短，处理完务必及时 ack，失败时带上可读的 error 信息；积压、反复失败和死信要按文档里的排查思路定期清理已完成记录，并结合心跳文件做存活监控。

使用场景

  • 本机跑多个 Agent 进程，彼此派发子任务，需要在某进程崩溃重启后仍能从队列里继续消费未确认消息。
  • 编排流水线式 Agent：上游写入队列，下游轮询处理并在完成后确认，避免重复执行同一条业务指令。
  • 某条消息处理反复失败时，依赖自动重试与死信队列定位错误内容，而不是在内存里静默丢失。
  • 多个 Agent 需要读写同一份共享状态，并通过带统一时间戳的队列消息对齐操作顺序与日志。

适合人员

  • 在本机用 Python 编排多个 LLM Agent 进程、需要进程间可靠传话而非单次函数调用的应用开发者。
  • 负责多 Agent 运维脚本的同学，希望在处理失败时能自动重试并在超限后把消息隔离到死信便于排查。
  • 做 Agent 实验平台的学生或研究员，要在 Windows/Linux/macOS 上用同一套 SQLite 队列做轻量通讯原型。
  • 编写自动化工作流、让不同命名 Agent 按配置启用并批量轮询队列的后端工程师。