如何通过技能编排引擎解决复杂业务逻辑耦合问题

5次阅读

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

在订单履约、风控等复杂业务场景中，传统的 if-else 模式往往导致代码维护成本急剧上升。以订单履约系统为例，随着业务规则增多，代码的圈复杂度（Cyclomatic Complexity）可能超过 30，远高于推荐值 10。高圈复杂度不仅增加代码理解难度，还提高了测试用例的编写成本。

维护成本 ：每次新增业务规则需修改核心逻辑，容易引入回归缺陷
复用率低 ：相似逻辑在不同场景重复实现，违反 DRY 原则
扩展性差 ：硬编码流程难以应对业务快速变化

适用场景：以条件判断为主的业务规则（如促销折扣计算）
局限：流程控制能力弱，不适合多步骤业务流

适用场景：人工审批与系统交互混合的长流程（如贷款审批）
局限：学习曲线陡峭，过度设计简单业务

优势：
业务逻辑原子化，支持动态组合
天然适合微服务架构，与 Spring Cloud 生态无缝集成
轻量级实现，开发体验贴近常规编码

每个技能需明确定义：

public interface Skill<I, O> {
    /**
     * @param input 必须实现 Serializable
     * @return 执行结果
     * @throws SkillException 业务异常
     */
    O execute(I input) throws SkillException;

    /** 默认超时 3 秒 */
    default int timeoutMs() { return 3000;}
}

pipeline     = 1*step
step         = skill-call / parallel / conditional
skill-call   = "{" "skill" qualified-name 
               ["input" json-value] "}"
parallel     = "{" "parallel" 1*step "}"
conditional  = "{" "if" condition 
               "then" step 
               ["else" step] "}"

自动注册技能 Bean：

@Bean
public SkillScannerPostProcessor skillScanner() {
    return new SkillScannerPostProcessor("com.example.skills");
}

@SkillComponent("paymentService")
public class PaymentSkill implements Skill<PaymentRequest, Receipt> {
    @Override
    public Receipt execute(PaymentRequest input) {
        // 调用支付网关
        return gateway.charge(input);
    }
}

{
  "if": {
    "condition": "#order.amount > 10000",
    "then": {
      "parallel": [{"skill": "riskControlService", "input": "#order"},
        {"skill": "inventoryService", "input": "#order.items"}
      ]
    },
    "else": {"skill": "fastCheckoutService"}
  }
}

本地缓存 ：对幂等技能缓存结果（Guava Cache）
异步化 ：IO 密集型技能使用 @Async 注解

集成 Hystrix 实现降级：

@HystrixCommand(
    fallbackMethod = "defaultResult",
    commandProperties = {
        @HystrixProperty(
            name="execution.isolation.thread.timeoutInMilliseconds",
            value="2000")
    })
public Receipt execute(PaymentRequest input) {// ...}

通过 SkyWalking 自动埋点：

@Trace(operationName = "skill/payment")
@Tags({@Tag(key = "orderId", value = "arg[0].orderId")})
public Receipt execute(PaymentRequest input) {// ...}