一、前言

在上一章节介绍了领域驱动设计的基本概念以及按照领域驱动设计的思想进行代码分层，但是仅仅只是从一个简单的分层结构上依然没法理解DDD以及如何去开发这样的微服务。另外往往按照这样分层后依然感觉和MVC也没有什么差别，也没有感受到带来什么非常大的好处。那么问题出在哪呢？我个人觉得DDD学起来更像是一套指导思想，不断的将学习者引入到领域触发的思维中去，而这恰恰也是最难学习的地方。时而感觉会了，而实际开发中又不对，本来已经拆解清晰了，但怎么又那么像MVC了。甚至怀疑自己，我在干嘛？

无论是DDD、MVC，他们更像是家里三居或者四局的格局，每一种格局方式都是为了更好的实现对应架构下的设计思想。但，不是说给你一个通用的架构模式，你就能开发出干净(高内聚)、整洁(低耦合)、漂亮(模块化)的代码。这就像是你家住三居、他家也住三居，但是你们屋子的舒适情况就一样吗？｛再有，你家里会把厕所安在厨房吗？但你的代码是否这么干过，不合理的摆放导致重构延期。｝

另外DDD之所以看着简单但又不那么好落地，个人认为很重要就是领域思想，DDD只是指导但是不能把互联网天下每一个业务行为开发都拿出来举例子给你看，每个领域需要设计。所以需要一些领域专家｛产品+架构+不是杠精的程序员｝来讨论梳理，将业务形态设计出合理的架构&代码。

二、案例目标

本案例通过一个商品下单规则的场景来进行演示DDD；

假设产品需求业务运行人员可以对不同的商品配置一些规则，这些规则可以满足不同用户类型可以下单不同商品。
另外一些行为规则是会随着业务发展而增加或者变动的，所以不能写死｛写死太吓人了｝。
数据库的PO类不应该被外部服务调用，这也是必须的。如果你开发过很多系统，那么可能已经吃过亏并意识到这个问题。
按照DDD思想我们尝试需要设计一个规则引擎的服务，通过给外部提供非常简单的接口（application）来获取最终结果。
通过这样的案例可以很容易的感受到目前的四层架构确实在实现DDD思想上有很多的帮助。

>如图；DDD分层结构 | 指导设计架构

三、DDD思想 · 开发设计

通过领域驱动设计的思想，从领域知识中提取和划分为一个一个的子领域（核心子域，通用子域，支撑子域），并在子领域上建立模型。那么在技术实现上就需要去支撑这种建模，以使我们的代码模块独立、免污染、易于扩展。

在上面我们提到需要开发一个可扩展使用的规则树，那么如果只是单纯的一次性需求，最快的方式是if语句就搞定了。但是为了使这个领域服务具备良好的使用和扩展性，我们需要做些拆分，那么如下；

1、你是否想过系统在过滤过则的时候其实就像执行一棵二叉树一样非左即右侧，每一条线上都有着执行条件，通过判断来达到最终的结果。

2、按照树形结构我们将定义出来四个类；树、节点、果实、指向线(From-To)，用于描述我们的规则行为。

3、在此基础上需要实现一个逻辑定义与规则树执行引擎，通过统一的引擎服务来执行我们每次配置好的规则树。

>如图；领域开发设计服务

