如何返回信号的处理结果？

Question

特别是如果信号处理需要调用一个/一些活动，我如何实现？

我试图返回数据或异常，但它不起作用。

无法从信号方法返回数据。抛出异常将阻止工作流执行。

Answer 1

在信号方法中返回数据或抛出异常是错误的，因为信号方法是异步的。处理过程必须类似于Kafka处理消息，并且不能通过方法返回结果。

所以下面的代码不起作用：

public class SampleWorkflow{
   public Result mySignalMethod(SignalRequest req){
      Result result = activityStub.execute(req)
      if(...){
          throw new RuntimeException(...)
      }
   return result
   }

}

你必须做什么：

• 确保信号不返回任何内容
• 使用查询方法返回结果
• 在信号方法处理中，将结果存储到工作流状态中，以便查询可以返回状态

如果您还使用设计模式将信号请求存储到队列中，并让工作流方法来处理信号，这将为您带来一些好处。

• 保证信号处理的FIFO排序
• 确保重置工作流不会遇到问题——重置后，信号将被保留并移动到工作流历史记录的早期位置。有时工作流不会初始化以重放信号。
• 也使异常处理更容易

请参见示例代码中的设计模式:Cadence Java sample/Temporal Java sample

如果我们应用了以上所有内容，示例代码应该如下所示:

public class SampleWorkflow{

   private Queue<SignalRequest> queue = new Queue<>();
   private Response<Result> lastSignalResponse;

   public void myWorkflowMethod(){
        Async.procedure(
                () -> {
                    while (true) {
                        Workflow.await(() -> !queue.isEmpty());
                        final SignalRequest req =
                                queue.poll();
                        // alternatively, you can use async to start an activity:  
                        try{
                             Result result = activityStub.execute(req); 
                        }catch (ActivityException e){
                             lastSignalResponse = new Response( e );
                        }

                        if(...){
                            lastSignalResponse = new Response( new RuntimeException(...) );
                        }else{
                             lastSignalResponse = new Response( result);  
                        }
                    }
                });

      ...
   }

   public Response myQueryMethod(){
       return lastSignalResponse;
   }

   public Result mySignalMethod(SignalRequest req){
      queue.add(req)
   }

}

在应用程序代码中，您应该发出信号，然后查询工作流以获得结果：

  workflowStub.mySignalMethod(req)
  Response response = workflowStub.myQueryMethod()

如果您想使用aysnc活动，请遵循以下示例节奏/示例时间

• 信号通过工作流决策任务（时态工作流任务）执行。决策任务不能返回结果。在当前设计中，没有让决策任务将结果返回到应用html" target="_blank">程序代码的机制。
• 工作流代码中的抛出异常将阻止决策任务或使工作流失败）。
• 查询方法旨在返回结果 - 但是，查询无法计划活动或修改工作流状态。
• 缺少让应用代码进行同步 API 调用以更新和返回数据。它需要一个复杂的设计：https://github.com/temporalio/proposals/pull/53