SSE让浏览器Ke以像收报纸一样持续获取后端推送的数据。代码示例：

const eventSource = new EventSource;
eventSource.onmessage = e => {
  const data = JSON.parse;
  // 渲染思考/观察步骤
};

只要返回了 taskId，页面就不必再轮询，而是被动接受geng新，这种体验比“等着转圈”要友好太多。

接收到前端请求后我们Zuo两件事：① 把原始指令保存进数据库；② 根据是否包含时间信息决定创建普通 Job 还是 Cron Job。

// POST /api/tasks
async createTask dto: CreateTaskDto) {
  const task = await this.prisma.task.create;
  if  {
    await this.queue.add(
      'agent-task',
      { taskId: task.id },
      { repeat: { cron: dto.cron, tz: 'Asia/Shanghai' } }
   );
  } else {
    await this.queue.add;
  }
  return { taskId: task.id };
}

*温馨提示*: 为了防止同一个用户频繁提交相同指令，Ke以在 Service 层加一层去重缓存，这样既省资源又提升安全性。

BullMQ 天生支持重复任务和并发限制。我们只需定义一个消费函数，让它负责把 Job 拉进「Agent Runtime」：

const worker = new Worker('agent-task', async job => {
  const { taskId } = job.data;
  await runAgent;
}, {
  concurrency: 5   // 同时Zui多跑五个 agent 实例
});

Ru果某个 Job 因异常退出，BullMQ 会自动重试并记录错误日志，这为后续运维提供了可靠依据。

Agent 本质是一台「状态机」，每一次迭代dou会产生三个可Neng的 Step 类型：

thought**：LLM 给出的思考文本。

type Step =
| { id:string; taskId:string; type:'thought'; content:string; createdAt:Date }
| { id:string; taskId:string; type:'action'; tool:string; input:any; createdAt:Date }
| { id:string; taskId:string; type:'observation'; content:string; createdAt:Date };

async function runAgent {
  let steps = await loadSteps;          // 恢复历史上下文
  while  {
    const ctx = await buildContext;     // 把所有 Step 串联成 prompt
    const llmResp = await llm.invoke;      // 思考阶段
    await saveStep;
    if  {
      await finishTask;
      break;
    }
    const toolResult = await callTool;
    await saveStep});
    steps.push; // 简化计数
  }
}

// 假设 LLM Yi经解析出以下结构
const result = await llm.invoke;
/*
{
   type:"cron",
   cron:"0 9 * * *",
   task:"查询 BTC 价格"
}
*/
await prisma.task.create({
   data:{ input:result.task, cron:result.cron, isCron:true }
});
await queue.add('agent-task',{taskId:newTask.id},{
   repeat:{cron:result.cron,tz:'Asia/Shanghai'}
});

flowchart TD
   A --> B
   B --> C
   C --> D
   D --> E
   A --> F
   F --> G
   G --> H

CREATE TABLE steps (
   id UUID PRIMARY KEY,
   task_id UUID NOT NULL,
   type TEXT CHECK),
   payload JSONB,
   created_at TIMESTAMP DEFAULT now
);
-- 查询Zui新 N 步：
SELECT * FROM steps WHERE task_id=$1 ORDER BY created_at DESC LIMIT $2;