基于ABP落地领域驱动设计-02.聚合和聚合根的最佳实践和原则

目录

• 系列文章
• 前言
• 聚合
• 聚合和聚合根原则
  • 包含业务原则
  • 单个单元原则
  • 事务边界原则
  • 可序列化原则
• 聚合和聚合根最佳实践
  • 只通过ID引用其他聚合
  • 用于 EF Core 和 关系型数据库
  • 保持聚合根足够小
  • 聚合根/实体中的主键
  • 聚合根/实体构造函数
  • 业务逻辑和实体中的异常处理
  • 实体中业务逻辑需要用到外部服务

前言

上一篇 基于abp落地领域驱动设计-01.全景图 概述了ddd理论和对应的解决方案、项目组成、项目引用关系，以及基于abp落地ddd的通用原则。从这本篇开始，会更加深入地介绍在基于 abp framework 落地ddd过程中的最佳实践和原则。

围绕ddd和abp framework两个核心技术，后面还会陆续发布核心构件实现、综合案例实现系列文章，敬请关注！
abp framework 研习社（qq群：726299208）
abp framework 学习及实施ddd经验分享；示例源码、电子书共享，欢迎加入！

领域对象是ddd的核心，我们会依次分析聚合/聚合根、仓储、规约、领域服务的最佳实践和规则。内容较多，会拆分成多个章节单独展开。

本文重点讨论领域对象——聚合和聚合根的最佳实践和原则

首先我们需要一个业务场景，例子中会用到 github 的一些概念，如：issue（建议）、repository（代码仓库）、label（标签）和user（用户）。

下图显示了业务场景对应的聚合、聚合根、实体、值对象以及它们之间的关系。

issue 聚合是由 issue（聚合根）、comment（实体）和 issuellabel（值对象）组成的集合。因为其他聚合相对简单，所以我们重点分析 issue 聚合。

聚合

正如前面所讲，一个聚合是一系列对象（实体和值对象）的集合，通过聚合根将所有关联对象绑定在一起。本节将介绍与聚合相关的最佳实践和原则。

我们对聚合根和子集合实体都使用实体这个术语，除非明确写出聚合根或子集合实体。

聚合和聚合根原则

包含业务原则

• 实体负责实现与其自身属性相关的业务规则。
• 聚合根还负责其子集合实体状态管理。
• 聚合应该通过实现领域规则和规约来保持自身的完整性和有效性。这意味着，与数据传输对象（dto）不同，实体具有实现业务逻辑的方法。实际上，我们应该尽可能在实体中实现业务规则。

单个单元原则

聚合及其所有子集合，作为单个单元被检索和保存。例如：如果向 issue 添加 comment，需要这样做：

• 从数据库中获取 issue 包含所有子集合：comments （该问题的评论列表） 和 issuelabels （该问题的标签集合）。
• 在 issue 类中调用方法添加一个新的 comment，比如： issue.addcommnet(...)
• 作为一个单一的数据库更新操作，将 issue（包括所有子集合）保存到数据库。

对于习惯使用 ef core 和 关系数据的开发者来说，这看起来似乎有些奇怪。获取 issue 的所有数据是没有必要且低效的。为什么我们不直接执行一个sql插入命令到数据库，而不查询任何数据呢？

答案是，我们应该在代码中实现业务规则并保持数据的一致性和完整性。如果我们有一个业务规则，如：用户不能对锁定的 issue 进行评论，我们如何不通过检索数据库中数据的情况下，检查 issue 的锁定状态呢？所以，只有当应用程序代码中的相关对象可用时，即获取到聚合及其所有子集合数据时，我们才能执行该业务规则。

另一方面，mongodb开发者会发现这个规则非常自然。因为在 mongodb 中，一个聚合对象（包括子集合）被保存在数据库中的一个集合中，而在关系型数据库中，它被分布在数据库中几个表中。因此，当你得到一个聚合时，所有的子集合已经作为查询的一部分被检索出来了，不需要任何额外配置。

abp框架有助于在您的应用程序中实现这一原则。

