如何从Uber Cadence中的Java代码获取打开/关闭的工作流列表？

Uber Cadence 是一个用于编排微服务的分布式工作流引擎。要从 Cadence 中的 Java 代码获取打开/关闭的工作流列表，你需要使用 Cadence 提供的客户端 API。以下是获取这些列表的基本步骤：

基础概念

工作流（Workflow）：在 Cadence 中，工作流是一系列任务的集合，这些任务可以并行或顺序执行，以完成一个业务逻辑。
工作流执行（Workflow Execution）：工作流的每次运行都被称为一个执行。
打开的工作流（Open Workflow）：尚未完成的工作流执行。
关闭的工作流（Closed Workflow）：已经完成（成功、失败或被取消）的工作流执行。

类型

状态机工作流：基于状态机模型定义工作流。
活动工作流：包含执行外部任务（活动）的工作流。

应用场景

订单处理系统：跟踪订单从创建到完成的整个流程。
复杂的数据处理：如 ETL（提取、转换、加载）作业。
微服务协调：协调多个微服务以完成一个业务流程。

获取打开/关闭的工作流列表

要获取打开或关闭的工作流列表，你需要使用 Cadence 的 Java 客户端库。以下是一个简单的示例代码：

import com.uber.cadence.client.WorkflowClient;
import com.uber.cadence.client.WorkflowOptions;
import com.uber.cadence.client.Workflow;
import com.uber.cadence.workflow.WorkflowExecution;
import com.uber.cadence.workflow.WorkflowExecutionFilter;
import com.uber.cadence.workflow.WorkflowQuery;

public class WorkflowListExample {

    public static void main(String[] args) {
        // 创建 WorkflowClient
        WorkflowClient workflowClient = WorkflowClient.newInstance("localhost:7933");

        // 获取打开的工作流列表
        WorkflowQuery openWorkflowsQuery = WorkflowQuery.newBuilder()
                .setWorkflowExecutionFilter(WorkflowExecutionFilter.newBuilder().setLatestDate(null).build())
                .build();
        List<WorkflowExecution> openWorkflows = workflowClient.newWorkflowStub("your-domain", openWorkflowsQuery).listOpenWorkflowExecutions();

        // 获取关闭的工作流列表
        WorkflowQuery closedWorkflowsQuery = WorkflowQuery.newBuilder()
                .setWorkflowExecutionFilter(WorkflowExecutionFilter.newBuilder().setLatestDate(null).build())
                .build();
        List<WorkflowExecution> closedWorkflows = workflowClient.newWorkflowStub("your-domain", closedWorkflowsQuery).listClosedWorkflowExecutions();

        // 打印结果
        System.out.println("Open Workflows: " + openWorkflows);
        System.out.println("Closed Workflows: " + closedWorkflows);

        // 关闭 WorkflowClient
        workflowClient.close();
    }
}