如何“加入”准备视图模型时有两个聚合根？

Question

假设 Book 和 Author 是我的模型中的聚合根。

在读取模型中，我有表AuthorsAndBooks，它是由Book.AuthorId加入的作者和书籍列表，

当触发BookAdded事件时，我想接收Author 数据来创建新的 AuthorsAndBooks 行。

由于 Book 是聚合根，因此有关 Author 的信息不包含在 BookAdded 事件中。我无法包含它，因为 Author root 没有 getter（根据有关 CQRS 和事件溯源的所有示例和帖子的指南）。

通常我会收到关于此问题的两种类型的答案：

1. 使用事件处理程序中所需的所有数据丰富您的域事件。但正如我所说，我不能为聚合根做到这一点。
2. 使用视图模型中的可用数据。即从视图模型加载 Author 并使用它来构建 AuthorsAndBooks 行。

最后一个在并发方面存在一些问题。处理 BookAdded 事件时，作者数据在视图模型中不可用。

你用什么方法来解决这个问题？谢谢。

Answer 1

恕我直言，从作者/书籍事件填充读取模型，使用重新排序来处理事件无序的情况（视图处理程序位于其自己的一致性边界内，无论如何都应该处理排序/重复数据删除情况）。

Answer 2

我要问的第一件事是为什么读取模型中存在并发问题。如果客户端在 AddBook 命令内发送对作者聚合的引用，那么它从哪里获取信息？如果书和作者同时创作，那么你的活动或许可以更加丰富。如果我在这里遗漏了什么，请告诉我。

Answer 3

最后一个有一些问题
并发。作者数据可以不
当时在视图模型中可用
BookAdded 事件正在处理。

那么“稍后处理事件”呢？因此，您只需将其放在队列的后面，直到该数据可用（可能有 x 次尝试的限制以及每次尝试之间的 x 时间）。

Answer 4

您的问题缺少一些上下文，例如导致此事件的用户场景是什么以及您从什么状态开始？如果您为此案例编写 BDD 测试，它们会是什么样子？了解这一点对于回答你的问题会有很大帮助。

如何解决将一本书与作者联系起来的问题取决于领域。首先，我们假设您的域拥有“作者”的聚合和“书籍”的聚合是有意义的，例如，如果我正在编写一个图书馆系统，我怀疑我是否会有作者的聚合，因为我不关心一个没有书的作家，我关心的是书。

至于缺少吸气剂，值得一提的是，聚合根没有吸气剂，因为它更喜欢 告诉-不要询问 的 OOP 风格。不过，您可以告诉一个 AR 做某事，然后如果需要，该 AR 会告诉另一台 AR 一些事情。重要的部分是 AR 会告诉其他人关于它自己的信息，而不是在您询问它然后传递它的地方编写代码。

最后我想问一下，为什么你添加书的时候没有作者ID呢？那你怎么知道作者是谁呢？我假设你可以执行以下操作（我的代码假设你正在使用流畅的界面来创建 AR，但你可以替换工厂、构造函数，无论你使用什么）：

CreateNew.Book()
  .ForAuthor(command.AuthorId)
  .WithContent(command.Content);

现在，也许场景是你正在添加一本书和一个全新作者。我要么将其作为两个单独的命令处理（这可能对您的域更有意义），要么按以下方式处理命令：

var author = CreateNew.Author()
  .WithName(command.AuthorName);

var book = CreateNew.Book()
  .ForAuthor(author.Id)
  .WithContent(command.Content);

也许问题是您在聚合根 Id 上没有 getter，我认为这是不必要的或常见。但是，假设 Id 封装对您很重要，或者您的 BookAdded 事件需要比 Id 提供的更多有关作者的信息，那么您可以执行以下操作：

var author = CreateNew.Author()
  .WithName(command.AuthorName);
var book = author.AddBook(command.Content);

// Adds a new book belonging to this Author
public Book AddBook(BookContent content) {
  var book = CreateNew.Book()
    .ForAuthor(this.Id)
    .WithContent(command.Content);
}

这里我们告诉作者添加一本书，此时它创建书籍的聚合根并将其 Id 传递给书籍。然后我们可以使用 BookAddedForAuthor 事件，其中包含作者的 id。

但最后一个也有缺点，它创建的命令必须通过多个聚合根起作用。我会尽可能地尝试找出为什么第一个示例不适合您。

另外，我无法充分强调您正在寻找的实现是如何由您的特定域上下文决定的。

Answer 5

作为一般建议，让事件处理程序具有幂等性，并确保您可以处理无序消息处理（通过重新排队或构建机制来填充丢失的数据）。
另一方面，要质疑为什么作者和书籍是如此绝望的聚合根源。也许你应该在添加一本书时从作者那里复制（f * 是什么“添加一本书”，这是一个命令）。问题在于所有这些编造的例子。下降到现实世界，我怀疑你的问题是否存在。