Durable-Workflow-Temporal与Agent控制面分工

Durable Workflow · Temporal 与 Agent 控制面分工

🏠 返回 04-README ｜ ⬅️ 03-Java-Agent编排 ｜ ➡️ 02-Buy领域智能体

定位：回答 Staff 白板「LangGraph checkpoint 够了为什么还要 Temporal？」——Agent 环内状态vs跨天业务流程的分工。Java 编排选型见 03；LangGraph interrupt 见 04-Agent框架；checkpoint 语义见 96 §2.0、13 §9.4。

L1 · 是什么

1.1 一句话定义

Temporal（或同类 durable execution 引擎）管理长寿命、多角色、强审计的业务流程；Agent Runtime（Spring AI loop / LangGraph）管理秒–分钟级的推理–工具循环。二者通过Activity 边界衔接：Workflow 定「何时、谁批、是否可重试」；Agent 定「这一步怎么推理、调哪些 tool」。

1.2 选型决策树

1.3 与 Spring Statemachine 对照（03）

L2 · 架构分工

2.1 两平面模型

2.2 Activity 设计原则

1. Activity 要幂等：executeRefund(orderId, idempotencyKey)。
2. Activity 粒度 = 业务原子步，不是「一次 LLM call」。
3. LLM 环放在 Activity 内，Activity 超时 > LLM P99 + 工具链。
4. HITL 用Workflow.awaitCondition/ Signal，不要阻塞 HTTP 线程。

2.3 Java 示意（Temporal Java SDK · L1）

API 以 Temporal Java SDK 为准；以下为面试示意结构。

@WorkflowInterfacepublicinterfaceRefundWorkflow{@WorkflowMethodRefundResultrun(RefundRequestreq);}publicclassRefundWorkflowImplimplementsRefundWorkflow{privatefinalRefundActivitiesacts=Workflow.newActivityStub(RefundActivities.class,ActivityOptions.newBuilder().setStartToCloseTimeout(Duration.ofMinutes(5)).setRetryOptions(RetryOptions.newBuilder().setMaximumAttempts(3).build()).build());@OverridepublicRefundResultrun(RefundRequestreq){SlotBundleslots=acts.collectSlots(req);AgentPlanplan=acts.runAgentPlan(req,slots);// 内部 Spring AI + checkpointacts.waitHumanApproval(req.orderId(),plan.riskSummary());returnacts.executeRefund(req.orderId(),req.idempotencyKey());}}

Agent Activity 内部仍可用 03 Plan-Execute + Redis checkpoint；Temporal 只保证Activity 级至少一次执行与超时重试。

2.4 LangGraph interrupt vs Temporal Signal

组合：客服 Agent 图内interrupt收集材料 → Workflow 进入waitHumanApproval→ Signalapproved→ 下一 Activity 调写工具。

L3 · 生产要点

3.1 版本与部署

3.2 失败模式

3.3 观测

• Workflow：workflow_id=order_id等业务键。
• Agent span：挂parent_trace= Activity span。
• 统一release_id进 08-可观测。

3.4 与 Camunda / Step Functions

Staff 原则：选已落地引擎，不为了面试换栈。

L4 · Staff 答辩

4.1 STAR-M-P：退款审批 3 天超时

4.2 大厂追问答

Q1 · 全用 LangGraph 行不行？

答：步内可以；跨天审批、定时器、多系统回调应用 Workflow 引擎。否则自研调度 ≈ 重写 Temporal。

Q2 · Activity 里 LLM 调用 90s 怎么办？

答：startToCloseTimeout> P99；环内 streaming；超长则拆 Activity或异步回调 Pattern。

Q3 · Temporal 与 Kafka？

答：Kafka事件通知；Temporal状态机与重试。Agent 侧「任务完成」可发 Kafka，编排不交给 Kafka 消费组随意重试。

Q4 · Python Agent + Java Workflow？

答：常见：Java Temporal Worker+Python Agent gRPC Activity（见 05-python-agent §集成）。契约：protobuf +release_id。

Q5 · 何时用 Spring Statemachine 代替 Temporal？

答：单服务、无跨天、团队无 Temporal 运维时 Statemachine 够用；多服务、审计、定时器选 Temporal。

4.3 与03 Supervisor 组合

原则：Supervisor 不解跨天；跨天用 Workflow 等 Signal。

4.4 部署拓扑（白板）

• API只startWorkflow，不阻塞等 LLM。
• Agent Service可独立扩缩；Activity 通过 gRPC 调用。
• Checkpoint与 Workflow DB分库——避免混表。

4.5 测试策略

4.6 容量与 SLO

4.7 常见追问速答

• Q：能否用 Kafka 代替 Temporal？— Kafka 传事件，不负责「等到周三经理批准」这类状态；会自研调度器。
• Q：Camunda BPMN？— 已有 BPMN 资产优先 Camunda；绿场 Java 云原生常用 Temporal。
• Q：Serverless？— Activity 调 Lambda 可行；长连接 LLM仍建议专用 Agent 服务。
• Q：与 96 原型 G？— 批处理 G 用 Temporal；单会话 A/B 用 Agent checkpoint。

§8 决策速查表（面试翻牌）

§9 与 Registry / Eval 联动

Activity 入参必须带release_id（11）。Workflow 升级用Workflow.getVersion()；禁止Activity 内隐式读「最新 prompt」。

发布前：Golden 含长流程用例（审批超时、Signal 恢复）→ eval/golden 扩展。

§10 白板 45min 脚本

5. 面试前 Checklist

• 画决策树：checkpoint vs Temporal
• 画两平面：Workflow History vs Agent Checkpoint
• 述Activity 四原则（幂等、粒度、超时、HITL Signal）
• 对比LangGraph interrupt vs Temporal Signal
• 口述STAR退款审批
• 列RUN_99P_* 与 Activity 重试关系

6. 导航

官方文档与源码（一级依据）

写作规范：docs/official-sources-registry.md §0

L1 · 官方文档

• Temporal — Documentation
• Temporal — Java SDK Develop
• LangGraph — Interrupts
• LangGraph — Persistence / Checkpoints

L2 · 官方源码

• temporalio/sdk-java
• langchain-ai/langgraph