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

为什么选择微服务？

单体架构的痛点

• 代码耦合严重，牵一发而动全身
• 部署周期长，风险高
• 技术栈单一，难以灵活选型
• 团队规模扩大后协作困难

微服务的优势

• 服务独立，快速迭代
• 技术栈灵活，按需选型
• 故障隔离，提高可用性
• 团队自治，提升效率

服务拆分原则

单一职责

每个服务只负责一个业务领域：

• 用户服务
• 订单服务
• 支付服务
• 库存服务
• 通知服务

高内聚低耦合

# ❌ 差的设计 - 服务间直接调用数据库
class OrderService:
    def get_user_info(self, user_id):
        return db.query("SELECT * FROM users WHERE id = ?", user_id)

# ✅ 好的设计 - 通过 API 调用
class OrderService:
    def get_user_info(self, user_id):
        return user_service_client.get(user_id)

数据私有化

每个服务拥有自己的数据库，禁止跨库查询。

核心技术组件

服务注册与发现

# Consul 配置
services:
  consul:
    image: consul:latest
    command: agent -server -bootstrap-expect=1
  
  app:
    environment:
      - CONSUL_HTTP_ADDR=consul:8500

API 网关

# Kong 配置
services:
  - name: user-service
    url: http://user-service:8080
    routes:
      - paths: ["/api/users"]

  - name: order-service
    url: http://order-service:8080
    routes:
      - paths: ["/api/orders"]

配置中心

// Spring Cloud Config
@Value("${database.url}")
private String dbUrl;

// 配置热更新
@RefreshScope

服务熔断

// Hystrix
@HystrixCommand(fallbackMethod = "fallback")
public Order getOrder(Long id) {
    return orderClient.findById(id);
}

public Order fallback(Long id) {
    return new Order(); // 降级返回
}

分布式事务

Saga 模式

# 订单创建流程
def create_order():
    try:
        inventory.reserve()
        payment.charge()
        shipping.schedule()
    except Exception as e:
        shipping.cancel()
        payment.refund()
        inventory.release()
        raise

最终一致性

通过消息队列实现异步最终一致：

# 订单服务
order.save()
message_queue.publish("order.created", order.id)

# 库存服务（监听消息）
@consumer("order.created")
def reduce_inventory(order_id):
    inventory.reduce(order_id)

服务通信

同步调用（REST/gRPC）

# REST
response = requests.get("http://user-service/users/123")

# gRPC (更高效)
user = user_stub.GetUser(GetUserRequest(id=123))

异步消息（Kafka/RabbitMQ）

# 生产者
kafka.produce("user.events", {"event": "registered", "user_id": 123})

# 消费者
@kafka.consume("user.events")
def handle_event(event):
    send_welcome_email(event["user_id"])

监控与日志

• 链路追踪: Jaeger, Zipkin
• 指标监控: Prometheus + Grafana
• 日志聚合: ELK Stack
• 健康检查: /health 端点

部署策略

• 蓝绿部署: 零停机切换
• 金丝雀发布: 逐步放量
• 滚动更新: 逐个替换

总结

微服务不是银弹，适合复杂业务场景。合理拆分，完善基础设施，才能发挥最大价值！