3. 事务与一致性模型：ACID特性、本地事务与分布式事务的区别、强一致性与最终一致性模型

3.1 事务的本质与ACID特性

事务（Transaction）是数据库系统执行过程中的一个逻辑工作单元，它由一组不可分割的操作序列组成。事务的可靠性由ACID四大特性保证，这是所有事务处理系统的基石。

3.2 本地事务与分布式事务的区别

本地事务（Local Transaction）运行在单一数据库实例内，由数据库自身的事务管理器负责协调。分布式事务（Distributed Transaction）则跨越多个独立的资源管理器（如多个数据库、消息队列、缓存服务），需要全局协调者来保证所有参与者的原子提交。

// Go语言中本地事务示例（使用database/sql）
func TransferFunds(db *sql.DB, fromID, toID string, amount float64) error {
    tx, err := db.Begin()
    if err != nil {
        return err
    }
    defer tx.Rollback() // 确保未提交时回滚

    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID)
    if err != nil {
        return err
    }

    _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toID)
    if err != nil {
        return err
    }

    return tx.Commit()
}

3.3 强一致性与最终一致性模型

一致性模型定义了分布式系统中数据副本之间同步的严格程度。强一致性（Strong Consistency）要求任何读操作都能读到最新写入的数据；最终一致性（Eventual Consistency）则允许短暂的不一致窗口，但保证在没有新更新的情况下，所有副本最终会达到一致状态。

• 强一致性： 线性一致性（Linearizability）——所有操作看起来像在单个时间点原子执行。
• 弱一致性： 顺序一致性（Sequential Consistency）——每个进程的操作顺序一致，但全局顺序可能不同。
• 最终一致性： 因果一致性（Causal Consistency）——有因果关系的操作必须按顺序被看到。
• 最终一致性： 读己之写（Read-Your-Writes）——客户端总能读到自己的写入。
• 最终一致性： 单调读（Monotonic Read）——客户端不会读到旧版本数据。

3.4 分布式事务的典型实现模式

在微服务和Go领域驱动设计实践中，常见的分布式事务模式包括两阶段提交（2PC）、TCC（Try-Confirm-Cancel）、Saga和本地消息表。每种模式在一致性强度、可用性和实现复杂度上各有取舍。

3.5 领域驱动设计中的事务边界策略

在DDD中，事务边界与聚合边界紧密相关。一个聚合（Aggregate）是一组具有紧密关联的实体和值对象的集合，外部只能通过聚合根（Aggregate Root）访问。事务应该以聚合为单位，一个事务只修改一个聚合实例。

• 聚合内强一致： 同一个聚合内的所有状态变更必须在同一个本地事务中完成。
• 聚合间最终一致： 不同聚合之间的状态同步通过领域事件（Domain Event）异步完成，允许短暂的不一致。
• 仓储（Repository）封装事务： 仓储负责管理聚合的持久化，事务边界在应用服务层（Application Service）控制。
• 避免跨聚合事务： 如果发现需要跨多个聚合的强一致事务，应重新审视聚合设计是否合理。

// Go + DDD 中聚合内事务示例
type OrderAggregate struct {
    ID        string
    Items     []OrderItem
    Status    OrderStatus
    Version   int
}

// 应用服务层控制事务边界
func (s *OrderService) SubmitOrder(ctx context.Context, orderID string) error {
    // 开启本地事务
    tx, err := s.db.BeginTx(ctx, nil)
    if err != nil {
        return err
    }
    defer tx.Rollback()

    // 加载聚合
    order, err := s.orderRepo.FindByID(ctx, tx, orderID)
    if err != nil {
        return err
    }

    // 执行聚合内业务逻辑
    if err := order.Submit(); err != nil {
        return err
    }

    // 保存聚合（一个事务只保存一个聚合）
    if err := s.orderRepo.Save(ctx, tx, order); err != nil {
        return err
    }

    // 提交事务
    if err := tx.Commit(); err != nil {
        return err
    }

    // 发布领域事件（异步，最终一致）
    s.eventBus.Publish(order.Events...)
    return nil
}