CQRS模式

CQRS 模式 (Command Query Responsibility Segregation)

概述

CQRS 将系统分为命令端（写）和查询端（读），使用不同的模型处理各自的需求。

核心思想：

• 命令（Command）：改变系统状态，不返回数据
• 查询（Query）：返回数据，不改变状态
• 写模型为业务规则优化，读模型为查询性能优化

            ┌─────────────┐
     命令 → │  写模型      │ → 领域模型（充血、聚合、事务）
            │  (Command)   │ → 数据库（规范化）
            └─────────────┘
                    │ 事件/同步
                    ▼
            ┌─────────────┐
     查询 → │  读模型      │ → 查询优化的视图
            │  (Query)     │ → 数据库（反规范化）
            └─────────────┘

代码示例

// 命令端：严格的领域模型
public class OrderCommandHandler {
    private final OrderRepository orderRepo;

    public void handle(PlaceOrderCommand cmd) {
        Order order = orderRepo.findById(cmd.getOrderId());
        order.place();  // 领域逻辑
        orderRepo.save(order);
        // 发布事件 → 更新读模型
    }

    public void handle(CancelOrderCommand cmd) {
        Order order = orderRepo.findById(cmd.getOrderId());
        order.cancel(cmd.getReason());
        orderRepo.save(order);
    }
}

// 查询端：为展示优化的模型
public class OrderQueryService {
    private final JdbcTemplate jdbc;

    // 直接查询优化后的视图，不走领域模型
    public OrderListDTO findOrders(OrderSearchCriteria criteria) {
        String sql = "SELECT o.id, o.status, c.name as customer_name, "
                   + "o.total_amount, o.created_at "
                   + "FROM order_view o JOIN customer c ON o.customer_id = c.id "
                   + "WHERE o.status = ? ORDER BY o.created_at DESC LIMIT ?";
        return jdbc.query(sql, criteria.getStatus(), criteria.getLimit());
    }

    public OrderDetailDTO findOrderDetail(String orderId) {
        // 从反规范化的视图中一次查出所有需要的数据
        return jdbc.queryForObject(
            "SELECT * FROM order_detail_view WHERE id = ?", orderId);
    }
}

# 命令端
class PlaceOrderCommandHandler:
    def __init__(self, order_repo, event_publisher):
        self.order_repo = order_repo
        self.event_publisher = event_publisher

    def handle(self, cmd: PlaceOrderCommand):
        order = self.order_repo.find_by_id(cmd.order_id)
        order.place()
        self.order_repo.save(order)
        for event in order.collect_events():
            self.event_publisher.publish(event)

# 查询端
class OrderQueryService:
    def __init__(self, read_db):
        self.read_db = read_db

    def search_orders(self, filters: dict) -> list[OrderSummaryDTO]:
        """直接从读优化的视图查询"""
        return self.read_db.query("order_summary_view", filters)

# 读模型更新器（监听事件）
class OrderReadModelUpdater:
    def on_order_placed(self, event: OrderPlacedEvent):
        self.read_db.upsert("order_summary_view", {
            "id": event.order_id,
            "status": "PLACED",
            "customer_name": event.customer_name,
            "total": event.total_amount,
        })

何时使用 CQRS

✅ 适用场景：
- 读写比例悬殊（读多写少）
- 读和写的模型差异大
- 需要独立扩展读和写
- 需要复杂的查询（报表、搜索）

❌ 不适用场景：
- 简单的 CRUD 应用
- 读写模型几乎相同
- 团队不熟悉事件驱动
- 最终一致性不可接受

CQRS 变体

与其他DDD概念的关系

总结

核心：读写分离，各自优化。命令端用领域模型保证业务正确，查询端用反规范化视图保证性能。

权衡：增加了架构复杂度，换来了读写各自的可扩展性和性能。