示例：添加 comment 到 issue

public class issueappservice : applicationservice ,iissueappservice
{
  private readonly irepository<issue,guid> _issuerepository;
  public issueappservice(irepository<issue,guid> issuerepository)
  {
    _issuerepository = issuerepository;
  }
  [authorize]
  public async task createcommentasync(createcommentdto input)
  {
    var issue = await _issuerepository.getasync(input.issueid);
    issue.addcomment(currentuser.getid(),input.text);
    await _issuerepository.updateasynce(issue);
  }
}

_issuerepository.getasync(...)方法默认作为单个单元检索 issue 对象并包含所有子集合。对于 mongodb 来说这个操作开箱即用，但是使用 ef core 需要配置聚合与数据库映射，配置后 ef core 仓储实现 会自动处理。_issuerepository.getasync(...)方法提供一个可选参数includedetails，可以传递值 false 禁用该行为，不包含子集合对象，只在需要时启用它。

issue.addcomment(...)传递参数 userid 和 text ，表示用户id和评论内容，添加到 issue 的 comments 集合中，并实现必要的业务逻辑验证。

最后，使用 _issuerepository.updateasync(...) 保存更改到数据库。

ef core 提供 变更跟踪（change tracking）功能，实际上你不需要调用 _issuerepository.updateasync(...) 方法，会自动进行保存。这个功能是由 abp 工作单元系统 提供，应用服务的方法作为一个单独的工作单元，在执行完之后会自动调用 dbcontext.savechanges()。当然，如果使用 mongodb 数据库，则需要显示地更新已经更改的实体。
所以，如果你想要编写独立于数据库提供程序的代码，应该总是为要更改的实体调用updateasync()方法。

事务边界原则

一个聚合通常被认为是一个事务边界。如果用例使用单个聚合，读取并保存为单个单元，那么对聚合对象所做的所有更改，将作为原子操作保存，而不需要显式地使用数据库事务。

当然，我们可能需要处理将多个聚合实例作为单一用例更改的场景，此时需要使用数据库事务确保更新操作的原子性和数据一致性。正因为如此，abp框架为一个用例（即一个应用程序服务方法）显式地使用数据库事务，一个应用程序服务方法，就是一个工作单元。

可序列化原则

聚合（包含根实体和子集合）应该是可序列化的，并且可以作为单个单元在网络上进行传输。举个例子，mongodb序列化聚合为json文档保存到数据库，反序列化从数据库中读取的json数据。

当您使用关系数据库和orm时，没有必要这样做。然而，它是领域驱动设计的一个重要实践。

聚合和聚合根最佳实践

以下最佳实践确保实现上述原则。

只通过id引用其他聚合

一个聚合应该只通过其他聚合的id引用聚合，这意味着你不能添加导航属性到其他聚合。

• 这条规则使得实现可序列化原则得以实现。
• 可以防止不同聚合相互操作，以及将聚合的业务逻辑泄露给另一个聚合。

我们来看一个例子，两个聚合根：gitrepository 和 issue ：

public class gitrepository:aggregateroot<guid>
{
  public string name {get;set;}
  public int starcount{get;set;}
  public collection<issue> issues {get;set;} //错误代码示例
}

public class issue:aggregateroot<guid>
{
  public tring text{get;set;}
  public gitrepository repository{get;set;} //错误代码示例
  public guid repositoryid{get;set;} //正确示例
}

• gitrepository 不应该包含 issue 集合，他们是不同聚合。
• issue 不应该设置导航属性关联 gitrepository ，因为他们是不同聚合。
• issue 使用 repositoryid 关联 repository 聚合，正确。

当你有一个 issue 需要关联的 gitrepository 时，那么可以从数据库通过 repositoryid 直接查询。

用于 ef core 和 关系型数据库

在 mongodb 中，自然不适合有这样的导航属性/集合。如果这样做，在源集合的数据库集合中会保存目标集合对象的副本，因为它在保存时被序列化为json，这样可能会导致持久化数据的不一致。

