10. 运行时架构与并发模型
一个主进程 + N 个子进程。主进程是"中枢神经"，子进程是独立运行的 Agent。
10.1 并发模型
┌──────────────────────────────────────────────────────────────────┐
│ LemonBoss Server (主进程) │
│ Node.js 单进程 + EventEmitter │
│ │
│ ┌─────────────────────────────────────────────────────────┐ │
│ │ Agent 进程管理器 │ │
│ │ │ │
│ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │
│ │ │ ACP #1 │ │ ACP #2 │ │ ACP #3 │ ... │ │
│ │ │ Master │ │ CEO │ │ 编剧部 │ │ │
│ │ │ │ │ │ │ │ │ │
│ │ │ 子进程 │ │ 子进程 │ │ 子进程 │ │ │
│ │ │ PID 1001 │ │ PID 1002 │ │ PID 1003 │ │ │
│ │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │
│ │ │ │ │ │ │
│ │ └─────────────┼─────────────┘ │ │
│ │ stdin / stdout pipe │ │
│ │ (JSON-RPC 双向通讯) │ │
│ └─────────────────────┼────────────────────────────────────┘ │
│ │ │
│ ┌─────────────────────┼────────────────────────────────────┐ │
│ │ 工具拦截器 (Tool Interceptor) │ │
│ │ │ │
│ │ Agent stdout 输出工具调用 → 主进程拦截: │ │
│ │ │ │
│ │ task.assign → 路由消息到目标 Agent 的 stdin │ │
│ │ task.report → 路由消息到上级 Agent 的 stdin │ │
│ │ role.create → AgentScaffold 创建目录 → 启动子进程 │ │
│ │ pipeline.set → 存储 DAG 到 SQLite │ │
│ │ org.status → 查询 SQLite 返回全局状态 │ │
│ │ skill.reuse → 复制 Skill 引用 │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ ┌──────────────────────────────────────────────────────────┐ │
│ │ SQLite (唯一共享存储) │ │
│ │ │ │
│ │ agents 表 ← Agent 注册信息和状态 │ │
│ │ messages 表 ← Agent 间所有通讯记录 │ │
│ │ tasks 表 ← 任务队列和进度 │ │
│ │ goals 表 ← 目标定义与追踪 │ │
│ │ loop_runs 表 ← Loop 运行记录 │ │
│ │ memories 表 ← Agent 共享记忆 │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ ┌─────────────┐ ┌─────────────┐ ┌──────────────────┐ │
│ │ Cron 调度器 │ │ Gateway Hub │ │ HTTP/WS API 层 │ │
│ │ node-cron │ │ 飞书/WA/钉钉│ │ Express + WS │ │
│ └─────────────┘ └─────────────┘ └──────────────────┘ │
│ │
└──────────────────────────────────────────────────────────────────┘
并发方式
| 维度 |
方案 |
说明 |
| 进程级并发 |
每个 Agent = 独立子进程 |
操作系统级别并行，互不阻塞 |
| 通讯方式 |
stdin/stdout pipe |
JSON-RPC over stdio（ACP 标准协议） |
| 共享存储 |
SQLite (WAL 模式) |
主进程单写，子进程通过工具请求读取 |
| 调度方式 |
异步事件驱动 |
Agent A 发任务后不等待，Agent B 完成后异步回报 |
子进程的启动方式
// 主进程启动一个 Agent 的 ACP 子进程
const child = spawn('claude', ['--agent', agentDir], {
stdio: ['pipe', 'pipe', 'pipe'], // stdin, stdout, stderr 全部管道化
cwd: path.join(agentDir, 'workspace'),
env: { ...process.env, ...agentEnv },
});
// 注入 System Prompt (agent.md + soul.md + ... 拼接)
child.stdin.write(systemPrompt);
// 监听 Agent 的输出 (工具调用)
child.stdout.on('data', (data) => {
const toolCall = parseJSON(data);
toolInterceptor.handle(toolCall, agentId);
});
10.2 Agent 生命周期
┌─── create ───┐
▼ │
┌─────────────────────────────────────┐
│ AgentRegistry │
│ │
│ ┌───────┐ ┌─────────┐ ┌───┐ │
│ │ idle │───→│ running │───→│stop│ │
│ │ │ │ │ │ │ │
│ │ 目录已│ │ ACP 子 │ │ACP│ │
│ │ 创建 │ │ 进程运行│ │关闭│ │
│ └───────┘ └─────────┘ └───┘ │
│ │ │ │
│ └──── error ───┘ │
│ │
│ destroy → 删除目录 + 注销 │
└─────────────────────────────────────┘
create: AgentScaffold 生成目录 → 注册到 SQLite → 注册到 Bus
start: 加载 Bootstrap Files → 启动 ACP 子进程 → 注入 System Prompt
stop: 关闭 ACP 子进程 → 状态改为 idle
destroy: 停止 → 从 Bus 注销 → 删除目录 → 从 SQLite 删除
10.3 框架核心服务
| 服务 |
职责 |
| AgentRegistry |
Agent CRUD + 生命周期管理 (create/list/get/update/destroy) |
| AgentBus |
消息路由 + 持久化 + 广播 |
| AgentProcessManager |
ACP 子进程启动/停止/监控/重启 |
| ToolInterceptor |
拦截 Agent 的工具调用，执行框架级操作 |
| CronScheduler |
解析 heartbeat.md，按时触发 Agent |
| GatewayHub |
外部 IM 消息接入 (飞书/WhatsApp/钉钉) |
| GoalTracker |
目标进度追踪与评估 |
| PipelineRouter |
按 DAG 自动流转 Pipeline 节点 |
10.4 技术选型
| 组件 |
技术方案 |
理由 |
| AI 内核 |
Claude Code ACP |
已验证的四维架构 (Protocol + Transport + Launcher + Runtime) |
| 后端主进程 |
Node.js + Express |
事件驱动，天然适合管理多子进程 |
| 子进程通讯 |
stdio pipe (JSON-RPC) |
ACP 标准协议，零依赖 |
| 共享存储 |
SQLite (better-sqlite3, WAL) |
轻量级，主进程单写多读，无外部依赖 |
| 实时推送 |
WebSocket + SSE |
前端仪表盘实时监控 |
| 定时任务 |
node-cron |
解析 heartbeat.md 的 cron 表达式 |
| 进程管理 |
Node.js child_process |
子进程启动/停止/信号管理 |
| 前端 |
Vue 3 + Vite |
控制面板和监控仪表盘 |
| 日志 |
Winston + JSONL |
结构化日志 + Agent 对话记录 |
| 网关 |
适配器模式 |
统一不同 IM 的消息格式 |
| 包管理 |
pnpm workspace |
Monorepo 管理 |
10.5 一个完整请求的生命周期
用户在飞书里说: "最近短剧市场怎么样？"
│
▼
[1] Gateway Hub (飞书适配器)
│ 消息格式化为标准格式
▼
[2] AgentProcessManager
│ 找到 Master ACP 子进程
│ 通过 stdin 注入消息
▼
[3] Master ACP 进程 (子进程 PID 1001)
│ 读取 agent.md + soul.md → 推理
│ 决定: 让 CEO 调数据部去分析
│ stdout: task.assign({ to: "cxo-ceo-001", ... })
▼
[4] ToolInterceptor (主进程)
│ 拦截 task.assign
│ 写入 SQLite messages 表
│ 注入到 CEO 的 stdin
▼
[5] CEO ACP 进程 (子进程 PID 1002) ← 与 Master 并行运行
│ 收到任务 → 推理
│ stdout: task.assign({ to: "role-data-001", ... })
▼
[6] ToolInterceptor → 路由到数据部
▼
[7] 数据部 ACP 进程 (子进程 PID 1005) ← 与 CEO 并行运行
│ 调用爬虫 Skill → 采集数据
│ 分析完成
│ stdout: task.report({ to: "cxo-ceo-001", ... })
▼
[8] ToolInterceptor → 路由回 CEO
▼
[9] CEO 收到数据 → 汇总
│ stdout: task.report({ to: "master-001", ... })
▼
[10] ToolInterceptor → 路由回 Master
▼
[11] Master 收到汇总 → 组织回复
│ stdout: reply({ content: "最近市场分析..." })
▼
[12] Gateway Hub → 飞书 → 用户
整个过程中 Master / CEO / 数据部 可能在同时做其他事 (心跳、其他任务)
所有步骤全异步, 不阻塞
