2

背景

我有一个使用 CQRS + ES 的系统,在这个系统中,有一些聚合,例如博客文章或问题,它们保存在事件存储中,并将事件发送到查询端以通过投影来保存读取模型。

在创建问题或帖子的情况下,这是相当简单的

  • 客户端创建命令以创建新问题
  • 命令处理程序创建一个新的问题聚合并将更改保存在事件存储中
  • 当聚合应用更改时,它会触发 IssueCreatedEvent 或类似事件
  • 读取端的投影将监听这一点并创建一个问题模型和它想要的任何其他非规范化数据(例如用于查询所有问题列表的缩减 IssueListItem)

如果对问题进行了更改,并且在写入端引发了适当的事件,例如IssueStatusChanged,并在读取端进行了相应的处理。在读取端加载两个非规范化模型,更新事件的状态并保存。简单的。

你如何处理评论等关系?

我正在实现一个评论系统,用户可以在其中发布对问题或博客文章的评论。我的第一个想法是将这些评论添加到问题中或在写入端发布聚合以保持一致性。当我想到这一点时,我意识到这可能会引入许多不必要的并发问题,例如当有人更新问题而其他人来发表新评论时。

这使我认为我应该将评论本身建模为它们自己的聚合根。这样,发布到博客文章或问题的评论不会与问题本身发生冲突。

因此,假设我以这种方式将写入端的评论建模为聚合,我有两个问题;

1)写端的issue或post聚合是否还需要存储这个关系?评论聚合本身已经使用 id 引用存储了它发布的项目。

如果是这样,我正在考虑让问题聚合订阅评论创建事件并添加自己的引用。

public class Issue : AggregateRoot, IEventHandler<CommentCreatedEvent>
{
      private ICollection<Guid> _Comments;

      public void Handle(CommentCreatedEvent @event)
      {
         _Comments.Add(@event.AggregateId)
      }
}

由于评论已经存储了对其父级的引用,这是否足够或不需要?这些数据在写入端并不是真正需要的,当它是加载所有评论的父级时,在读取端更重要。

2)在读取方面,存储这些数据的最佳方式是什么?

具体来说,为了使这些数据易于更新,我需要在另一个表中放置评论并将它们加入到适当的帖子或问题中。在我完成评论后,我将实施一个关注系统,用户可以在其中关注项目以接收更新。然而,沿着这条路走下去会很快让我回到读取端的高度规范化模式,这违背了优化、非规范化读取模型的目的。

因此,我考虑在问题表中添加一个列,例如将所有评论存储为序列化的 json clob 或其他内容。这样,当评论发生更改时,我仍然可以拉出一条记录来加载问题,对评论进行适当的更改(例如更新现有评论、添加新评论或删除评论)并重新保存记录. 从阅读的角度来看,仍然可以一口气检索整个问题。

我在这种方法中看到的问题是,如果用户更改了他们的个人资料图片或个人资料名称,我将不得不加载每个问题和/或帖子,加载评论并在评论信息中进行适当的更改。

我还想知道文档数据库(我一直在为读取端考虑的其他东西)如何解决更新嵌套数据的问题?

4

3 回答 3

2

然而,我在聚会上有点晚了,这是我对 2 号的看法。

存储读取模型的最佳方式是易于查询。文档数据库可以是一个很好的技术解决方案,但它也可以与 rdbms 一起使用,前提是您定义了相关的读取模型模式。

您可以将所有评论与帖子一起存储,但情况并非总是如此,因为高流量网站通过 ajax 将评论与帖子分开加载。所以它真的取决于读取模型用例。

于 2013-10-23T07:51:12.203 回答
0

问题1:不需要有Issue中的关系。这里没有特别要保护的一致性。

问题 2:我最近正在阅读 NoSQL 提炼。看起来像 Casandra 这样的 Column-Family 数据库很适合评论。

Row | issueId | name                          | comments   |
    | 1       | comments persistence solution | {c1,c2,c3} | 

您可以使用 Casandra api 或 Casandra 查询语言来检索评论的子集或整个评论列。

更新

评论栏只是一个序列化的 id 集合,是完整的评论吗?否,评论存储为一行中的列。Casandra 支持嵌套列。所以评论栏可能有这样的结构

| other columns | comments                   |
|  ............ | c1   | c2           | c3   |
                | "+1" | "Nice one"   | "+1" |

如果我没记错的话,你可以在 Casandra 中单独获取和设置任何评论。在这种情况下,您可以更新任何一条评论。或者您可以获取评论列以检索所有评论。

于 2013-10-18T05:04:18.633 回答
-1

问题 1:您不能在聚合根中处理事件。违反 DDD 原则是个坏主意。如果 Comments 存在于不同的聚合中,那么 Issue 聚合中的任何后果最终都必须由您域中的某种流程管理器、域服务或 Saga 处理。

如果可能在您的域中,您必须声明 Issue 不知道 Comments(我想这是一种自然的思维方式),因此您不应该保留任何此类引用。

对另一种方式的评论可以保留对它们相关问题的引用。

问题 2:为什么不将问题/帖子所需的所有字段保留在评论表中(处理问题/帖子更新)?这使您在查询读取模型时无需连接这两个表。

于 2013-11-08T00:03:29.793 回答