然而，ef core 和关系型数据库的开发者可能会发现这个限制性的规则是不必要的，因为 ef core 可以在数据库的读写中处理它。

但是我们认为这是一条重要的规则，有助于降低领域的复杂性防止潜在的问题，我们强烈建议实施这条规则。然而，如果你认为忽略这条规则是切实可行的，请参阅前面基于abp落地领域驱动设计-01.全景图中关于数据库独立性原则的讨论部分。

保持聚合根足够小

一个好的做法是保持一个简单而小的聚合。这是因为一个聚合体将作为一个单元被加载和保存，读/写一个大对象会导致性能问题。

请看下面的例子：

public class userrole:valueobject
{
  public guid userid{get;set;}
  public guid roleid{get;set;}
}

public class role:aggregateroot<guid>
{
  public string name{get;set;}
  public collection<userrole> users{get;set;} //错误示例：角色对应的用户是不断增加的
}
public class user:aggregateroot<guid>
{
  public string name{get;set;}
  public collection<userrole> roles{get;set;}//正确示例：一个用户拥有的角色数量是有限的
}

role聚合 包含 userrole 值对象集合，用于跟踪分配给此角色的用户。注意，userrole 不是另一个聚合，对于规则仅通过id引用其他聚合没有冲突。

然而，实际却存在一个问题。在现实生活中，一个角色可能被分配给数以千计（甚至数以百万计）的用户，每当你从数据库中查询一个角色时，加载数以千计的数据项是一个重大的性能问题。记住：聚合是由它们的子集合作为一个单一单元加载的。

另一方面，用户可能有角色集合，因为实际情况中用户拥有的角色数量是有限的，不会太多。当您使用用户聚合时，拥有一个角色列表可能会很有用，且不会影响性能。

如果你仔细想想，当使用非关系型数据库（如mongodb）时，当role和user都有关系列表时还有一个问题：在这种情况下，相同的信息会在不同的集合中重复出现，将很难保持数据的一致性，每当你在user.roles中添加一个项，你也需要将它添加到role.users中。

因此，根据以下因素来确定聚合边界和大小：

• 考虑对象关联性，是否需要在一起使用。
• 考虑性能，查询（加载/保存）性能和内存消耗。
• 考虑数据的完整性、有效性和一致性。

而实际：

• 大多数聚合根没有子集合。
• 一个子集合最多不应该包含超过100-150个条目。如果您认为集合可能有更多项时，请不要定义集合作为聚合的一部分，应该考虑为集合内的实体提取为另一个聚合根。

聚合根/实体中的主键

• 一个聚合根通常有一个id属性作为其标识符（主键，primark key: pk）。推荐使用 guid 作为聚合根实体的pk。
• 聚合中的实体（不是聚合根）可以使用复合主键。

示例：聚合根和实体

//聚合根：单个主键
public class organization
{
  public guid id{get;set;}
  public string name{get;set;}
  //...
}
//实体：复合主键
public class organizationuser
{
  public guid organizationid{get;set;} //主键
  public guid userid{get;set;}//主键
  public bool isowner{get;set;}
  //...
}

• organization 包含 guid 类型主键 id
• organizationuser 是 organization 中的子集合，有复合主键：organizationid 和 userid 。

这并不意味着子集合实体应该总是有复合主键，只有当需要时设置；通常是单一的id属性。

复合主键实际上是关系型数据库的一个概念，因为子集合实体有自己的表，需要一个主键。另一方面，例如：在mongodb中，你根本不需要为子集合实体定义主键，因为它们是作为聚合根的一部分来存储的。

聚合根/实体构造函数

构造函数是实体的生命周期开始的地方。一个设计良好的构造函数，担负以下职责：

• 获取所需的实体属性参数，来创建一个有效的实体。应该强制只传递必要的参数，并可以将非必要的属性作为可选参数。
• 检查参数的有效性。
• 初始化子集合。

示例：issue（聚合根）构造函数

using system;
using system.collections.generic;
using system.collections.objectmodel;
using volo.abp;
using volo.abp.domain.entities;

