基于 DDD 的微服务设计演示 2021-09-15 程序之旅,记录 3 条评论 1638 次阅读 ### 基于 DDD 的微服务设计演示 [TOC] #### 单 Service 实现数据查询 用单 Service 注入不同的 Dao，实现各种不同的查询。 > 大数据相关产品，运用大数据技术对海量的数据进行分析处理，并且最终的结果是通过各种报表来查询并展示。因此这些项目除了后台的各种分析处理以外，还要在前段展现各种报表，而且这些报表非常多且繁杂。同时，使用这个系统的都是决策型领导，报表的改变非常的频繁，因此我们需要具备快速开发报表的能力。 每个报表在 service 中的代码基本相同，从前端获取查询参数，然后调用 Dao 执行查询，最多再做一些翻页的操作。 1. 以往每个 Dao 都要写一个自己的接口，然后配置一个 Mapper，但 Dao 接口都长得一模一样,只是接口名与 Mapper 不同。 2. 过去的设计,每个 Service 都对应一个Dao，现在一个 Service 要对应很多个 Dao。 ```xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"..> <description>The application context for query</description> <bean id="customerQry" class="com demo2 support service. impl. Query Servicelmpl"> <property name="queryDao"> <bean class="com demo2 support dao impl. QueryDaoMybatisImpl"> <property name="sqlMapper" value="com demo2 trade query dao. Customer Mapper" ></property> </bean> </property> </bean> </beans> ``` dao 的实现 ```xml <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.newgrand.iotmanagement.mapper.IotDeviceMapper"> <sql id="select"> select * from iot_device where 1 = 1 </sql> <!--查询条件部分--> <sql id="conditions"> <if test="id != '' and id != null"> and id = #{id} </if> </sql> <!-- 翻页查询部分--> <sql id="isPage"> <if test="size != null and size =!''"> limit #{size} offset #{firstRow} </if> </sql> <select id="query" parameterType="java.util.HashMap" resultType="com.newgrand.iotmanagement.entity.IotDevice"> <include refid="select"/> <include refid="conditions"/> <include refid="isPage"/> </select> <!-- 计算 count部分 --> <select id="count" parameterType="java.util.HashMap" resultType="java.lang.Long"> select count(*)from( <include refid="select"/> <include refid="conditions"/> ) count </select> <!--求和计算部分--> <select id="aggregate" parameterType="java.util.HashMap" resultType="java.util.HashMap"> select ${aggregation} from( <include refid="select"/> <include refid="conditions"/> )aggregation </select> </mapper> ``` 如果是一些关联查询 ```xml <?xml version="1.0"encoding="UTF-8" ?> <beans xmlns= "httP://www.springframework.org/schema/beans" ... > <description>The application context for query</description> <bean id="productQry"class="com demo2 support repository. AutofillQueryServicelmpl"> <property name="queryDao"> <bean class="com demo2 support dao impl. Query DaoMybatislmpl"> <property name="sqlMapper" value= "om demo2trade query dao. ProductMapper"></property> </bean> </property> <property name="dao" ref= "basicDao"></property> </bean> </beans> ``` 同时配置 join 的操作 ```xml <?xml version="1.0"encoding="UTF-8" ?> <vobjs> <vo class="com demo2trade entity. Product" tableName="Product"> <property name="id"column="id" isPrimaryKey="true"></property> <property name="name" column="name"></property> <property name="price"column="price"></property> <property name="unit" column="unit"></property> <property name="classify" column="classify" ></property> <property name="supplierid" column="supplier_id"></property> <join name="supplier" joinKey="supplierid" joinType="manyToOne" class="com.demo2trade entity. Supplier"></join> </vo> <vo class="com.demo2 trade entity. Supplier" tableName="Supplier"> <property name="id"column="id" isPrimaryKey="true"></property> <property name="name" column="name" ></property> </vo> </vobjs> ``` 补填就配置 AutofillQueryServiceImpl，不补填就配置 QueryServiceImpl 注意:如果配置的是 AutofillQueryServicelmpl, 除了配置 queryDao,还要配置 basicDao #### 数据补填对微服务的支持 当 Product 微服务要补填 Supplier 时，只能远程调用 Supplier 微服务的相应接口，数据补填必须要技术中台提供对微服务的相应支持。 ```xml <?xml version="1.0"encoding="UTF-8" ?> <vobjs> <vo class="com demo2 product entity. Product" tableName="Product"> <property name="id" column="id" isPrimarykey="true"></property> <property name="name"column="name" ></property> <property name="price"column="price"></property> <property name="unit"column="unit"></property> <property name="classify " column="classify" ></property> <property name="supplier_id" column="supplier_id"></property> <ref name="supplier"refKey="supplier_id" refType="manyToOne" bean = "com.demo2.product.service.SupplierService" method = "loadSupplier" listMethod="loadSuppliers"> </vo> </vobjs> ``` ##### Supplier 微服务提供 2 个查询接口 - Supplier loadSupplier(id),通过某个 id 进行查找 - `List<Supplier> loadSupplier(List<Long> ids)` 通过多个 id 进行批量查找 > - method 配置的是对单个 ID 进行查找的方法 > - listMethod 配置的是对多个 ID 批量查找的方法 #### 通用仓库与工厂的设计 DDD 的架构设计增加了仓库与工厂，除了读写数据库以外，还实现了对领域对象的映射与装配。传统的DDD设计,每个模块都有自己的仓库与工厂，创建出来后放到仓库的缓存中,供上层应用访问，当领域对象在经过一系列操作以后,最后通过仓库完成数据的持久化。 仓库和工厂对 Dao 替换的同时，还扩展了许多的功能，如数据的补填、领域对象的映射与装配、聚合的处理。  #### 原有的遗留系统要通过改造转型为 DDD - 通过邻域建模添加 vObj.xml - 将原来注入 Dao 改为注入仓库 PS: 至于真正的实现微服务的架构还需要很多的细节，需要工作的经验与学习的日积月累，领域模型的学习就先告一段落，接下来就是 DDD 如何与微服务 Spring cloud 技术工具的配合使用。 打赏: 微信, 支付宝 标签: java, 领域模型, DDD, 微服务 本作品采用 知识共享署名-相同方式共享 4.0 国际许可协议 进行许可。
微信
支付宝
刚上厕所没带纸，正苦恼着该怎么办，结果刷到了大佬的文章，瞬间感觉人生没有什么坎是过不去的，不擦了，直接站起来走了，感谢大佬的分享
很久没有写博客了啊。
最近公司有点忙，学的都是管理上的知识，不好写博客的哦。