登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-04-22 15:54:34 185浏览 收藏

本篇文章给大家分享《如何创建自定义工作流程定义?》,覆盖了Golang的常见基础知识,其实一个语言的全部知识点一篇文章是不可能说完的,但希望通过这些问题,让读者对自己的掌握程度有一定的认识(B 数),从而弥补自己的不足,更好的掌握它。

问题内容

我们要求让用户创建自己的工作流程。这些工作流程可以具有简单的是/否分支以及等待来自外部事件的信号。如果我们有完善的工作流定义,这不会是一个问题,但是由于工作流可以是动态的,这会带来一个更棘手的问题。


解决方案


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

对于无法在代码中硬编码业务逻辑的用例,应编写外部工作流定义语言的解释器。这种语言通常称为 dsl,因为它们在针对特定领域实现时非常有用。 dsl 通常基于 yaml/json/xml。有时它只是数据库表中的数据。

以下是我如何构建工作流程代码以支持自定义 dsl:

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

下面是一个简单 dsl 的示例代码,它指定了要执行的一系列活动:

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

public class SequenceInterpreter implements Interpreter {

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

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

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

@WorkflowInterface    
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;
  }
}

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

好了,本文到此结束,带大家了解了《如何创建自定义工作流程定义?》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>