namespace issuetracking.issues
{
  public class issue:aggregateroot<guid>
  {
    public guid repositoryid{get;set;}
    public string title{get;set;}
    public string text{get;set;}
    public guid? assigneduserid{get;set;}
    public bool isclosed{get;set;}
    pulic issueclosereason? closereason{get;set;} //枚举
    public icollection<issuelabel> labels {get;set;}

    public issue(
      guid id,
      guid repositoryid,
      string title,
      string text=null,
      guid? assigneduserid = null
    ):base(id)
    {
      //属性赋值
      repositoryid=repositoryid;
      //有效性检测
      title=check.notnullorwhitespace(title,nameof(title));

      text=text;
      assigneduserid=assigneduserid;
      //子集合初始化
      labels=new collection<issuelabel>();
    }
    private issue(){/*反序列化或orm 需要*/}
  }
}

• issue类通过其构造函数参数，获得属性所需的值，以此创建一个正确有效的实体。
• 在构造函数中验证输入参数的有效性，比如：check.notnullorwhitespace(...) 当传递的值为空时，抛出异常argumentexception。
• 初始化子集合，当使用 labels 集合时，不会获取到空引用异常。
• 构造函数将参数id传递给base类，不在构造函数中生成 guid，可以将其委托给另一个 guid生成服务，作为参数传递进来。
• 无参构造函数对于orm是必要的。我们将其设置为私有，以防止在代码中意外地使用它。

实体属性访问器和方法

上面的示例代码，看起来可能很奇怪。比如：在构造函数中，我们强制传递一个不为null的title。但是，我们可以将 title 属性设置为 null，而对其没有进行任何有效性控制。这是因为示例代码关注点暂时只在构造函数。

如果我们用 public 设置器声明所有的属性，就像上面的issue类中的属性例子，我们就不能在实体的生命周期中强制保持其有效性和完整性。所以：

• 当需要在设置属性时，执行任何逻辑，请将属性设置为私有private。
• 定义公共方法来操作这些属性。

示例：通过方法修改属性

namespace issuetracking.issues
{
  public guid repositoryid {get; private set;} //不更改
  public string title { get; private set; } //更改，需要非空验证
  public string text{get;set;} //无需验证
  public guid? assigneduserid{get;set;} //无需验证
  public bool isclosed { get; private set; } //需要和 closereason 一起更改
  public issueclosereason? closereason { get;private set;} //需要和 isclosed 一起更改

  public class issue:aggregateroot<guid>
  {
    //...
    public void settitle(string title)
    {
      title=check.notnullorwhitespace(title,nameof(title));
    }

    public void close(issueclosereason reason)
    {
      isclosed = true;
      closereason =reason;
    }

    public void reopen()
    {
      isclosed=false;
      closereason=null;
    }
  }
}

• repositoryid 设置器设置为私有private，因为 issue 不能将 issue 移动到另一个 repository 中，该属性创建之后无需更改。
• title 设置器设置为私有，当需要更改时，可以使用 settitle 方法，这是一种可控的方式。
• text 和 assigneduserid 都有公共设置器，因为这两个字段并没有约束，可以是null或任何值。我们认为没有必要定义单独的方法来设置它们。如果以后需要，可以添加更改方法并将其设置器设置为私有。领域层是内部项目，并不会暴露给客户端使用，所以这种更改不会有问题。
• isclosed 和 issueclosereason 是成对修改的属性，分别定义 close 和 reopen 方法一起修改他们。通过这种方式，可以防止在没有任何理由的情况下关闭一个问题。

业务逻辑和实体中的异常处理

当你在实体中进行验证和实现业务逻辑，经常需要管理异常：

• 创建特定领域异常。
• 必要时在实体方法中抛出这些异常。

示例：

public class issue:aggregateroot<guid>
{
  //..
  public bool islocked {get;private set;}
  public bool isclosed{get;private set;}
  public issueclosereason? closereason {get;private set;}

