评估temporal.io替代Camunda：BPMN User Task等效方案及实现咨询

一、阻塞逻辑不应放在Activity或服务内部 #

绝对不建议将阻塞等待逻辑嵌入Activity或业务服务中，原因如下：

• Temporal的Activity设计定位是短周期、幂等、可重试的原子操作，长时间阻塞会持续占用Worker资源，违背其执行模型。
• 若Activity抛出异常触发默认重试机制，会导致重复生成人工任务或重复调用外部服务，直接破坏流程的确定性。

正确的做法是：让工作流本身显式处理阻塞等待逻辑，保持流程定义的清晰与确定性——当需要等待外部事件（人工操作、外部服务回调）时，让工作流进入可控的等待状态，而非让Activity挂起。

二、用Workflow Signals模拟BPMN User Task（推荐方案） #

Temporal的Workflow Signals正是为处理外部事件驱动流程继续而设计的，完全匹配BPMN User Task的阻塞等待场景，具体实现方式如下：

1. 工作流中实现信号等待逻辑 #

在工作流定义里，通过信号处理方法+状态变量，结合Workflow.await()实现阻塞等待：

// 定义信号接口，用于接收外部完成通知
public interface UserTaskCompletedSignal {
    void signal(String taskId, String approvalResult);
}

public class BusinessWorkflowImpl implements BusinessWorkflow {
    private String taskResult;
    private boolean isTaskCompleted;

    @Override
    public void executeBusinessFlow() {
        // 1. 执行前置Activity：触发人工任务生成（比如调用服务创建待办）
        TaskActivities.generateUserTask("order-review-001");

        // 2. 阻塞等待信号：直到人工任务完成
        Workflow.await(() -> isTaskCompleted);

        // 3. 信号收到后，继续后续业务逻辑
        OrderActivities.processApprovalResult(taskResult);
    }

    // 信号处理方法：接收外部传来的任务完成信息
    @SignalMethod
    public void handleUserTaskCompleted(String taskId, String approvalResult) {
        this.taskResult = approvalResult;
        this.isTaskCompleted = true;
    }
}

• 工作流会持久化等待状态，即使Worker重启，也会从等待点恢复执行，完全保证流程确定性。
• 若需等待多个阻塞任务，可维护计数器，每个信号触发时递减，直到计数器归0再继续流程。
• 可给等待设置超时，避免永久阻塞：Workflow.await(Duration.ofHours(24), () -> isTaskCompleted)，超时后可触发异常处理分支。

2. 外部服务向特定工作流实例发送信号 #

通过Temporal SDK的WorkflowClient，指定目标工作流ID（或Run ID，用于区分同一工作流的多次运行）发送信号，以Java为例：

// 初始化Temporal客户端
WorkflowClient client = WorkflowClient.newInstance(temporalService);

// 通过工作流ID获取工作流Stub
BusinessWorkflow workflowStub = client.newWorkflowStub(
    BusinessWorkflow.class,
    WorkflowOptions.newBuilder().setWorkflowId("order-flow-001").build()
);

// 将Stub转换为信号接口并发送信号
UserTaskCompletedSignal signalStub = WorkflowClient.newSignalStub(UserTaskCompletedSignal.class, workflowStub);
signalStub.signal("order-review-001", "approved");

其他语言（Go/Python/TypeScript）逻辑一致：通过工作流ID定位实例，调用信号方法传递参数即可。

内容的提问来源于stack exchange，提问作者Tuomas Toivonen