事件溯源中聚合根不变量管理：避免重复检查与提升语义

在领域驱动设计（DDD）和事件溯源（Event Sourcing）的实践中，聚合根（Aggregate Root）是领域模型的核心，它作为一致性边界，负责维护其内部所有实体和值对象的不变量。不变量是业务规则，必须在聚合根的生命周期中始终保持为真。然而，在实际应用中，尤其当外部服务需要根据外部数据源更新聚合根的多个属性时，如何优雅且高效地处理这些不变量，避免逻辑重复或代码冗余，是一个常见的挑战。

聚合根与不变量管理的挑战

考虑一个 ProductAggregateRoot，它包含价格（price）和可用性（availability）等属性。为了维护业务规则，changePrice 方法中会包含一系列不变量检查：

class ProductAggregateRoot
{
    private $price;
    private $availability;

    // ... 构造函数和从事件重构的方法 ...

    public function changePrice(ChangeProductPrice $command): self
    {
        // 不变量检查1: 产品不可用时不能改变价格
        if ($this->availability->equals(Availability::UNAVAILABLE())) {
            throw CannotChangePriceException::unavailableProduct();
        }

        // 不变量检查2: 价格未改变时无需更新
        if ($this->price->equals($command->newPrice)) {
            throw CannotChangePriceException::priceHasntChanged();
        }

        // 记录事件
        $this->recordThat(
            new ProductPriceChanged($this->price, $command->newPrice)
        );

        return $this;
    }

    // ... 其他方法 ...
}

当一个外部领域服务需要同步外部数据，同时更新产品的价格和可用性时，开发者可能会面临以下困境：

1. 冗余的异常处理： 如果外部服务需要调用 changePrice 和 changeAvailability 等多个方法，为了捕获各自抛出的业务异常，可能会导致大量的 try-catch 块，使得服务层的逻辑变得笨重和难以阅读。

   // 外部服务中的示例
   try {
       $aggregate->changePrice(new ChangeProductPrice(
           $productId,
           $state->getPrice()
       ));
   } catch (CannotChangePriceException $ex) {
       // 处理或忽略价格变更异常
   }
   
   try {
       $aggregate->changeAvailability(new ChangeProductAvailability(
           $productId,
           $state->getAvailability()
       ));
   } catch (CannotChangeAvailabilityException $ex) {
       // 处理或忽略可用性变更异常
   }
   // ... 更多类似的逻辑 ...

2. 不变量逻辑的重复： 为了避免 try-catch，服务层可能会在调用聚合根方法前，先通过 CanChangePrice() 这样的方法预先检查不变量。但这会导致不变量逻辑在服务层和聚合根内部重复，增加了维护成本和出错风险。

这种模式不仅使得代码结构混乱，也模糊了业务意图，降低了系统的可维护性。

策略一：构建意图明确的复合命令

解决上述问题的关键在于重新思考命令的粒度及其所代表的业务意图。与其让外部服务发送一系列原子性的“改变价格”、“改变可用性”命令，不如引入一个更具业务语义的复合命令，它能够封装一个更高级别的业务操作。

例如，当外部系统同步产品信息时，其意图通常是“更新产品详情”，而非仅仅“改变价格”或“改变可用性”。此时，我们可以定义一个 UpdateProductDetails 命令，并在聚合根中实现相应的方法。

// 定义复合命令
class UpdateProductDetails
{
    public $productId;
    public $newPrice;
    public $newAvailability;

    public function __construct(ProductId $productId, Price $newPrice, Availability $newAvailability)
    {
        $this->productId = $productId;
        $this->newPrice = $newPrice;
        $this->newAvailability = $newAvailability;
    }
}

class ProductAggregateRoot
{
    // ... 现有属性和方法 ...

    public function updateDetails(UpdateProductDetails $command): self
    {
        $currentPrice = $this->price;
        $currentAvailability = $this->availability;

        $newPrice = $command->newPrice;
        $newAvailability = $command->newAvailability;

        // 统一进行不变量检查，具有更丰富的上下文
        // 例如：如果新的可用性是“可用”，那么当前不可用状态对价格变更的限制可能不再适用
        if ($newAvailability->equals(Availability::AVAILABLE()) && $currentAvailability->equals(Availability::UNAVAILABLE())) {
            // 产品正在变为可用，此时价格可以被修改，即使之前不可用
            // 记录可用性变更事件
            $this->recordThat(new ProductAvailabilityChanged($currentAvailability, $newAvailability));
            $this->availability = $newAvailability;

            if (!$currentPrice->equals($newPrice)) {
                // 价格也发生了变化
                $this->recordThat(new ProductPriceChanged($currentPrice, $newPrice));
                $this->price = $newPrice;
            }
        } elseif ($currentAvailability->equals(Availability::UNAVAILABLE())) {
            // 产品仍然不可用，如果尝试改变价格，则抛出异常
            if (!$currentPrice->equals($newPrice)) {
                 throw CannotChangePriceException::unavailableProduct();
            }
            // 如果只有可用性变化，但仍不可用，则记录可用性变更
            if (!$currentAvailability->equals($newAvailability)) {
                $this->recordThat(new ProductAvailabilityChanged($currentAvailability, $newAvailability));
                $this->availability = $newAvailability;
            }
        } else {
            // 产品当前可用
            if (!$currentPrice->equals($newPrice)) {
                $this->recordThat(new ProductPriceChanged($currentPrice, $newPrice));
                $this->price = $newPrice;
            }
            if (!$currentAvailability->equals($newAvailability)) {
                $this->recordThat(new ProductAvailabilityChanged($currentAvailability, $newAvailability));
                $this->availability = $newAvailability;
            }
        }

        return $this;
    }
}

