DDD开发实践调研

喜欢ヅ旅行 2023-06-14 04:24 16阅读 0赞

# 1. 概述 #

DDD为复杂软件的设计提供了指导思想，其将易发生变化的业务核心域放置在限定上下文中，在确保核心域一致性和内聚性的基础上，DDD可以被多种语言和多种技术框架实现，具体的框架实现需要根据实际的业务场景和需求来制定。

核心的指导思路归纳为：

*  关注点放在domain上，将业务领域限定在同一上下文中
 *  降低上下文之间的依赖，通过‘开发主机服务’（REST服务是其中的一种）、‘消息模式’、‘事件驱动’等架构风格实现
 *  遵循分层架构模式

# 2. 架构风格 #

针对DDD的架构设计，《实现领域驱动设计》提到了几种架构风格：六边形架构、REST架构、CQRS、事件驱动等。在实际使用中，落地的架构并非是纯粹其中的一种，而很有可能户将上述几种架构风格结合起来实现。

## 分层图 ##

![format_png][]

## 六边形架构（端口和适配器） ##

所谓的六边形架构，其实是分层架构的扩展，原来的分层架构通常是上下分层的，比如常见的MVC模式，上层是对外的服务接口，下层是对接存储层或者是集成第三方服务，中层是业务逻辑层。我们跳出分层的概念，会发现上面层和下面层其实都是端口+适配器的实现，上面层开放http/tcp端口，采用rest/soap/mq协议等对外提供服务，同时提供对应协议的适配器；下层也是端口+适配器，只不过应用程序这时候变成了调用者，第三方服务或者存储层提供端口和服务，应用程序本身实现适配功能。

基于上述思考，将分层接口中的上层和下层统一起来就变成了六边形架构，基于端口和适配器的实现，示意图如下：

![format_png 1][]

*上图来源于《实现领域驱动设计》的P111*

我认为六边形架构并非创造一种新的架构风格，只是将原来的分层架构风格重新解读，使得架构更加简洁通用。同时，在DDD的设计思想下，六边形架构风格，让领域模型处于架构的核心区域，让开发人员将焦点聚集到领域。**DDD和六边形架构是天然契合的，是DDD的首选架构。**

## REST ##

REST——即Representational State Transfer的缩写，翻译过来是"表现层状态转化"。参考至：[理解RESTful架构][RESTful]。

RESTful风格的架构将‘资源’放在第一位，每个‘资源’都有一个URI与之对应，可以将‘资源’看着是ddd中的实体；RESTful采用具有自描述功能的消息实现无状态通信，提高系统的可用性；至于‘资源’的哪些属性可以公开出去，针对‘资源’的操作，RESTful使用HTTP协议的已有方法来实现：GET、PUT、POST和DELETE。

在DDD的实现中，我们可以将对外的服务设计为RESTful风格的服务，将实体/值对象/领域服务作为'资源'对外提供增删改查服务。但是并不建议直接将实体暴露在外，一来实体的某些隐私属性并不能对外暴露，二来某些资源获取场景并不是一个实体就能满足的，因此我们在实际实践过程中，在领域模型上增加了dto这样一个角色，dto可以组合多个实体/值对象的资源对外暴露。

## CQRS ##

CQRS——Cammand-Query Responsibility Segregation的缩写。翻译过来就是“[命令与查询职责分离][Link 1]”。

简而言之，CQRS就是平常大家在讲的读写分离，通常读写分离的目的是为了提高查询性能，同时达到读/写的解耦。让DDD和CQRS结合，我们可以分别对读和写建模，查询模型通常是一种非规范化数据模型，它并不反映领域行为，只是用于数据显示；命令模型执行领域行为，且在领域行为执行完成后，想办法通知到查询模型。

那么命令模型如何通知到查询模型呢？ 如果查询模型和领域模型共享数据源，则可以省却这一步；如果没有共用数据源，则可以借助于‘消息模式’（Messaging Patterns）通知到查询模型，从而达到最终一致性（Eventual Consistency）。

Martin在blog中指出：CQRS适用于极少数复杂的业务领域，如果不是很适合反而会增加复杂度；另一个适用场景为获取高性能的服务。

![format_png 2][]

*　　　　图片来源于Martin Fowler的blog，图中表述的查询模型和命令模型共用数据源。*

关于CQRS的讨论可以参考Martin大叔的blog：[CQRS][]，以及：[CQRS, Task Based UIs, Event Sourcing agh!][CQRS_ Task Based UIs_ Event Sourcing agh]

## 事件驱动 ##

这一架构风格在下面的demo中并未使用，不做过多阐述。

# 3. 架构实例 #

结合最近在重构的社区服务系统（COMMUNITY），尝试使用上述的指导思想和架构风格，完成一次架构设计尝试，并详述如下：

## 架构图 ##

![format_png 3][]

## 架构详述 ##

COMMUNITY系统架构整合了六边形架构、RESTful架构风格、CQRS架构风格三种架构风格，并遵循经典的分层架构思想。

