Go Workflow 引擎从 Tempor 与 Cadence 到流程编排工作流引擎是后端组件的粘合层。Tempor / Cadence 是 Go 编写的开源流程编排引擎。本文讲清原理与集成。一、Temporal 是什么Temporal 微服务编排 时间调度 容错。Google Uber 支持。执行流程Worker - TaskQueue - Activity - Result二、Hello Worldimportgo.temporal.io/sdk/clientimportgo.temporal.io/sdk/workerc,_:client.Dial(client.Options{})w:worker.New(c,default,worker.Options{})w.RegisterWorkflow(Greet)w.RegisterActivity(SayHello)w.Start()WorkflowfuncGreet(ctx workflow.Context,namestring)(string,error){varresultstringerr:workflow.ExecuteActivity(ctx,SayHello,name).Get(ctx,result)returnresult,err}funcSayHello(ctx context.Context,namestring)(string,error){returnHello name,nil}启动importgo.temporal.io/sdk/clientc,_:client.Dial(client.Options{})c.ExecuteWorkflow(context.Background(),client.StartWorkflowOptions{TaskQueue:default},Greet,Tom)三、Workflow 特点确定性相同 input 永远相同 output异步能 sleep、等待 signal自动重试失败自动 backoff四、Activity包含 IO、API 调用等非确定性操作用户注册 activityworker 调用五、信号与查询Workflow 接受 signalvarstatusstringfunc(w*MyWorkflow)Signal(ctx workflow.Context)func(workflow.Context,string){returnfunc(ctx workflow.Context,sstring){statuss}}client sidec.SignalWorkflow(ctx,workflowID,,update,new-status)六、Cadence 与 TemporalCadence 是 Uber 的 Workflow 引擎Temporal 是它的 fork 增强。Temporal 兼容性更好。七、Workflow 测试importgo.temporal.io/sdk/testsuitevars testsuite.WorkflowTestSuite env:s.NewTestWorkflowEnvironment()env.RegisterWorkflow(Greet)env.RegisterActivity(SayHello)env.ExecuteWorkflow(Greet,Tom)八、企业实战长流程审批funcApproval(ctx workflow.Context,orderIDstring)(string,error){ctxworkflow.WithActivityOptions(ctx,...)iferr:workflow.ExecuteActivity(ctx,NotifyApplicant,orderID).Get(ctx,nil);err!nil{return,err}varsignalstringworkflow.GetSignalChannel(ctx,manager).Receive(ctx,signal)returnsignal,nil}等待经理审批duration 可达几小时。九、Temporal 全套组件temporal-server协调者temporal-worker执行者temporal-frontend接入tctl命令行十、K8s 部署apiVersion:apps/v1kind:StatefulSetmetadata:name:temporalspec:replicas:1template:spec:containers:-name:serverimage:temporalio/serverenv:-name:DBvalue:postgresqlPostgres 储存 Workflow 状态。十一、与 Saga 模式Workflow 提供默认 Retry、补偿胜过 Saga。十二、踩坑清单必须 deterministic不能直接 time.NowActivity 可以包含 IO用 ctx 包替代 channel十三、未来Serverless WorkflowAI Agent 工作流十四、总结与展望Workflow 引擎是长事务 容错 异步的最佳工具。Temporal 已是云原生标准之一。未来LLM-as-Agent 兴起后会重塑workflow 定义 执行的形态。十五、参考文献temporal.io 官方文档Cadence 文档