微服务架构设计：从单体到分布式的演进之路

什么是微服务？

微服务是一种架构风格，将应用拆分为小型、独立部署的服务，每个服务运行在自己的进程中，通过轻量级机制通信。

单体 vs 微服务

维度	单体架构	微服务架构
部署	整体部署	独立部署
扩展	整体扩展	按需扩展
技术栈	统一	多样化
故障隔离	差	好
开发效率	初期快	长期快
运维复杂度	低	高

服务拆分原则

1. 基于业务能力

电商系统:
├── 用户服务 (user-service)
├── 商品服务 (product-service)
├── 订单服务 (order-service)
├── 支付服务 (payment-service)
└── 库存服务 (inventory-service)

2. 单一职责

每个服务只做一件事，并且做好：

• 用户服务：注册、登录、信息管理
• 订单服务：创建、查询、取消订单
• 支付服务：处理支付、退款

3. 数据库隔离

# ✅ 每个服务独立数据库
user-service → user_db
order-service → order_db
product-service → product_db

# ❌ 避免共享数据库
all-services → shared_db (反模式)

服务间通信

同步通信（HTTP/REST）

// 服务 A 调用服务 B
async function createOrder(userId, items) {
  // 1. 验证用户
  const user = await fetch(`http://user-service/users/${userId}`);
  
  // 2. 检查库存
  const stock = await fetch("http://inventory-service/check", {
    method: "POST",
    body: JSON.stringify({ items })
  });
  
  // 3. 创建订单
  const order = await fetch("http://order-service/orders", {
    method: "POST",
    body: JSON.stringify({ userId, items })
  });
  
  return order;
}

异步通信（消息队列）

// 发布事件
await kafka.produce("order.created", {
  orderId: "123",
  userId: "456",
  amount: 99.99
});

// 订阅事件
kafka.consume("order.created", async (event) => {
  await sendEmail(event.userId, "订单创建成功");
  await updateInventory(event.items);
});

服务发现

# Consul 配置
services:
  - name: user-service
    address: 192.168.1.10
    port: 8080
    health: /health

# 服务调用
GET http://consul/v1/catalog/service/user-service

API 网关

# Kong 配置
routes:
  - name: user-route
    paths: ["/api/users"]
    services: user-service
    
  - name: order-route
    paths: ["/api/orders"]
    services: order-service

plugins:
  - rate-limiting
  - jwt-auth
  - cors

容错与弹性

1. 超时与重试

async function callWithRetry(service, maxRetries = 3) {
  for (let i = 0; i < maxRetries; i++) {
    try {
      return await fetch(service, { timeout: 5000 });
    } catch (e) {
      if (i === maxRetries - 1) throw e;
      await sleep(1000 * (i + 1)); // 指数退避
    }
  }
}

2. 熔断器模式

class CircuitBreaker {
  constructor(threshold = 5, timeout = 60000) {
    this.failureCount = 0;
    this.threshold = threshold;
    this.timeout = timeout;
    this.state = "CLOSED";
  }
  
  async call(fn) {
    if (this.state === "OPEN") {
      throw new Error("Circuit breaker is OPEN");
    }
    try {
      const result = await fn();
      this.onSuccess();
      return result;
    } catch (e) {
      this.onFailure();
      throw e;
    }
  }
}

3. 降级策略

// 推荐服务不可用时，返回热门商品
async function getRecommendations(userId) {
  try {
    return await recommendationService.get(userId);
  } catch (e) {
    return await productService.getPopular(); // 降级
  }
}

分布式事务

Saga 模式

1. 创建订单 (Order Service)
2. 扣减库存 (Inventory Service)
3. 扣款 (Payment Service)
   ↓ 失败
4. 补偿：恢复库存
5. 补偿：取消订单

监控与日志

# 技术栈推荐
监控：Prometheus + Grafana
日志：ELK Stack (Elasticsearch, Logstash, Kibana)
链路追踪：Jaeger / Zipkin
告警：Alertmanager

结语

微服务不是银弹。小团队从单体开始，遇到瓶颈再拆分。记住：合适的架构才是最好的架构。