### 1、在遵循分层架构思想的基础上，引入了六边形架构风格，对内对外均通过适配器+端口的方式呈现： ###

*  面向用户侧，提供http端口，并使用SpringMVC框架的RequestMapping、Controller等组件实现对http 请求的解析，转化为Application层可识别的业务dto对象，这里的Controller+RequestMapping便起着适配器的作用；
 *  面向第三方服务，通过httpclient和tcpclient的适配，可以对接多种协议的第三方服务端口；
 *  面向存储层，通过mongoclient的适配，访问mongodb；通过mybatis的适配，访问oracle；通过redisclient的适配，访问redis；
 *  面向消息中间件，通过mqclient的适配，方为rabbitMQ；

### 2、实现了RESTful架构风格，通过RESTful风格的接口契约对外提供主机开放服务。借助SpringMVC实现。 ###

### 3、实现了CQRS架构风格： ###

*  orcale作为命令模型存储存在，并配以Transaction事务管理。主要存储帖子、评论、话题、圈子、关注等实体信息；
 *  Mongodb作为查询模型存储存在，存储个人动态、社区动态等非结构化数据；
 *  redis同样作为查询模型存储存在，存储用户个人信息、热门评论、热门帖子、热门话题、用户点赞信息等；
 *  Application层分为QueryService和CommandService两大类应用服务，分别组合查询模型和命令模型；
 *  使用rabbitMQ作为消息中间件，CommandService在完成命令模型的维护后，生产事件消息写入rabbitMQ，QueryService作为消费者从rabbitMQ读取事件消息，更新查询模型；
 *  查询模型和命令模型极其对应的application service可以独立部署，独立扩展。

### 4、遵循基本的分层架构风格。 ###

User Interface —— 用户接口层。对外提供各种协议形式的服务，并提供Validation参数校验，authenticate权限认证，业务实体组装器Assembler等。图中标绿组件。

*  接受请求；
 *  请求格式校验及转换；
 *  权限校验；
 *  路由请求；
 *  记录请求；
 *  回复响应；

Application —— 应用服务层。组合多个业务实体、基础设施层的各种组件完成业务服务。图中标黄部分。

*  它是组件的粘合剂，组合domain层的各个组件和 infrastructure层的持久化组件、消息组件等等，完成具体的业务逻辑，提供完整的业务服务。
 *  通过DDD实现业务服务时，检验业务模型的质量的一个标准便是 —— service方法中不要有if/else。如果存在if/else，要么就是系统用例存在耦合，要么就是业务模型不够友好，导致部分业务逻辑泄漏到service了。

Domain —— 业务领域层。DDD概念中的核心业务层，封装所有业务逻辑，包含entity、value object、domain service、domain event等。图中标蓝部分。

*  entity
 *  value object
 *  domain event
 *  domain service
 *  factory
 *  repository

Infrastructure —— 基础设施层。提供公共组件，如：Logging、Trascation、HttpClient等。图中标灰部分。

# 4.demo #

## 项目结构 ##

![format_png 4][]

## 应用层 ##

组织业务，调用domian层的service和repository以及infrastructue的工具等等

代码块

Plain Text

