历史回放如何以节奏工作？

Question

历史回放如何在抑扬顿挫中发挥作用？

我有一个按顺序调用两个活动的工作流。

比方说，第一个活动完成了，第二个活动有100行代码。如果应用服务器在执行activity2中的第50行代码时重新启动，它会从第50行开始执行吗？如果是，cadence内部正在发生什么神奇的事情？

@Override
    public String composeGreeting(String greeting, String name) throws Exception {
      FileWriter fw =
          new FileWriter(
              "/Users/kumble-004/Documents/Uber_Cadence/Sample_Projects/TestCadence/src/com/company/"+name+".txt");

      System.out.println(
          DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss").format(LocalDateTime.now())
              + " [Activity] started");

      long time = System.currentTimeMillis() + 240000;
      int i = 0, j=1;

      while (System.currentTimeMillis() != time) {
        if(i++ %10000000 == 0) {
          fw.write("print - " + j++ + " " +
                  DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss").format(LocalDateTime.now()) +"\n");
        }
      }
      fw.close();
      System.out.println(
          DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss").format(LocalDateTime.now())
              + " [Activity] ended");

      return greeting + " " + name + "!";
    }
  }

我的hello活动中有上面的代码。此代码将运行4分钟，当条件满足时，它将在文件中写入数据

我启动了一个工作流，并在打印[活动]开始后退出了节奏服务器。我没有启动它只是停止了它。但4分钟后，它正好打印[活动]在控制台中结束。我想知道这怎么可能，因为我停止了服务器，但代码正在执行，数据正在写入文件。

当我通过节奏用户界面检查它时，它显示最后的历史记录是ActivityTaskStarted。我启动了我的服务器。15分钟后（因为计划是15分钟）活动返回事件ActivityTaskTimedOut，由于超时，整个whorkflow都失败了。

请解释重新启动节奏服务器时发生了什么？

Answer 1

如果应用服务器在执行activity2中的第50行代码时重启，它会从第50行开始执行吗

不，它不会从第50行自动恢复。

重放仅发生在工作流中。它依靠历史来重放和重建内存堆栈。工作流中发生的所有事情都存储在历史记录中:

• 工作流代码中的每一步，都会生成一堆名为“决策”的结果
• 活动/ChildWorkflow结果
• 信号等外部事件
• 计时器
• 等等。

有关更多详细信息，请参阅有关重播历史记录的文档，以及什么是节奏决策任务？

但4分钟后，它正在打印[活动]在控制台中结束。我想知道这怎么可能，因为我停止了服务器，但代码正在执行，数据正在写入文件。

那是因为你的活动工作者还在运行。您运行的代码纯粹是活动代码。

但是，当服务器关闭时，它活动结果将无法报告给服务器。这意味着历史记录将丢失它，工作流可能会重新安排另一个活动（如果启用重试）。

请参考关于活动超时的文档，然后重试