Uber candence

### Uber Cadence 工作流引擎概述 Cadence 是由 Uber 开发的一款分布式工作流引擎，旨在解决传统请求-响应模型无法处理的长时间运行任务和复杂业务流程的问题[^2]。它的核心目标是帮助开发者专注于实现业务逻辑，而无需过多关注底层的技术细节。 Cadence 提供了一个强大的框架，可以用来协调跨多个服务的任务执行，并确保即使在网络分区或其他故障情况下也能保持一致性[^4]。其设计使得它可以轻松应对高并发环境下的挑战，同时支持多种状态机模型以适应不同的应用场景。 #### 主要特性 - **可靠性**：通过持久化记录每一步的操作历史，确保即使发生节点失败也不会丢失数据。 - **灵活性**：支持自定义调度策略以及动态调整工作流的行为模式。 - **扩展性**：能够水平扩展到数千个工作线程上并行处理大量请求。 项目地址位于 [https://gitcode.com/gh_mirrors/ca/cadence-web](https://gitcode.com/gh_mirrors/ca/cadence-web)，这里包含了完整的文档和支持工具，比如可视化界面 `cadence-web` 可用于监控正在运行的工作流实例及其进度[^1]。 ### 使用教程 为了更好地理解如何利用 Cadence 创建自己的工作流应用，下面给出了一些基础指导： #### 安装与配置 首先需要安装 Cadence CLI 和服务器组件。可以通过 Docker 镜像快速启动本地测试环境： ```bash docker run -d --name cadence-server -p 7933:7933 -p 7935:7935 -p 7936:7936 ubercadence/server:latest ``` 接着初始化域（domain），这是 Cadence 中组织所有资源的基本单位之一： ```bash cadence domain register your-domain-name --description "My first Domain" ``` #### 编写第一个 Workflow 以下是一个简单的 Go 示例程序展示如何定义及调用 workflow： ```go package main import ( "context" "fmt" "github.com/uber-go/tally" "go.uber.org/cadence/activity" "go.uber.org/cadence/workflow" ) func GreetingActivity(ctx context.Context, name string) (string, error) { return fmt.Sprintf("Hello %s", name), nil } func GreetingWorkflow(ctx workflow.Context, name string) (string, error) { ao := workflow.ActivityOptions{ ScheduleToStartTimeout: time.Minute, StartToCloseTimeout: time.Minute, } ctx = workflow.WithActivityOptions(ctx, ao) var result string err := workflow.ExecuteActivity(ctx, GreetingActivity, name).Get(ctx, &result) if err != nil { return "", err } return result, nil } ``` 上述代码片段展示了怎样注册 activity 函数并通过它们构建更高级别的 workflow 结构[^3]。 最后，在 worker 进程里分别登记刚才创建好的 activities 和 workflows 并开始监听来自客户端发起的新任务请求即可完成整个部署过程。 ###