public PostingRespBody posting(RequestDto<PostingReqBody> requestDto) throws BusinessException {

PostingReqBody postingReqBody = requestDto.getBody();

/**

*NOTE： 请求参数校验交给了validation，这里无需校验userId和postId是否为空

String userId = postingReqBody.getUserId();

String title = postingReqBody.getTitle();

String sourceContent = postingReqBody.getSourceContent();

long userIdInLong = Long.valueOf(userId);

/**

* 组装domain model entity

* NOTE：这里的PostAuthor不需要从repository重载，原因在于：deletePost场景需要用户登录后才能操作，

*        在进入service之前，已经在controller层完成了用户身份鉴权，故到达这里的userId肯定是合法的用户

PostAuthor postAuthor = new PostAuthor(userIdInLong);

Post post = postAuthor.posting(title, sourceContent);

/**

* NOTE：使用repository将model entity 写入存储

postRepository.save(post);

/**

* NOTE：使用postAssembler将Post model组装成dto返回。

return postAssembler.assemblePostingRespBody(post);

}

## 领域层 ##

model的行为，是用于组装model的

代码块

Plain Text

public class PostAuthor extends User{

private final static int MIN_LENGTH_POST_SOURCE_CONTENT = 16;

public PostAuthor(long id) {

super(id);

}

/**

* 发布帖子

* @param title

* @param sourceContent

* @return Post 发布得到的帖子

public Post posting(String title, String sourceContent) throws BusinessException {

if(sourceContent.length() < MIN_LENGTH_POST_SOURCE_CONTENT) {

//抛出业务异常

throw new BusinessException(ReturnCode.POST_SOURCE_CONTENT_AT_LEAST_SIXTEEN_WORDS);

}

Post post = new Post(this.getId(), title, sourceContent);

return post;

}

/**

* 删帖

* @param post 拟被删除的帖子实体

* @return post 删帖后的帖子实体

* @throws BusinessException

public Post deletePost(Post post) throws BusinessException {

if (post == null) {

throw new BusinessException(ReturnCode.POST_IS_NOT_EXIT);

}

if (!this.isMyself(post.getPostAuthor())) {

throw new BusinessException(ReturnCode.CAN_NOT_DELETE_OTHER_USERS_POST);

}

post.delete();

return post;

}

domain service，有些行为逻辑不适合放在domain对象上，需要抽出一个领域服务

帖子的过滤逻辑

![format_png 5][]

代码块

Plain Text

public abstract class AbstractContentFilter {

private AbstractContentFilter nextContentFilter;

/**

* 过滤指定内容

* @param content

* @return boolean

*     true —— 通过

*  false —— 不通过

public abstract boolean filtContent(Object content);

/**

* @return the nextContentFilter

public AbstractContentFilter getNextContentFilter() {

return nextContentFilter;

}

/**

* @param nextContentFilter the nextContentFilter to set

public void setNextContentFilter(AbstractContentFilter nextContentFilter) {

this.nextContentFilter = nextContentFilter;

}

@Override

public String toString() {

return super.toString();

}

@Override

public int hashCode() {

return super.hashCode();

}

@Override

public boolean equals(Object obj) {

if(!(obj instanceof AbstractContentFilter)) {

return false;

} else {

return this == obj;

}

public class ImageContentFilter extends AbstractContentFilter {

/* (non-Javadoc)

* @see com.dqdl.community.domain.model.post.ContentFilter#filtContent(com.dqdl.community.domain.model.post.Post)

@Override

public boolean filtContent(Object content) {

// TODO 调用第三方的图片过滤服务实现，已经超过了domain的范畴，此处略去。后续单列文章讲解如何和第三方服务交互。

return true;

}

# 5.资料 #

DDD：

[http://www.cnblogs.com/daoqidelv/p/7492322.html][http_www.cnblogs.com_daoqidelv_p_7492322.html]

[http://www.cnblogs.com/landeanfen/p/4816706.html][http_www.cnblogs.com_landeanfen_p_4816706.html]

实践源码：[https://github.com/daoqidelv/community-ddd-demo/tree/master][https_github.com_daoqidelv_community-ddd-demo_tree_master]

一个DDD框架：[https://github.com/changmingxie/aggregate-framework][https_github.com_changmingxie_aggregate-framework]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9rbS5zYW5rdWFpLmNvbS9hcGkvZmlsZS8zNTg1MTk2NS8zNTg1MjAzOQ?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cDovL2ltYWdlczIwMTcuY25ibG9ncy5jb20vYmxvZy84NDkwNTEvMjAxNzA5Lzg0OTA1MS0yMDE3MDkwOTIxNTgxMDk2MC0xNjU5NjczMTI1LnBuZw?x-oss-process=image/format,png
[RESTful]: http://www.ruanyifeng.com/blog/2011/09/restful
[Link 1]: http://www.udidahan.com/2009/12/09/clarified-cqrs/
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cDovL2ltYWdlczIwMTcuY25ibG9ncy5jb20vYmxvZy84NDkwNTEvMjAxNzA5Lzg0OTA1MS0yMDE3MDkxMDE1NDM1NzUyMi0xNzI0MDk1MDk1LnBuZw?x-oss-process=image/format,png
[CQRS]: https://martinfowler.com/bliki/CQRS.html
[CQRS_ Task Based UIs_ Event Sourcing agh]: http://codebetter.com/gregyoung/2010/02/16/cqrs-task-based-uis-event-sourcing-agh/
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cDovL2ltYWdlczIwMTcuY25ibG9ncy5jb20vYmxvZy84NDkwNTEvMjAxNzA5Lzg0OTA1MS0yMDE3MDkxMDE3NTM0MjIyNi0xMTQ0MjkwMTg0LnBuZw?x-oss-process=image/format,png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9rbS5zYW5rdWFpLmNvbS9hcGkvZmlsZS8zNTg1MTk2NS8zNTgyODEyNg?x-oss-process=image/format,png
[format_png 5]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9rbS5zYW5rdWFpLmNvbS9hcGkvZmlsZS8zNTg1MTk2NS8zNTgyODI3Mg?x-oss-process=image/format,png
[http_www.cnblogs.com_daoqidelv_p_7492322.html]: http://www.cnblogs.com/daoqidelv/p/7492322.html
[http_www.cnblogs.com_landeanfen_p_4816706.html]: http://www.cnblogs.com/landeanfen/p/4816706.html
[https_github.com_daoqidelv_community-ddd-demo_tree_master]: https://github.com/daoqidelv/community-ddd-demo/tree/master
[https_github.com_changmingxie_aggregate-framework]: https://github.com/changmingxie/aggregate-framework