事件溯源聚合根是否应该有权访问事件溯源存储库？

Question

我正在开发 事件源 CQRS 实现，在应用程序/域层使用 DDD 。我有一个如下所示的对象模型：

public class Person : AggregateRootBase
{
    private Guid? _bookingId;

    public Person(Identification identification)
    {
        Apply(new PersonCreatedEvent(identification));
    }

    public Booking CreateBooking() {
        // Enforce Person invariants
        var booking = new Booking();
        Apply(new PersonBookedEvent(booking.Id));
        return booking;
    }

    public void Release() {
        // Enforce Person invariants
        // Should we load the booking here from the aggregate repository?
        // We need to ensure that booking is released as well.
        var booking = BookingRepository.Load(_bookingId);
        booking.Release();
        Apply(new PersonReleasedEvent(_bookingId));
    }

    [EventHandler]
    public void Handle(PersonBookedEvent @event) { _bookingId = @event.BookingId; }

    [EventHandler]
    public void Handle(PersonReleasedEvent @event) { _bookingId = null; }
}

public class Booking : AggregateRootBase
{
    private DateTime _bookingDate;
    private DateTime? _releaseDate;

    public Booking()
    {
        //Enforce invariants
        Apply(new BookingCreatedEvent());
    }

    public void Release() 
    {
        //Enforce invariants
        Apply(new BookingReleasedEvent());
    }

    [EventHandler]
    public void Handle(BookingCreatedEvent @event) { _bookingDate = SystemTime.Now(); }
    [EventHandler]
    public void Handle(BookingReleasedEvent @event) { _releaseDate = SystemTime.Now(); }
    // Some other business activities unrelated to a person
}

到目前为止，根据我对 DDD 的理解，Person 和 Booking 都是单独的聚合根，原因有两个：

1. 有时业务组件会从数据库中单独提取 Booking 对象。 （即，已被释放的人员由于信息不正确而修改了之前的预订）。
2. 每当需要更新 Booking 时，Person 和 Booking 之间不应出现锁定争用。

另一项业务要求是，一个人一次只能进行一次预订。因此，我担心在读取端查询查询数据库，因为那里可能存在一些不一致（由于使用 CQRS 并具有最终一致的读取数据库）。

是否应该允许聚合根通过对象的 id 查询事件源后备存储（根据需要延迟加载它们）？还有其他更有意义的实施途径吗？

Answer 1

首先，在您的案例中，您真的需要事件溯源吗？对我来说看起来很简单。事件溯源既有优点也有缺点。虽然它为您提供了免费的审计跟踪并使您的域模型更具表现力，但它使解决方案变得复杂。

好的，我假设此时您已经考虑了自己的决定，并且决定继续使用事件溯源。我认为您缺少消息传递作为聚合之间通信手段的概念。 Pat Helland 的论文（顺便说一句，它不是关于 DDD 或事件溯源，但涉及可扩展性）。

这个想法是聚合可以互相发送消息来强制某些行为。聚合之间不能有同步（也称为方法调用）交互，因为这会引入一致性问题。

在您的示例中，人员 AR 会向预订 AR 发送预订消息。该消息将以某种异步且可靠的方式传输。 Booking AR 将处理此消息，如果已被其他人预订，它将回复 ReservationRejected 消息。否则，它将发送 ReservationConfirmed。这些消息必须由 Person AR 处理。也许，他们会生成另一个事件，该事件将被转换为发送给客户的电子邮件或类似的内容。

无需在模型中获取查询数据。只是发消息。如果您想要示例，可以下载 Ncqrs 项目的“Messaging”分支的源代码并查看在场景测试课上。它使用 Blue Book 中的 Cargo 和 HandlingEvent 示例演示了 AR 之间的消息传递。

这能回答你的问题吗？