微服务架构设计：拆分、通信与治理

什么是微服务？

微服务架构将单体应用拆分为多个小型服务，每个服务：

• 独立部署和扩展
• 围绕业务能力组织
• 拥有自己的数据存储
• 通过轻量级协议通信

1. 服务拆分原则

单一职责原则

每个服务只做一件事：

• 用户服务：用户管理、认证
• 订单服务：订单处理
• 支付服务：支付处理
• 库存服务：库存管理

领域驱动设计（DDD）

┌─────────────────────────────────────┐
│           限界上下文               │
│  ┌─────────┐  ┌─────────┐          │
│  │ 用户聚合 │  │ 订单聚合 │          │
│  └─────────┘  └─────────┘          │
│  ┌─────────┐  ┌─────────┐          │
│  │ 支付聚合 │  │ 库存聚合 │          │
│  └─────────┘  └─────────┘          │
└─────────────────────────────────────┘

2. 服务通信

同步通信（HTTP/RPC）

// REST API
GET /api/users/123
POST /api/orders

// gRPC（更高效）
service UserService {
  rpc GetUser(GetUserRequest) returns (User);
}

异步通信（消息队列）

// 事件驱动架构
// 订单服务发布事件
producer.send("order.created", {orderId: 123});

// 库存服务消费事件
consumer.on("order.created", async (event) => {
  await reduceStock(event.orderId);
});

3. 服务发现

# Consul 配置
services:
  - name: user-service
    port: 8080
    check:
      http: http://localhost:8080/health
      interval: 10s

4. API 网关

网关作为统一入口：

• 路由转发
• 认证授权
• 限流熔断
• 日志监控

# Kong 配置
routes:
  - name: user-route
    paths: ["/users"]
    services: user-service
    plugins:
      - jwt-auth
      - rate-limiting

5. 数据一致性

Saga 模式

// 编排式 Saga
async function createOrder(orderData) {
  try {
    await orderService.create(orderData);
    await inventoryService.reserve(orderData.items);
    await paymentService.charge(orderData.payment);
  } catch (error) {
    // 执行补偿操作
    await paymentService.refund(orderData.payment);
    await inventoryService.release(orderData.items);
    await orderService.cancel(orderData.id);
  }
}

6. 容错与弹性

• 熔断器：快速失败，避免雪崩
• 重试机制：处理临时故障
• 降级策略：核心功能优先
• 超时控制：避免长时间等待

7. 可观测性

• 日志：集中式日志收集（ELK）
• 指标：Prometheus + Grafana
• 追踪：Jaeger/Zipkin 分布式追踪

总结

微服务不是银弹，适合复杂系统。合理拆分、完善治理，才能发挥微服务优势！