台账数据流：写命令→CommandGateway→HarnessState 记录谱系→File/JDBC

台账数据流：写命令→CommandGateway→HarnessState 记录谱系→File/JDBC 由 Archify 生成的数据流图。 01 / 写命令面 02 / 唯一写面 03 / HarnessState 记录谱系 04 / 持久化 05 / 存储实现 执行写命令 · claim/heartbeat/deliverWait · 01 / 写命令面 执行写命令 claim/heartbeat/deliverWait 治理写命令 · createTask/submit/review · 01 / 写命令面 治理写命令 createTask/submit/review CommandGateway · 校验+fencing+幂等 · 02 / 唯一写面 · 唯一写面 CommandGateway 校验+fencing+幂等 唯一写面 执行与等待谱系 · Exec/Lease/Wait/Wakeup/Checkpoint · 03 / HarnessState 记录谱系 · executionId 串联 执行与等待谱系 Exec/Lease/Wait/Wakeup/Checkpoint executionId 串联 治理与审计谱系 · Sub/Rev/Gate + Fact/Event · 03 / HarnessState 记录谱系 · taskId 串联+events 治理与审计谱系 Sub/Rev/Gate + Fact/Event taskId 串联+events HarnessPersistence · store.update 落盘 · 04 / 持久化 HarnessPersistence store.update 落盘 FileHarnessStore · state.json 单文件 · 05 / 存储实现 FileHarnessStore state.json 单文件 JdbcHarnessStore · 关系表·多 worker 共享 · 05 / 存储实现 JdbcHarnessStore 关系表·多 worker 共享 ① 执行命令 StateCommand ① 治理 StateCommand ② 写执行记录 apply(state) ② 治理 apply(state) ③ 执行聚合 HarnessState ③ 治理聚合 HarnessState ④ save/load 单机 ④ save/load 多 worker 图例 主要数据 数据存储 数据流

唯一写面

  • • 所有写入经 CommandGateway.apply(state)：校验 actor/状态机/fencing/幂等
  • • 读侧 getState/listX 直接读 HarnessState，不带写锁

谱系可追

  • • executionId 串起 Execution→Wait→Checkpoint→Session 谱系
  • • taskId→submissionId→gateId 串起治理链，可查 lineage