如何创建自定义工作流程定义？

Cadence工作流是直接实现您的业务逻辑的代码。

对于用代码对业务逻辑进行硬编码的选择用例，则应编写外部工作流定义语言的解释器。这种语言通常称为DSL，因为它们在针对特定域实施时确实非常有用。DSL通常基于YAML / Json / XML。有时，它只是数据库表中的数据。

这是构造工作流代码以支持自定义DSL的方式：

1. 接收当前工作流程定义ID和状态并返回要执行的操作列表的活动。此活动将当前状态（包括对最近执行的操作的结果）应用于适当的DSL实例。结果是下一组要执行的操作。操作是特定于DSL的，但最常见的操作是执行活动，等待特定信号，休眠一段时间，完成或失败工作流程。
2. 工作流实现一个循环，该循环调用上述活动并执行请求的操作，直到请求工作流完成操作为止。

这是普通DSL的示例代码，它指定要执行的一系列活动：

public interface Interpreter {
  @ActivityMethod
  String getNextStep(String workflowType, String lastActivity);
}

public class SequenceInterpreter implements Interpreter {

  // dslWorkflowType->(activityType->nextActivity)
  private final Map<String, Map<String, String>> definitions;

  public SequenceInterpreter(Map<String, Map<String, String>> definitions) {
    this.definitions = definitions;
  }

  @Override
  public String getNextStep(String workflowType, String lastActivity) {
    Map<String, String> stateTransitions = definitions.get(workflowType);
    return stateTransitions.get(lastActivity);
  }
}

public interface InterpreterWorkflow {
  @WorkflowMethod
  String execute(String type, String input);
  @QueryMethod
  String getCurrentActivity();
}

public class InterpreterWorkflowImpl implements InterpreterWorkflow {

  private final Interpreter interpreter = Workflow.newActivityStub(Interpreter.class);

  private final ActivityStub activities =
      Workflow.newUntypedActivityStub(
          new ActivityOptions.Builder().setScheduleToCloseTimeout(Duration.ofMinutes(10)).build());

  private String currentActivity = "init";
  private String lastActivityResult;

  @Override
  public String execute(String workflowType, String input) {
    do {
      currentActivity = interpreter.getNextStep(workflowType, currentActivity);
      lastActivityResult = activities.execute(currentActivity, String.class, lastActivityResult);
    } while (currentActivity != null);
    return lastActivityResult;
  }

  @Override
  public String getCurrentActivity() {
    return currentActivity;
  }
}

显然，现实生活中的解释器活动将接收更复杂的状态对象作为参数，并返回可能包含多种命令类型列表的结构。