四、工程模型

 
itstack-demo-ddd-
└── src
    ├── main
    │   ├──  java 
    │   │   └── org.itstack.demo
    │   │       ├── application
    │   │       │├── MallRuleService.java
    │   │       │└── MallTreeService.java
    │   │       ├── domain
    │   │       │├── rule
    │   │       ││   ├── model
    │   │       ││   │   ├── aggregates
    │   │       ││   │   │   └── UserRichInfo.java
    │   │       ││   │   └── vo
    │   │       ││   │       ├── DecisionMatter.java
    │   │       ││   │       ├── EngineResult.java
    │   │       ││   │       ├── TreeNodeInfo.java
    │   │       ││   │       ├── TreeNodeLineInfo.java
    │   │       ││   │       └── UserSchool.java
    │   │       ││   ├── repository
    │   │       ││   │   └── IRuleRepository.java
    │   │       ││   └── service
    │   │       ││       ├── engine
    │   │       ││       │   ├── impl
    │   │       ││       │   └── EngineFilter.java
    │   │       ││       ├── logic
    │   │       ││       │   ├── impl
    │   │       ││       │   └── LogicFilter.java
    │   │       ││       └── MallRuleServiceImpl.java
    │   │       │└── tree
    │   │       │    ├── model
    │   │       │    │   ├── aggregates
    │   │       │    │   │   └── TreeCollect.java
    │   │       │    │   └── vo
    │   │       │    │       ├── TreeInfo.java
    │   │       │    │       └── TreeRulePoint.java
    │   │       │    ├── repository
    │   │       │    │   └── ITreeRepository.java
    │   │       │    └── service
    │   │       │        └── MallTreeServiceImpl.java
    │   │       ├── infrastructure
    │   │       │├── common
    │   │       ││   └── Constants.java
    │   │       │├── dao
    │   │       ││   ├── RuleTreeDao.java
    │   │       ││   ├── RuleTreeNodeDao.java
    │   │       ││   └── RuleTreeNodeLineDao.java
    │   │       │├── po
    │   │       ││   ├── RuleTree.java
    │   │       ││   ├── RuleTreeConfig.java
    │   │       ││   ├── RuleTreeNode.java
    │   │       ││   └── RuleTreeNodeLine.java
    │   │       │├── repository
    │   │       ││   ├── cache
    │   │       ││   │   └── RuleCacheRepository.java
    │   │       ││   ├── mysql
    │   │       ││   │   ├── RuleMysqlRepository.java
    │   │       ││   │   └── TreeMysqlRepository.java
    │   │       ││   ├── RuleRepository.java
    │   │       ││   └── TreeRepository.java
    │   │       │└── util
    │   │       │    └── CacheUtil.java
    │   │       ├── interfaces
    │   │       │├── dto
    │   │       ││├── DecisionMatterDTO.java
    │   │       ││└── TreeDTO.java
    │   │       │└── DDDController.java
    │   │       └── DDDApplication.java
    │   └── resources
    │       ├── mybatis
    │       └── application.yml
    └── test
         └── java
             └── org.itstack.demo.test
                 └──  api Test.java

演示部分重点代码块，完整代码下载关注公众号；bugstack虫洞栈 | 回复DDD落地

application应用层

>application/MallRuleService.java | 应用层定义接口服务，也可以适当做简单包装

 
/**
 * 商超规则过滤服务；提供规则树决策功能
 * 微信公众号：bugstack虫洞栈 | 专注原创技术专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */public interface MallRuleService {

    /**
     * 决策服务
     * @param matter 决策物料
     * @return       决策结果
     */    EngineResult process(final DecisionMatter matter);

}

domain领域层

domain中有两个领域服务；规则树信息领域、规则执行领域，通过合理的抽象化来实现高内聚、低耦合的模块化服务

>domain/service/MallRuleServiceImpl.java | 领域层中的service来实现应用层接口

 
/**
 * 规则树服务；提供规则规律功能
 *
 *、rule包下只进行规则决策领域的处理
 *、封装决策行为到领域模型中，外部只需要调用和处理结果即可
 *、可以扩展不同的决策引擎进行统一管理
 *
 * 微信公众号：bugstack虫洞栈 | 专注原创技术专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */@Service("mallRuleService")
public class MallRuleServiceImpl implements MallRuleService {

    private Logger logger = LoggerFactory.getLogger(MallRuleServiceImpl.class);

    @Resource(name = "ruleEngineHandle")
    private EngineFilter ruleEngineHandle;

    @Override
    public EngineResult process(DecisionMatter matter) {
        try {
            return ruleEngineHandle.process(matter);
        } catch (Exception e) {
            logger.error("决策引擎执行失败", e);
            return new EngineResult(false);
        }
    }

}

>domain/service/logic/LogicFilter.java | 逻辑决策定义

 
/**
 * 微信公众号：bugstack虫洞栈 | 专注原创技术专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */public interface LogicFilter {

    /**
     * 逻辑决策器
     * @param matterValue          决策值
     * @param treeNodeLineInfoList 决策节点
     * @return                     下一个节点Id
     */    Long filter(String matterValue, List<TreeNodeLineInfo> treeNodeLineInfoList);

    /**
     * 获取决策值
     *
     * @param decisionMatter 决策物料
     * @return               决策值
     */    String matterValue(DecisionMatter decisionMatter);

}

>domain/service/engine/EngineFilter.java | 引擎执行定义

 
/**
 * 微信公众号：bugstack虫洞栈 | 专注原创技术专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */public interface EngineFilter {

    EngineResult process(final DecisionMatter matter) throws Exception;

}

infrastructure基础层

实现领域层仓储定义
数据库操作为非业务属性的功能操作
在仓储实现层进行组合装配DAO&Redis&Cache等

>infrastructure/repository/RuleRepository.java

 
/**
 * 微信公众号：bugstack虫洞栈 | 专注原创技术专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */public interface EngineFilter {

    EngineResult process(final DecisionMatter matter) throws Exception;

}

interfaces接口层

包装应用接口对外提供api
外部传输对象采用DTO类，主要为了避免内部类被污染｛不断的迭代的需求会在类中增加很多字段｝
目前依然是提供的Http服务，如果提供的rpc服务，将需要对外提供可引用jar

