Cadence技能创建窗口：从零开始的实战指南与避坑技巧

1次阅读

共计 2096 个字符，预计需要花费 6 分钟才能阅读完成。

Cadence 是一个用于构建分布式应用的编排引擎，它通过持久化的工作流状态和自动恢复机制，解决了分布式系统中的可靠性问题。技能创建窗口是 Cadence 中一个重要的概念，它允许开发者定义和管理工作流的执行逻辑。对于新手来说，掌握技能创建窗口的实现是使用 Cadence 的第一步。

在开始之前，我们需要理解几个关键术语：

工作流（Workflow）：工作流是 Cadence 中的核心概念，它定义了业务流程的执行逻辑。工作流可以包含多个活动（Activity），并且可以处理决策（Decision）。
活动（Activity）：活动是工作流中的一个具体任务，比如调用外部服务或执行计算。活动通常是无状态的，可以被多次重试。
决策器（Decider）：决策器负责根据当前工作流状态决定下一步执行哪个活动或分支。

首先，你需要配置 Cadence 服务端。以下是安装和启动 Cadence 的步骤：

下载并安装 Cadence 服务端：

docker run --rm -it -p 7933-7935:7933-7935 -p 7939:7939 ubercadence/local:latest

验证服务是否正常运行：
```
curl http://localhost:7933/health
```

以下是一个简单的工作流定义示例，用 Go 语言实现：

package main

import (
    "context"
    "time"

    "go.uber.org/cadence/activity"
    "go.uber.org/cadence/workflow"
    "go.uber.org/zap"
)

// 定义工作流
func SimpleWorkflow(ctx workflow.Context, name string) (string, error) {
    // 定义工作流选项
    ao := workflow.ActivityOptions{
        ScheduleToStartTimeout: time.Minute,
        StartToCloseTimeout:    time.Minute,
        HeartbeatTimeout:       time.Second * 20,
    }
    ctx = workflow.WithActivityOptions(ctx, ao)

    // 执行活动
    var result string
    err := workflow.ExecuteActivity(ctx, SimpleActivity, name).Get(ctx, &result)
    if err != nil {return "", err}

    return result, nil
}

// 定义活动
func SimpleActivity(ctx context.Context, name string) (string, error) {logger := activity.GetLogger(ctx)
    logger.Info("Activity started", zap.String("name", name))
    return "Hello" + name + "!", nil
}

活动的实现通常是无状态的，可以包含任何业务逻辑。以下是一个带注释的活动示例：

// SimpleActivity 是一个简单的活动示例
func SimpleActivity(ctx context.Context, name string) (string, error) {
    // 获取活动上下文中的日志记录器
    logger := activity.GetLogger(ctx)
    logger.Info("Activity started", zap.String("name", name))

    // 模拟业务逻辑
    result := "Hello" + name + "!"

    // 返回结果
    return result, nil
}

问题描述：工作流定义后无法启动，日志中没有错误信息。

解决方案：检查工作流注册是否正确，确保工作流和活动在 Worker 中正确注册。

问题描述：活动执行超时，工作流卡住。

解决方案 ：调整活动的ScheduleToStartTimeout 和StartToCloseTimeout参数，确保超时时间足够长。

问题描述：工作流状态与预期不符，可能由于决策器逻辑错误。

解决方案：检查决策器逻辑，确保所有分支都正确处理。