Temporal¶

在这篇文章中

• Temporal 主要功能
• 部署功能
• 部署 Temporal 后的入门指南
• 主屏幕和导航
• 使用 Go 测试 Temporal（可选）
• 通过 API 订购 Temporal 服务器

Temporal 主要功能¶

• 工作流编排： 提供长时间运行的业务流程的稳健执行。自动处理故障和重试，保证任务完成。
• 分布式事务： 确保在不同服务之间一致地执行操作，而无需使用分布式锁。
• 超时和调度： 允许设置定时器和调度任务，即使对于长时间运行的流程也能保持高精度。
• 可扩展性： 支持水平扩展以处理高负载。组件可以独立扩展。
• 历史调试： 保留流程执行的历史记录，便于分析和调试工作流。
• 版本控制： 支持在不中断运行中的任务的情况下安全更新工作流。
• 可观测性： 与监控和跟踪系统集成，以便控制应用程序。
• 多租户： 为多个团队或应用程序提供隔离和资源管理。

部署功能¶

• 预装依赖项：
  • Docker；
  • Git（用于克隆存储库）。
• 附加组件：
  • Nginx（用于反向代理）；
  • Postgresql（数据库）；
  • Elasticsearch（用于工作流历史记录存储）；
  • Grafana（用于监控）；
  • Prometheus（用于指标收集）；
  • Jaeger（用于分布式跟踪）；
  • OpenTelemetry Collector（用于遥测收集）。
• 项目目录：/root/docker-compose
• 自定义文件：/root/docker-compose/docker-compose-multirole_edited.yaml

具有 Web 界面的主要组件：

部署 Temporal 后的入门指南¶

付款后，服务器就绪的通知将发送到您注册的电子邮件地址。其中将包含 VPS IP 地址和登录凭据以进行访问。我们公司的客户通过 服务器管理面板和 API — Invapi 管理硬件。

点击 webpanel 标签中的链接后，将打开授权窗口。

授权数据可以在服务器管理面板的 Configuration >> Tags 选项卡或发送的电子邮件中找到：

• 通过 Web 界面访问 Temporal 管理面板的链接：在 webpanel 标签中；
• Login 和 Password 用于管理服务器：在服务器交付时通过电子邮件提供。

主屏幕和导航¶

点击 webpanel 标签中的链接后，将打开 Temporal Web 界面：

主屏幕显示所选命名空间中的工作流列表 (Workflows)。消息“No Workflows running in this Namespace”表示当时没有活动进程。

界面的主要元素：

• 左侧的 Sidebar 提供对系统不同部分的访问；
• Top bar 显示当前命名空间（默认为“default”）；
• 右上角的 Start Workflow 按钮用于启动新进程；
• Process table 包含 Status、Workflow ID、Run ID、Type、Start、End 列。

功能能力

1. 启动新的工作流进程：

   • 点击右上角的 Start Workflow 按钮；
   • 在出现的表单中填写必要的参数；
   • 确认进程创建。

2. 查看和过滤进程：

   • 使用 Filter 按钮根据各种条件选择进程；
   • 从表中选择任何进程以查看详细信息。

3. 代码示例：

   • 通过 GitHub 存储库链接访问集成示例：
   • samples-go - Go 示例；
   • samples-java - Java 示例；
   • samples-typescript - TypeScript 示例；
   • samples-python - Python 示例；
   • samples-dotnet - .NET 示例；
   • samples-php - PHP 示例。

4. 更改设置：

   • 右上角的 UTC 选择器用于更改时区；
   • (Gear) 按钮用于访问额外的界面设置。

典型用例：

• 监控进程：定期检查运行中任务的状态；
• 调试：在发生故障时详细分析错误；
• 管理工作负载：启动、暂停和取消进程；
• 开发新进程：使用代码示例创建自定义工作流。

使用 Go 测试 Temporal（可选）¶

1. 安装 Go¶

在开始测试之前，在服务器上安装 Go：

更新包列表

apt update

apt install -y wget git curl

wget https://golang.org/dl/go1.22.1.linux-amd64.tar.gz

tar -C /usr/local -xzf go1.22.1.linux-amd64.tar.gz

echo 'export PATH=$PATH:/usr/local/go/bin' >> ~/.bashrc

echo 'export GOPATH=$HOME/go' >> ~/.bashrc

echo 'export PATH=$PATH:$GOPATH/bin' >> ~/.bashrc

source ~/.bashrc

go version

2. 克隆 Temporal 示例存储库¶

进入主目录

cd ~

git clone https://github.com/temporalio/samples-go.git

cd samples-go

3. 使用 Saga 示例进行测试¶

Saga 模式用于管理分布式事务，确保在发生错误时能够回滚（补偿）。

Saga 示例的结构

saga/
├── worker/main.go     # 处理任务的 Worker 进程
├── start/main.go      # 初始化 Worker 进程
├── activity.go        # 动作定义（取款/存款）
├── workflow.go        # 动作序列定义
└── shared.go          # 通用定义

运行测试：

1. 启动 Worker（在第一个终端中执行）：

   cd ~/samples-go
   go run saga/worker/main.go
   

   Worker 将向 Temporal 注册并等待任务。将出现有关尝试获取任务的日志消息。

2. 启动 Starter（在第二个终端中执行）：

   cd ~/samples-go
   go run saga/start/main.go
   

   Starter 启动从一个账户向另一个账户转账的过程。

预期结果：

在 Worker 的日志中，您将看到：

1. 从账户 001-001 取款；
2. 向账户 002-002 存款；
3. 在 activity StepWithError 中专门创建的错误；
4. 三次尝试执行有故障的 activity；
5. 启动补偿操作：
   • 将资金返回到原始账户；
   • 取消取款。

4. 通过 Temporal Web 界面验证结果¶

1. 在浏览器中打开 Temporal Web 界面（通过 webpanel 标签）；
2. 在界面中，找到 ID 为 transfer-money-workflow 的工作流；
3. 您将看到工作流的完整执行历史记录，包括所有活动和补偿操作：

通过 API 订购 Temporal 服务器¶