如何在循环中使用Cadence/Temporal版本API适配运行中工作流

假设有一个包含10次循环活动的工作流，代码实现如下：

public class LoopWorkflowImpl implements LoopWorkflow{
   private final Api api = Workflow.newActivityStub(Api.class, ...)

   @Override
   public int start(){
        int sum = 0;
        for(int i=0; i<10; i++){
             sum += api.getCount();
        }
        return sum;
   }
}

现需将其中的api.getCount()调用改为api.getCountV2()，对于已完成5次api.getCount()调用的运行中工作流，如何让其剩余5次调用使用api.getCountV2()？同时请说明如何在循环中使用Cadence/Temporal的版本控制API（workflow.getVersion）。

解决方案 #

一、处理运行中已完成5次循环的工作流 #

Temporal/Cadence的工作流依赖事件重放机制恢复执行，直接替换方法名会导致重放失败——历史事件里记录的是getCount调用，新代码无法匹配对应逻辑。要实现兼容，必须通过版本控制API区分新旧逻辑，让已完成的循环沿用旧逻辑，未执行的循环切换新逻辑。

二、循环中使用版本控制API的具体实现 #

修改后的代码示例：

public class LoopWorkflowImpl implements LoopWorkflow{
   private final Api api = Workflow.newActivityStub(Api.class, ...);
   // 定义版本标识与版本号
   private static final String COUNT_API_VERSION = "COUNT_API_VERSION";
   private static final int VERSION_V1 = 0;
   private static final int VERSION_V2 = 1;

   @Override
   public int start(){
        int sum = 0;
        for(int i=0; i<10; i++){
            // 每次循环前检查版本
            int currentVersion = Workflow.getVersion(
                COUNT_API_VERSION,
                VERSION_V1,
                VERSION_V2
            );
            if (currentVersion == VERSION_V1) {
                sum += api.getCount();
            } else {
                sum += api.getCountV2();
            }
        }
        return sum;
   }
}

核心逻辑说明：

• Workflow.getVersion会将当前执行使用的版本号写入工作流历史事件。
• 已完成5次循环的工作流，前5次循环的历史中记录的是VERSION_V1，重放时会自动执行getCount；第6到10次循环无对应历史记录，会使用最新的VERSION_V2，从而调用getCountV2。
• 新启动的工作流会直接使用VERSION_V2，全程调用getCountV2。

待所有旧工作流执行完成后，可清理旧版本逻辑——使用Workflow.getVersion的重载方法（仅传入当前版本号），彻底移除VERSION_V1相关代码。

内容的提问来源于stack exchange，提问作者Long Quanzheng