从基础到实践：深入解析Skill与MCP的核心区别及适用场景

2次阅读

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

去年参与某电商促销系统时，团队将库存扣减服务错误地设计为 MCP（Microservice Choreography Pattern，微服务编排模式），结果在秒杀场景下出现了严重的性能瓶颈：

每次库存操作触发 6 个服务的串行调用链
99 线延迟高达 800ms（测试环境：4 核 8G Pod × 3 实例，JMeter 500 并发）
最终改用 Skill（Service Skill，服务技能）模式后，延迟降低至 120ms

另一个典型案例是某银行转账系统误用 Skill 处理跨行交易，导致：

部分补偿操作缺失
资金对账出现差错的概率达 0.3%
不得不通过人工干预修复数据

维度	Skill	MCP
核心目标	轻量级原子操作	分布式事务流程控制
典型场景	商品详情查询、单表 CRUD	订单创建、跨系统资金转账
失败处理	快速重试或降级	Saga 模式补偿事务

协议	Skill 适用性	MCP 适用性
HTTP/1.1	★★★★★	★★☆☆☆
gRPC	★★★☆☆	★★★★★
RabbitMQ	★★☆☆☆	★★★★☆
Kafka	★☆☆☆☆	★★★★★

指标	Skill（Go 实现）	MCP（Java 实现）
平均延迟	12ms	210ms
QPS	8500	1200
CPU 占用	8%	35%
内存消耗	120MB	480MB

@RestController
public class ProductSkill {

    // @Skill 注解标识轻量级服务单元
    @Skill(name="priceQuery", version="1.0")
    @GetMapping("/products/{id}/price")
    public ResponseEntity<BigDecimal> getPrice(
        @PathVariable Long id,
        @RequestParam(required=false) String currency) {

        // 幂等性设计：相同 ID 请求总返回相同结果
        Product product = repository.findById(id)
            .orElseThrow(() -> new ProductNotFoundException(id));

        return ResponseEntity.ok(currencyService.convert(product.getPrice(), currency)
        );
    }
}

@Saga
public class OrderProcessingSaga {

    @StartSaga
    @SagaEventHandler(associationProperty="orderId")
    public void handle(OrderCreatedEvent event) {
        // 开启分布式事务
        commandGateway.send(new ReserveInventoryCommand(event.getOrderId(), 
            event.getItems()));
    }

    @SagaEventHandler(associationProperty="orderId")
    public void handle(InventoryReservedEvent event) {
        commandGateway.send(new ProcessPaymentCommand(event.getOrderId(),
            event.getAmount()));
    }

    // 补偿事务示例
    @SagaEventHandler(associationProperty="orderId")
    public void handle(PaymentFailedEvent event) {
        commandGateway.send(new CancelInventoryReservationCommand(event.getOrderId()
        ));
        // 记录事务终止状态
        SagaLifecycle.end();}
}

幂等性保障：
为所有写操作添加唯一请求 ID
采用数据库唯一索引防重
实现请求指纹校验（如 SHA-256 摘要）

熔断配置：

resilience4j.circuitbreaker:
  instances:
    priceQuery:
      failureRateThreshold: 50
      waitDurationInOpenState: 10s
      slidingWindowSize: 20

雪崩预防：
每个 Saga 阶段设置独立超时（建议≤2s）
实现断路器级联检测
采用 Bulkhead 模式隔离资源
监控重点：
Saga 完成率（需 >99.9%）
补偿事务触发频率（警戒线 >1%）
阶段执行时长分布（P99≤300ms）

graph TD
    A[业务需求] -->| 简单查询 / 单一操作 | B(Skill)
    A -->| 跨服务事务 | C(MCP)
    B --> D{延迟要求?}
    D -->|≤50ms| E[HTTP+ 缓存]
    D -->|>50ms| F[gRPC]
    C --> G{数据一致性?}
    G -->| 强一致 | H[Saga+DB 锁]
    G -->| 最终一致 | I[事件溯源]