Cadence Skill Language 实战指南：从工作流设计到生产环境避坑

1次阅读

共计 2821 个字符，预计需要花费 8 分钟才能阅读完成。

在微服务架构中，一个业务操作往往需要跨多个服务协作完成（比如电商下单涉及库存扣减、支付、物流等）。传统代码实现会面临三大难题：

状态持久化问题：服务重启后如何恢复执行上下文？
长事务管理：半小时的订单超时检查如何避免阻塞线程？
协调复杂度：支付失败后如何自动触发补偿退款？

手动处理这些问题需要大量样板代码，而 Cadence Skill Language 通过声明式语法将工作流逻辑与底层稳定性解耦。

特性	Cadence	Temporal	Airflow
编程模型	代码定义工作流	代码定义工作流	DAG 配置文件定义
状态存储	自带持久化层	依赖外部数据库	依赖数据库
错误恢复	自动断点续传	自动断点续传	手动重试
适用场景	复杂业务流	通用工作流	定时批处理

@WorkflowInterface
public interface OrderProcessingWorkflow {
    @WorkflowMethod
    void processOrder(String orderId, BigDecimal amount);

    @SignalMethod
    void updateDeliveryAddress(String newAddress);

    @QueryMethod
    OrderStatus getCurrentStatus();}

关键注解说明：

@WorkflowMethod：标记工作流入口方法，执行时会自动生成唯一 WorkflowId
@SignalMethod：允许外部主动推送事件（如修改收货地址）
@QueryMethod：提供实时状态查询接口

RetryOptions retryOptions = new RetryOptions.Builder()
    .setInitialInterval(Duration.ofSeconds(1))
    .setMaximumInterval(Duration.ofMinutes(10))
    .setBackoffCoefficient(2.0)
    .setMaximumAttempts(5)
    .setDoNotRetry(IllegalArgumentException.class) // 非法参数不重试
    .build();

public class OrderProcessingWorkflowImpl implements OrderProcessingWorkflow {
    private OrderStatus status = OrderStatus.CREATED;
    private String deliveryAddress;

    @Override
    public void processOrder(String orderId, BigDecimal amount) {
        // 1. 验证订单
        ActivityOptions options = new ActivityOptions.Builder()
            .setTaskQueue("validation-queue")
            .setScheduleToCloseTimeout(Duration.ofMinutes(1))
            .build();
        ValidationActivities validator = Workflow.newActivityStub(ValidationActivities.class, options);
        validator.validateOrder(orderId);

        // 2. 扣减库存（带自动重试）status = OrderStatus.INVENTORY_CHECKING;
        InventoryActivities inventory = Workflow.newActivityStub(
            InventoryActivities.class, 
            new ActivityOptions.Builder().setRetryOptions(retryOptions).build());
        inventory.reserveItems(orderId);

        // 3. 等待支付结果（最长等待 30 分钟）status = OrderStatus.AWAITING_PAYMENT;
        Workflow.await(Duration.ofMinutes(30), () -> paymentReceived);

        // 4. 触发物流
        if (paymentReceived) {ShippingActivities shipping = Workflow.newActivityStub(ShippingActivities.class);
            shipping.scheduleDelivery(orderId, deliveryAddress);
            status = OrderStatus.COMPLETED;
        } else {inventory.cancelReservation(orderId);
            status = OrderStatus.CANCELLED;
        }
    }

    // 信号处理方法
    @Override
    public void updateDeliveryAddress(String newAddress) {this.deliveryAddress = newAddress;}
}

活动任务分片：对大数组处理拆分为并行子任务

List<Workflow.ChildWorkflowFuture<Integer>> futures = new ArrayList<>();
for (int i = 0; i < 100; i++) {futures.add(Workflow.newChildWorkflowStub(ProcessItemWorkflow.class).process(itemIds[i]));
}
List<Integer> results = futures.stream().map(Workflow.ChildWorkflowFuture::get).collect(Collectors.toList());