软件架构设计实战：从单体到微服务的演进路径与核心考量

3次阅读

没有评论

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

在创业初期或小型项目中，单体架构因其简单直接的开发模式广受欢迎。但随着业务规模扩大，这种架构的弊端逐渐显现：

扩展性差 ：所有功能模块耦合在同一个进程中，无法针对热点服务单独扩容
技术栈僵化 ：全团队必须使用相同的技术版本，升级框架如履薄冰
部署效率低 ：改一行代码就需要全量发布，凌晨部署成为常态
故障影响面大 ：一个非核心模块的 bug 可能导致整个系统崩溃

当系统复杂度达到一定规模时，我们需要根据业务特点选择适合的架构模式：

SOA（面向服务架构）
适用场景：企业内部系统整合
特点：强调 ESB 总线、WS-* 协议栈
缺点：中心化架构容易成为性能瓶颈
微服务架构
适用场景：互联网高并发场景
特点：轻量级 HTTP 通信、去中心化治理
优势：独立部署、技术异构性支持
Serverless
适用场景：事件驱动型短时任务
特点：按需计费、自动弹性伸缩
限制：冷启动延迟、状态管理困难

采用领域驱动设计（DDD）进行边界划分：

按照业务能力划分：如订单服务、库存服务、支付服务
遵循单一职责原则：每个服务不超过 10 个 API 接口
团队自治：每个微服务由 2 - 3 人的全功能团队负责

@RestController
@RequestMapping("/api/v1/orders")
public class OrderController {
    @PostMapping
    public ResponseEntity<Order> createOrder(@Valid @RequestBody OrderDTO dto) {
        // 参数校验通过 Spring Validation
        Order order = orderService.create(dto);
        return ResponseEntity.created(URI.create("/orders/"+order.getId())
        ).body(order);
    }
}

关键设计要点：

版本控制：URL 路径包含 v1/v2
状态码语义：201 用于资源创建成功
HATEOAS：返回资源 URI 便于客户端导航

采用 Saga 模式处理跨服务事务：

func CreateOrderSaga(ctx context.Context, req OrderRequest) error {
    // 步骤 1：创建订单（可补偿）if err := orderClient.Create(ctx, req); err != nil {return err}

    // 步骤 2：扣减库存（需持久化日志）if err := inventoryClient.Lock(ctx, req.Items); err != nil {orderClient.Cancel(ctx, req.OrderID) // 补偿操作
        return err
    }

    // 步骤 3：支付（最终一致性）if err := paymentClient.Charge(ctx, req); err != nil {inventoryClient.Unlock(ctx, req.Items) // 补偿
        orderClient.Cancel(ctx, req.OrderID)
        return err
    }

    return nil
}

典型电商微服务架构包含以下组件：

接入层 ：API Gateway 统一路由
业务服务 ：订单 / 商品 / 用户等核心领域服务
支撑服务 ：
注册中心（Nacos/Eureka）
配置中心（Apollo）
消息队列（Kafka/RocketMQ）
观测体系 ：
指标监控（Prometheus）
分布式追踪（SkyWalking）
日志中心（ELK）

通过 Istio 实现流量管理：

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
  name: product-service
spec:
  hosts:
  - product
  http:
  - route:
    - destination:
        host: product
        subset: v1
      weight: 90
    - destination:
        host: product
        subset: v2
      weight: 10

Hystrix 配置示例：

@HystrixCommand(
    fallbackMethod = "getProductFallback",
    commandProperties = {@HystrixProperty(name="circuitBreaker.requestVolumeThreshold", value="10"),
        @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds", value="10000")
    }
)
public Product getProduct(String id) {return productClient.get(id);
}

public Product getProductFallback(String id) {return cacheService.getCachedProduct(id); // 降级逻辑
}