golang如何实现工作流引擎_golang工作流引擎实现要点

工作流状态机必须用有向无环图DAG建模不可用if-else拼接需以邻接表拓扑排序保障执行顺序节点函数统一签名、调度分离状态按粒度持久化超时与重试须节点级配置DSL仅用于路由决策。工作流状态机必须用有向无环图DAG建模不能靠 if-else 拼接Go 里写工作流最常见错误是把流程当成线性条件判断来处理一个 if 套一个 switch再嵌一层 select。结果一加分支就乱一改节点就崩。真正可维护的工作流底层必须是 DAG —— 每个节点有明确入度和出度执行顺序由拓扑排序决定而非代码书写顺序。实操建议立即学习“go语言免费学习笔记深入”用 map[string][]string 表示邻接表key 是节点 IDvalue 是它指向的下一组节点 ID 列表启动前调用 toposort 检查环路避免死循环可用 github.com/yourbasic/graph 或手写 DFS 环检测节点执行函数统一签名func(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error)不暴露内部状态流转细节别在节点里直接调用下一个节点函数 —— 节点只负责“算”调度器负责“派”状态持久化不能只靠内存变量得选对存储粒度本地测试时用 map[string]interface{} 存流程实例状态很顺上线后一并发就丢状态、一重启就断流。根本原因是没区分「瞬态上下文」和「持久化快照」。实操建议立即学习“go语言免费学习笔记深入”每个流程实例必须有唯一 instanceID所有状态变更都以该 ID 为 key 写入持久层高频读写字段如当前节点名、重试次数存在 Redis带 TTL低频但关键字段如审批意见、原始表单走 PostgreSQL加 workflow_instances 表不要每步都全量序列化整个 data map —— 只存 diff用 jsonpatch 或自定义结构体字段标记 dirty注意事务边界状态更新和业务操作必须在同一个 DB 事务中提交否则会出现“流程已进下一流程但订单未扣款”这类错位超时与重试必须绑定到节点级不是整个流程用 context.WithTimeout 包一层主流程看起来简洁实际会把审批、支付、通知全卡死。真实业务里人工审批可能等三天而 HTTP 调用必须 5 秒失败重试 —— 它们超时逻辑完全不同。 Cleanup.pictures 智能移除图片中的物体、文本、污迹、人物或任何不想要的东西