业务相关Skill开发实战：从设计原则到代码实现

2次阅读

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

在业务系统开发中，Skill 作为核心业务能力的载体，常常面临几个典型问题：

紧耦合问题：业务逻辑与框架代码深度绑定，导致修改成本高
状态混乱：业务流程中的状态流转缺乏统一管理，容易产生脏数据
异常处理缺失：对边界条件和异常场景考虑不足，系统健壮性差

这些痛点直接影响系统的可维护性和扩展性。以一个订单处理 Skill 为例，当需要增加新的支付方式时，如果业务逻辑与支付接口强耦合，就不得不修改核心代码。

def process_order(order_data):
    # 验证数据
    # 计算金额
    # 调用支付
    # 更新库存
    # ...

优点：逻辑直观，适合简单场景
缺点：随着业务复杂化，函数会膨胀成难以维护的 ” 巨无霸 ”

class OrderService {
    private PaymentGateway paymentGateway;
    private InventoryRepo inventoryRepo;

    public OrderResult process(Order order) {// ...}
}

优点：通过封装降低复杂度
缺点：大型类仍然可能成为 ” 上帝对象 ”

process_order = (
    validate_order
    >> calculate_amount
    >> process_payment
    >> update_inventory
)

优点：无副作用，易于测试
缺点：学习曲线陡，业务表达不如 OO 直观

// 订单聚合根
public class Order {
    private OrderId id;
    private List<OrderItem> items;
    private OrderStatus status;

    public void addItem(ProductId productId, int quantity) {// 业务规则校验}
}

关键点：

通过聚合根维护业务一致性边界
值对象 (如 OrderId) 增强领域表现力
仓储接口隔离持久化细节

class OrderStatus(ABC):
    @abstractmethod
    def proceed(self, order): pass

class PaidStatus(OrderStatus):
    def proceed(self, order):
        if order.validate_inventory():
            order.change_status(PreparingStatus())

优势：

状态转换逻辑集中管理
避免大量 if-else 分支
方便新增状态类型

通过装饰器模式实现：

@Idempotent(key = "#order.id", ttl = 24*3600)
public OrderResult processOrder(Order order) {// ...}

其中注解实现：

@Around("@annotation(idempotent)")
public Object checkIdempotent(ProceedingJoinPoint pjp, Idempotent idempotent) {String key = parseKey(pjp, idempotent);
    if (redis.setIfAbsent(key, "processing")) {
        try {return pjp.proceed();
        } finally {redis.delete(key);
        }
    }
    throw new IdempotentException("Duplicate request");
}

乐观锁：适合冲突率低的场景

UPDATE orders SET version = version + 1 
WHERE id = ? AND version = ?

分布式锁：强一致性要求时使用

try (Lock lock = redisson.getLock("order:"+orderId)) {if (lock.tryLock()) {// 处理业务}
}

TPS 提升：通过批处理减少 IO 次数
RT 降低：
异步化非核心流程
本地缓存热点数据

示例异步处理：

@celery.task
def async_process_payment(order_id):
    # 耗时操作

resilience4j.circuitbreaker:
  instances:
    paymentService:
      failureRateThreshold: 50
      waitDurationInOpenState: 10s
      ringBufferSizeInClosedState: 100

反例：

void process() {orderRepo.save(order); // 事务 1
    paymentService.charge(); // 事务 2
    inventoryService.reduce(); // 事务 3}

修正：

@Transactional
void process() {// 所有操作在同一个事务中}

反例：

def process(order):
    logger.info(f"Start processing {order}")  # 可能泄露敏感信息

修正：

def process(order):
    logger.debug("Order processing", 
        extra={"orderId": order.id})  # 只记录必要字段

反例：

class PaymentService {private static final String URL = "http://prod-pay";}

修正：

@Value("${payment.url}")
private String paymentUrl;

业务 Skill 的终极形态应该是可复用的领域能力：

通过标准化接口暴露核心能力
使用适配器模式对接不同上下游
设计领域事件实现系统解耦

示例事件发布：

class OrderService {
    @Autowired
    private DomainEventPublisher publisher;

    public void complete(Order order) {publisher.publish(new OrderCompletedEvent(order));
    }
}

在实际项目中，建议建立业务 Skill 矩阵，明确各 Skill 的输入输出契约，这样才能真正构建灵活可扩展的业务系统。

开发高质量的业务 Skill 需要：