GitHub周趋势2026W25 | Headroom 压缩 95% Token、NVIDIA 开源 AI Agent 安全扫描器、…
2026-07-28
2026-07-29 0
内置本地 Agent 对 AI 产品的必要性,我们已在上一篇完成论证!
接下来聚焦怎么做,从架构设计延伸到代码接入,给出我们的落地方案。
五层的职责如下:
| 层级 | 技术选择 | 职责 |
|---|---|---|
| UI 交互层 | React + 流式 Hook | 负责对话界面、审批卡片及结果展示 |
| 基础 Agent 层 | LangChain createAgent() | 承担通用问答和工具调用循环 |
| 工作流编排层 | LangGraph StateGraph | 处理复杂任务、检查点与中断恢复 |
| 工具接入层 | 自研 Tool Adapter | 统一屏蔽数据源、本地命令和第三方差异 |
| 宿主层 | Electron Main + Local Service | 负责密钥安全、进程管理和随包发布 |
新建 ai-agent-server 以 Hono 框架向外提供 HTTP 服务的 workspace:
// apps/ai-agent-server/src/server.tsimport { Hono } from 'hono';import { serve } from '@hono/node-server';export const createAiAgentServer = async (config) => {const app = new Hono();// 健康检查app.get('/health', (c) => c.json({ status: 'ready', model: config.model }));// 问答接口(Step 2 实现)registerChatRoutes(app, config);const server = serve({ fetch: app.fetch, hostname: config.host, port: config.port });return { origin: `http://
关键点:
127.0.0.1:39321,仅监听本地先完成普通问答,再于后续加入工具,由此实现最小 Agent 接入:
// apps/ai-agent-server/src/agent/createHomeAiQaAgent.tsimport { createAgent } from 'langchain';import { ChatOpenAI } from '@langchain/openai';export const createHomeAiQaAgent = (config) => {const model = new ChatOpenAI({apiKey: config.apiKey,model: config.model,temperature: 0.2,configuration: { baseURL: config.baseUrl },});return createAgent({model,tools: [],// 先不加工具,二期再扩展systemPrompt: '你是本地 AI 助手...',name: 'home_qa_agent',});};
SSE 流式接口:
// apps/ai-agent-server/src/routes/chat.tsexport const registerChatRoutes = (app, config) => {const agent = createHomeAiQaAgent(config);app.post('/api/agent', async (c) => {const body = await c.req.json();const stream = await agent.stream({ messages: body.messages },{ encoding: 'text/event-stream', streamMode: ['values', 'updates', 'messages'] },);return new Response(stream, {headers: { 'Content-Type': 'text/event-stream', 'Cache-Control': 'no-cache' },});});};
让 Agent 服务随应用自动启动。开发态用 pnpm dev,打包态用 fork:
// electron/src/main/processManager/aiAgentProcess/index.tsexport const startAiAgentProcess = () => {if (app.isPackaged) {// 打包态:fork 打包后的 js 文件aiAgentProcess = childProcess.fork(path.join(__dirname, 'aiAgentServer.js'), []);} else {// 开发态:pnpm 启动 dev serveraiAgentProcess = childProcess.spawn('pnpm', ['--filter', 'ai-agent-server', 'dev'], { env: { ...process.env } });}};
前端通过 LinkService 获取运行时状态:
// 前端调用const runtime = await window.LinkService.request('v1/aiAgent/getRuntime');// runtime = { ready: true, status: 'ready', baseUrl: 'http://127.0.0.1:39321' }
右侧副面板使用 LangGraph SDK 的 useStream Hook:
// apps/src/features/home/components/AiQaPanel/index.tsximport { FetchStreamTransport, useStream } from '@langchain/langgraph-sdk/react';const AiQaPanel = ({ runtime }) => {const transport = useMemo(() => new FetchStreamTransport({apiUrl: `${runtime.baseUrl}/api/agent`,}), [runtime.baseUrl]);const stream = useStream({ transport });return (<section><header><h2>AI 问答h2>header>{/* 消息列表 */}<div>{stream.messages.map(renderMessage)}div>{/* 输入框 */}<input value={input} onChange={(e) => setInput(e.target.value)} /><button onClick={() => stream.submit({ messages: [{ type: 'human', content: input }] })}>发送button>section>);};
Agent 一旦能执行本地命令,就必须有权限审批。推荐三层模型:
| 风险等级 | 典型操作 | 默认策略 |
|---|---|---|
low | 读取笔记和线程上下文 | 自动执行 |
medium | 创建文档、导出 PDF | 首次需要确认,之后可记住 |
high | 运行 Shell 命令、发送消息 | 每次都必须审批 |
critical | 删除文件、批量外发 | 默认拒绝 |
用 LangGraph 的 interrupt() 实现审批中断:
// Agent 调用高风险工具时,interrupt 等待用户审批// 用户点击"允许"后,resume 继续执行
由前端展示审批卡片:
<ApprovalCardtitle="读取文件"reason="需要读取首页实现文件"riskLevel="low"onApprove={() => AiAgentApis.approveRequest(requestId)}onDeny={() => AiAgentApis.denyRequest(requestId)}/>
这是 Agent 区别于普通 Chat 的重要方面之一。
基于 thread_id 进行状态持久化,保存当前会话中的:
使用 LangGraph 的 checkpointer 实现,开发阶段采用 MemorySaver,生产环境采用 PostgresSaver。
需要跨会话长期保存的内容:
关键判断在于,并非所有内容都值得记忆。只应保存三类信息:用户明确要求记住的内容、高频重复且对后续有帮助的内容,以及权限与偏好类配置。
Agent ReAct 循环适合直接处理普通问答、单工具调用这类简单任务。
显式编排复杂任务应采用 LangGraph StateGraph,这类任务包含多步骤、审批以及多阶段产物。任务编排层次推荐如下:
| 层次 | 作用 |
|---|---|
| Intent Classifier | 问答 / 查询 / 生成 / 执行 / 工作流:对这些意图进行识别 |
| Planner | 把目标拆分为可执行步骤 |
| Supervisor | 负责子袋里调度、审批和重试 |
| Executor | 运行工具或子图 |
| Verifier | 核查结果是否完整 |
| 错误类型 | 示例 | 处理 |
|---|---|---|
model_error | 超时、429 | 自动重试 / 模型降级 |
tool_error | 参数错误 | 交由 Agent 自行修复 |
permission_error | 审批遭到拒绝 | 中断并提示用户 |
sandbox_error | 路径不合法 | 终止并开展诊断 |
从业务层面审视,需要做到以下事项,因为接个模型并不等于完成 LangChain Agent 接入的核心:
更关键的是,Agent 只是执行和编排任务的框架。要让大模型更好地工作,离不开以下工程化工作:
这些还将成为更深远的课题!