>interfaces/DDDController.java

 
**
 * 微信公众号：bugstack虫洞栈 | 欢迎关注学习专题案例
 * 论坛：
 * Create by 小傅哥 on @
 */@Controller
public class DDDController {

    private Logger logger = LoggerFactory.getLogger(DDDController.class);

    @Resource
    private MallTreeService mallTreeService;
    @Resource
    private MallRuleService mallRuleService;

    /**
     * 测试接口：
     * 请求参数：{"treeId":}
     */    @ request Mapping(path = "/api/tree/queryTreeSummaryInfo", method = RequestMethod.POST)
    @ResponseBody
    public ResponseEntity queryTreeSummaryInfo(@RequestBody TreeDTO request) {
        String reqStr = JSON.toJSONString(request);
        try {
            logger.info("查询规则树信息{}Begin req：{}", request.getTreeId(), reqStr);
            TreeCollect treeCollect = mallTreeService.queryTreeSummaryInfo(request.getTreeId());
            logger.info("查询规则树信息{}End res：{}", request.getTreeId(), JSON.toJSON(treeCollect));
            return new ResponseEntity<>(treeCollect, HttpStatus.OK);
        } catch (Exception e) {
            logger.error("查询规则树信息{}Error req：{}", request.getTreeId(), reqStr, e);
            return new ResponseEntity<>(e.getMessage(), HttpStatus.OK);
        }
    }

    /**
     * 测试接口：
     * 请求参数：{"treeId":,"userId":"fuzhengwei","valMap":{"gender":"man","age":"25"}}
     */    @RequestMapping(path = "/api/tree/decisionRuleTree", method = RequestMethod.POST)
    @ResponseBody
    public ResponseEntity decisionRuleTree(@RequestBody DecisionMatterDTO request) {
        String reqStr = JSON.toJSONString(request);
        try {
            logger.info("规则树行为信息决策{}Begin req：{}", request.getTreeId(), reqStr);
            DecisionMatter decisionMatter = new DecisionMatter();
            decisionMatter.setTreeId(request.getTreeId());
            decisionMatter.setUserId(request.getUserId());
            decisionMatter.setValMap(request.getValMap());
            EngineResult engineResult = mallRuleService.process(decisionMatter);
            logger.info("规则树行为信息决策{}End res：{}", request.getTreeId(), JSON.toJSON(engineResult));
            return new ResponseEntity<>(engineResult, HttpStatus.OK);
        } catch (Exception e) {
            logger.error("规则树行为信息决策{}Error req：{}", request.getTreeId(), reqStr, e);
            return new ResponseEntity<>(e.getMessage(), HttpStatus.OK);
        }
    }

}

五、测试验证

>规则树结构{数据库转Json} | 可自行定义

 
{
    "treeNodeMap": {
        "": {
            "nodeType":,
            "ruleDesc": "用户性别[男/女]",
            "ruleKey": "userGender",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": "man"
                },
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": "woman"
                }
            ]
        },
        "": {
            "nodeType":,
            "ruleDesc": "用户年龄",
            "ruleKey": "userAge",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": ""
                },
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": ""
                }
            ]
        },
        "": {
            "nodeType":,
            "ruleDesc": "用户年龄",
            "ruleKey": "userAge",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": ""
                },
                {
                    "nodeIdFrom":,
                    "nodeIdTo":,
                    "ruleLimitType":,
                    "ruleLimitValue": ""
                }
            ]
        },
        "": {
            "nodeType":,
            "nodeValue": "果实A",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [ ]
        },
        "": {
            "nodeType":,
            "nodeValue": "果实B",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [ ]
        },
        "": {
            "nodeType":,
            "nodeValue": "果实C",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [ ]
        },
        "": {
            "nodeType":,
            "nodeValue": "果实D",
            "treeId":,
            "treeNodeId":,
            "treeNodeLineInfoList": [ ]
        }
    },
    "treeRoot": {
        "treeId":,
        "treeName": "购物分类规则树",
        "treeRootNodeId":
    }
}

>通过postman调用 | raw => json

查询规则树信息

测试接口：`

请求参数：{“treeId”:10001}

 
{
    "treeInfo": {
        "treeId":,
        "treeName": "购物分类规则树",
        "treeDesc": "用于分类不同类型用户可购物范围",
        "nodeCount":,
        "lineCount":
    },
    "treeRulePointList": [
        {
            "ruleKey": "userGender",
            "ruleDesc": "用户性别[男/女]"
        },
        {
            "ruleKey": "userAge",
            "ruleDesc": "用户年龄"
        }
    ]
}

规则树行为信息决策

测试接口：