优势：

• 提升业务语义： 命令直接反映了高层次的业务操作，使得领域模型更易于理解。
• 集中不变量检查： 所有相关的不变量检查可以在一个方法中进行，拥有更完整的上下文信息，例如，当可用性从“不可用”变为“可用”时，原先“不可用不能改价格”的不变量可能不再适用。
• 减少外部服务复杂性： 外部服务只需发送一个命令，无需关心聚合根内部的多个原子操作和各自的异常处理。
• 避免状态预判： 外部服务不再需要预先查询聚合根的当前状态来决定是否调用某个方法。

策略二：重新审视“无操作”不变量

另一个常见的场景是，当聚合根已经处于命令所期望的状态时，是否应该抛出异常。例如，changePrice 方法中，如果 command->newPrice 与 this->price 相同，则抛出 CannotChangePriceException::priceHasntChanged()。

这种做法强制调用者在每次尝试变更前都必须知道聚合根的当前状态，这在事件溯源系统中尤其困难，因为聚合根的状态是根据事件流实时重构的。

更好的做法是，如果聚合根已经处于目标状态，则执行一个“无操作”（No-Op），即不记录任何事件，直接返回聚合根实例。这表明聚合根已经满足了命令的要求。

class ProductAggregateRoot
{
    // ... 现有属性和方法 ...

    public function changePrice(ChangeProductPrice $command): self
    {
        // 不变量检查1: 产品不可用时不能改变价格
        if ($this->availability->equals(Availability::UNAVAILABLE())) {
            throw CannotChangePriceException::unavailableProduct();
        }

        // 重新审视不变量2: 如果价格未改变，则执行无操作
        if ($this->price->equals($command->newPrice)) {
            // 价格已经是你想要的值，无需改变，也不抛出异常
            return $this; 
        }

        // 记录事件
        $this->recordThat(
            new ProductPriceChanged($this->price, $command->newPrice)
        );
        $this->price = $command->newPrice; // 更新内部状态

        return $this;
    }

    // ... 其他方法 ...
}

优势：

• 简化调用方逻辑： 调用方无需预先查询聚合根的当前状态。它只需表达其意图，聚合根会自行判断是否需要进行状态变更。
• 区分业务错误与状态已满足： 只有当命令无法被执行（例如，产品不可用）时才抛出异常，而不是当状态已经满足时。
• 减少不必要的事件记录： 避免记录那些实际上没有引起状态变化的“事件”，保持事件流的精炼。

最佳实践与注意事项

1. 命令粒度决策： 决定命令粒度时，应以业务意图为导向。如果一个操作在业务上是一个整体，且其内部的不变量检查相互关联，则应考虑使用复合命令。
2. 不变量的归属： 始终强调不变量检查应尽可能在聚合根内部完成。聚合根是其一致性的守护者，任何绕过聚合根的直接状态修改都可能破坏不变量。
3. 领域服务角色： 领域服务的主要职责是协调多个聚合根、与其他领域或外部系统交互，而不是重复聚合根内部的不变量逻辑。它应该向聚合根发送命令，并处理聚合根抛出的业务异常。
4. 事件溯源的本质： 事件记录的是已发生的事实。一个“无操作”不应产生事件，因为没有实际的状态变化发生。

总结

在事件溯源和DDD中，有效管理聚合根的不变量是构建健壮领域模型的关键。通过采纳意图明确的复合命令，我们能够提供更丰富的上下文来执行不变量检查，并减少外部服务与聚合根之间的耦合。同时，重新审视“无操作”场景下的不变量处理，允许聚合根在状态已满足时优雅地返回，从而简化调用方逻辑并保持事件流的纯粹性。这些策略共同构成了在不重复不变量逻辑的前提下，维护聚合根完整性和提升系统可维护性的有效途径。