  public void close(issueclosereason reason)
  {
    isclose = true;
    closereason =reason;
  }
  public void reopen()
  {
    if(islocked)
    {
      throw new issuestateexception("不能打开一个锁定的问题！请先解锁！");
    }
    isclosed=false;
    closereason=null;
  }
  public void lock()
  {
    if(!isclosed)
    {
      throw new issuestateexception("不能锁定一个关闭的问题！请先打开！");
    }
  }
  public void unlock()
  {
    islocked = false;
  }
}

这里有两个业务规则：

• 锁定的issue不能重新打开
• 不能锁定一个关闭的issue

issue 类在这些业务规则中抛出异常 issuestateexception 。

namespace issuetracking.issues
{
  public class issuestateexception : exception
  {
    public issuestateexception(string message)
      :base(message)
      {

      }
  }
}

抛出此类异常有两个潜在问题:

1. 在这种异常情况下，终端用户是否应该看到异常(错误)消息？如果是，如何实现本地化异常消息？因为不能在实体中注入和使用istringlocalizer，导致不能使用本地化系统。
2. 对于 web 应用程序或 http api，应该给客户端返回什么 http status code？

abp框架 exception handing 系统处理了这些问题。

示例：抛出业务异常

using volo.abp;
namespace issutracking.issues
{
  public class issuestateexception : buisinessexception
  {
    public issuestateexcetipn(string code)
      : base(code)
      {

      }
  }
}

• issuestateexception 类继承 businessexception 类。abp框架在请求禁用时默认返回 403 http 状态码；发生内部错误是返回 500 http 状态码。
• code 用作本地化资源文件中的一个键，用于查找本地化消息。

现在，我们可以修改 reopen 方法：

public void reopen()
{
  if(islocked)
  {
    throw new issuestateexception("issuetracking:cannotopenlockedissue");
  }
  isclosed=false;
  closereason=null;
}

建议：使用常量代替魔术字符串"issuetracking:cannotopenlockedissue"。

然后在本地化资源中添加一个条目，如下所示:

"issuetracking:cannotopenlockedissue":"不能打开一个锁定的问题！请先解锁！"

• 当抛出异常时，abp自动使用这个本地化消息(基于当前语言)向终端用户显示。
• 异常code（"issuetracking:cannotopenlockedissue"）被发送到客户端，因此它可以以编程方式处理错误情况。

实体中业务逻辑需要用到外部服务

当业务逻辑只使用该实体的属性时，在实体方法中实现业务规则是很简单的。如果业务逻辑需要查询数据库或使用任何应该从依赖注入系统中获取的外部服务时，该怎么办？请记住，实体不能注入服务。

有两个方式实现：

• 在实体方法上实现业务逻辑，并将外部依赖项作为方法的参数。
• 创建领域服务（domain service）

领域服务在后面介绍，现在让我们看看如何在实体类中实现它。

示例：业务规则：一个用户不能同时分配超过3个未解决的问题

public class issue:aggregateroot<guid>
{
  //..
  public guid? assigneduserid{get;private set;}
  //问题分配方法
  public async task assigntoasync(appuser user,iuserissueservice userissueservice)
  {
    var openissuecount = await userissueservice.getopenissuecountasync(user.id);
    if(openissuecount >=3 )
    {
      throw new businessexception("issuetracking:cannotopenlockedissue");
    }
    assigneduserid=user.id;
  }
  public void cleanassignment()
  {
    assigneduserid=null;
  }
}

• assigneduserid 属性设置器设置为私有，通过 assigntoasync 和 cleanassignment 方法进行修改。
• assigntoasync 获取一个 appuser 实体，实际上只用到 user.id，传递实体是为了确保参数值是一个存在的用户，而不是一个随机值。
• iuserissueservice 是一个任意的服务，用于获取分配给用户的问题数量。如果业务规则不满足，则抛出异常。所有规则满足，则设置 assigneduserid 属性值。

此方法完全实现了应用业务逻辑，然而，它有一些问题：

• 实体变得复杂，因为实体类依赖外部服务。
• 实体变得难用，调用方法时需要注入依赖的外部服务 iuserissueservice 作为参数。

聚合和聚合根的最佳实践和原则部分完结！