【原】DDD專題案例一《初識(shí)領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)DDD落地方案》

小傅哥 2021-12-13

展開全文

作者：付政委

納百川、吞吐、成自臥龍，笑紅塵、紛繁、當(dāng)乃胸容

微信公眾號(hào)：bugstack蟲洞棧
領(lǐng)取驅(qū)動(dòng)設(shè)計(jì)DDD{Domain-Driven Design}歷史較長但隨著微服務(wù)的興起DDD又活躍到開發(fā)工程師的視線。它提供的是一套架構(gòu)設(shè)計(jì)思想，我們可以使用這套方法論將架構(gòu)設(shè)計(jì)的盡可能做到高內(nèi)聚、低耦合、可擴(kuò)展性強(qiáng)的應(yīng)用服務(wù)。那么本專題以DDD實(shí)戰(zhàn)落地為根本，分章節(jié)設(shè)計(jì)不同的架構(gòu)模型。
學(xué)習(xí)并實(shí)戰(zhàn)是奔入應(yīng)用級(jí)開發(fā)最快的方法，Hi HelloWorld！我來了。

前言介紹

DDD（Domain-Driven Design 領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)）是由Eric Evans最先提出，目的是對軟件所涉及到的領(lǐng)域進(jìn)行建模，以應(yīng)對系統(tǒng)規(guī)模過大時(shí)引起的軟件復(fù)雜性的問題。整個(gè)過程大概是這樣的，開發(fā)團(tuán)隊(duì)和領(lǐng)域?qū)＜乙黄鹜ㄟ^ 通用語言(Ubiquitous Language)去理解和消化領(lǐng)域知識(shí)，從領(lǐng)域知識(shí)中提取和劃分為一個(gè)一個(gè)的子領(lǐng)域（核心子域，通用子域，支撐子域），并在子領(lǐng)域上建立模型，再重復(fù)以上步驟，這樣周而復(fù)始，構(gòu)建出一套符合當(dāng)前領(lǐng)域的模型。

開發(fā)目標(biāo)

依靠領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)的設(shè)計(jì)思想，通過事件風(fēng)暴建立領(lǐng)域模型，合理劃分領(lǐng)域邏輯和物理邊界，建立領(lǐng)域?qū)ο蠹胺?wù)矩陣和服務(wù)架構(gòu)圖，定義符合DDD分層架構(gòu)思想的代碼結(jié)構(gòu)模型，保證業(yè)務(wù)模型與代碼模型的一致性。通過上述設(shè)計(jì)思想、方法和過程，指導(dǎo)團(tuán)隊(duì)按照DDD設(shè)計(jì)思想完成微服務(wù)設(shè)計(jì)和開發(fā)。
1、拒絕泥球小單體、拒絕污染功能與服務(wù)、拒絕一加功能排期一個(gè)月
2、架構(gòu)出高可用極易符合互聯(lián)網(wǎng)高速迭代的應(yīng)用服務(wù)
3、物料化、組裝化、可編排的服務(wù)，提高人效

服務(wù)架構(gòu)

微信公眾號(hào)：bugstack蟲洞棧 | 服務(wù)架構(gòu)

應(yīng)用層{application}

應(yīng)用服務(wù)位于應(yīng)用層。用來表述應(yīng)用和用戶行為，負(fù)責(zé)服務(wù)的組合、編排和轉(zhuǎn)發(fā)，負(fù)責(zé)處理業(yè)務(wù)用例的執(zhí)行順序以及結(jié)果的拼裝。
應(yīng)用層的服務(wù)包括應(yīng)用服務(wù)和領(lǐng)域事件相關(guān)服務(wù)。
應(yīng)用服務(wù)可對微服務(wù)內(nèi)的領(lǐng)域服務(wù)以及微服務(wù)外的應(yīng)用服務(wù)進(jìn)行組合和編排，或者對基礎(chǔ)層如文件、緩存等數(shù)據(jù)直接操作形成應(yīng)用服務(wù)，對外提供粗粒度的服務(wù)。
領(lǐng)域事件服務(wù)包括兩類：領(lǐng)域事件的發(fā)布和訂閱。通過事件總線和消息隊(duì)列實(shí)現(xiàn)異步數(shù)據(jù)傳輸，實(shí)現(xiàn)微服務(wù)之間的解耦。

領(lǐng)域?qū)觷domain}

領(lǐng)域服務(wù)位于領(lǐng)域?qū)?，為完成領(lǐng)域中跨實(shí)體或值對象的操作轉(zhuǎn)換而封裝的服務(wù)，領(lǐng)域服務(wù)以與實(shí)體和值對象相同的方式參與實(shí)施過程。
領(lǐng)域服務(wù)對同一個(gè)實(shí)體的一個(gè)或多個(gè)方法進(jìn)行組合和封裝，或?qū)Χ鄠€(gè)不同實(shí)體的操作進(jìn)行組合或編排，對外暴露成領(lǐng)域服務(wù)。領(lǐng)域服務(wù)封裝了核心的業(yè)務(wù)邏輯。實(shí)體自身的行為在實(shí)體類內(nèi)部實(shí)現(xiàn)，向上封裝成領(lǐng)域服務(wù)暴露。
為隱藏領(lǐng)域?qū)拥臉I(yè)務(wù)邏輯實(shí)現(xiàn)，所有領(lǐng)域方法和服務(wù)等均須通過領(lǐng)域服務(wù)對外暴露。
為實(shí)現(xiàn)微服務(wù)內(nèi)聚合之間的解耦，原則上禁止跨聚合的領(lǐng)域服務(wù)調(diào)用和跨聚合的數(shù)據(jù)相互關(guān)聯(lián)。

基礎(chǔ)層{infrastructrue}

基礎(chǔ)服務(wù)位于基礎(chǔ)層。為各層提供資源服務(wù)（如數(shù)據(jù)庫、緩存等），實(shí)現(xiàn)各層的解耦，降低外部資源變化對業(yè)務(wù)邏輯的影響。
基礎(chǔ)服務(wù)主要為倉儲(chǔ)服務(wù)，通過依賴反轉(zhuǎn)的方式為各層提供基礎(chǔ)資源服務(wù)，領(lǐng)域服務(wù)和應(yīng)用服務(wù)調(diào)用倉儲(chǔ)服務(wù)接口，利用倉儲(chǔ)實(shí)現(xiàn)持久化數(shù)據(jù)對象或直接訪問基礎(chǔ)資源。

接口層{interfaces}

接口服務(wù)位于用戶接口層，用于處理用戶發(fā)送的Restful請求和解析用戶輸入的配置文件等，并將信息傳遞給應(yīng)用層。

開發(fā)環(huán)境

1、jdk1.8【jdk1.7以下只能部分支持netty】
2、springboot 2.0.6.RELEASE
3、idea + maven

代碼示例

 1itstack-demo-ddd-01
 2└── src
 3    ├── main
 4    │   ├── java
 5    │   │   └── org.itstack.demo
 6    │   │       ├── application
 7    │   │       │    ├── event
 8    │   │       │    │   └── ApplicationRunner.java  
 9    │   │       │    └── service
10    │   │       │        └── UserService.java    
11    │   │       ├── domain
12    │   │       │    ├── model
13    │   │       │    │   ├── aggregates
14    │   │       │    │   │   └── UserRichInfo.java   
15    │   │       │    │   └── vo
16    │   │       │    │       ├── UserInfo.java   
17    │   │       │    │       └── UserSchool.java 
18    │   │       │    ├── repository
19    │   │       │    │   └── IuserRepository.java    
20    │   │       │    └── service
21    │   │       │        └── UserServiceImpl.java    
22    │   │       ├── infrastructure
23    │   │       │    ├── dao
24    │   │       │    │   ├── impl
25    │   │       │    │   │   └── UserDaoImpl.java    
26    │   │       │    │   └── UserDao.java    
27    │   │       │    ├── po
28    │   │       │    │   └── UserEntity.java 
29    │   │       │    ├── repository
30    │   │       │    │   ├── mysql
31    │   │       │    │   │   └── UserMysqlRepository.java
32    │   │       │    │   ├── redis
33    │   │       │    │   │   └── UserRedisRepository.java        
34    │   │       │    │   └── UserRepository.java 
35    │   │       │    └── util
36    │   │       │        └── RdisUtil.java
37    │   │       ├── interfaces
38    │   │       │    ├── dto
39    │   │       │    │   └── UserInfoDto.java    
40    │   │       │    └── facade
41    │   │       │        └── DDDController.java
42    │   │       └── DDDApplication.java
43    │   ├── resources    
44    │   │   └── application.yml
45    │   └── webapp    
46    │       └── WEB-INF
47    │            └── index.jsp   
48    └── test
49         └── java
50             └── org.itstack.demo.test
51                 └── ApiTest.java

演示部分重點(diǎn)代碼塊，完整代碼下載關(guān)注公眾號(hào)；bugstack蟲洞棧 | 回復(fù)DDD落地

application/UserService.java | 應(yīng)用層用戶服務(wù)，領(lǐng)域?qū)臃?wù)做具體實(shí)現(xiàn)

 1/**
 2 * 應(yīng)用層用戶服務(wù)
 3 * 蟲洞棧：https://
 4 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 5 * Create by fuzhengwei on @2019
 6 */
 7public interface UserService {
 8
 9    UserRichInfo queryUserInfoById(Long id);
10
11}

domain/repository/IuserRepository.java | 領(lǐng)域?qū)淤Y源庫，由基礎(chǔ)層實(shí)現(xiàn)

 1/**
 2 * 蟲洞棧：https://
 3 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 4 * Create by fuzhengwei on @2019
 5 */
 6public interface IUserRepository {
 7
 8    void save(UserEntity userEntity);
 9
10    UserEntity query(Long id);
11
12}

domain/service/UserServiceImpl.java | 應(yīng)用層實(shí)現(xiàn)類，應(yīng)用層是很薄的一層可以只做服務(wù)編排

 1/**
 2 * 蟲洞棧：https://
 3 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 4 * Create by fuzhengwei on @2019
 5 */
 6@Service("userService")
 7public class UserServiceImpl implements UserService {
 8
 9    @Resource(name = "userRepository")
10    private IUserRepository userRepository;
11
12    @Override
13    public UserRichInfo queryUserInfoById(Long id) {
14
15        // 查詢資源庫
16        UserEntity userEntity = userRepository.query(id);
17
18        UserInfo userInfo = new UserInfo();
19        userInfo.setName(userEntity.getName());
20
21        // TODO 查詢學(xué)校信息，外部接口
22        UserSchool userSchool_01 = new UserSchool();
23        userSchool_01.setSchoolName("振華高級(jí)實(shí)驗(yàn)中學(xué)");
24
25        UserSchool userSchool_02 = new UserSchool();
26        userSchool_02.setSchoolName("東北電力大學(xué)");
27
28        List<UserSchool> userSchoolList = new ArrayList<>();
29        userSchoolList.add(userSchool_01);
30        userSchoolList.add(userSchool_02);
31
32        UserRichInfo userRichInfo = new UserRichInfo();
33        userRichInfo.setUserInfo(userInfo);
34        userRichInfo.setUserSchoolList(userSchoolList);
35
36        return userRichInfo;
37    }
38
39}

infrastructure/po/UserEntity.java | 數(shù)據(jù)庫對象類

 1/**
 2 * 數(shù)據(jù)庫實(shí)體對象；用戶實(shí)體
 3 * 蟲洞棧：https://
 4 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 5 * Create by fuzhengwei on @2019
 6 */
 7public class UserEntity {
 8
 9    private Long id;
10    private String name;
11
12    get/set ...
13}

infrastructrue/repository/UserRepository.java | 領(lǐng)域?qū)佣x接口，基礎(chǔ)層資源庫實(shí)現(xiàn)

 1/**
 2 * 蟲洞棧：https://
 3 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 4 * Create by fuzhengwei on @2019
 5 */
 6@Repository("userRepository")
 7public class UserRepository implements IUserRepository {
 8
 9    @Resource(name = "userMysqlRepository")
10    private IUserRepository userMysqlRepository;
11
12    @Resource(name = "userRedisRepository")
13    private IUserRepository userRedisRepository;
14
15    @Override
16    public void save(UserEntity userEntity) {
17        //保存到DB
18        userMysqlRepository.save(userEntity);
19
20        //保存到Redis
21        userRedisRepository.save(userEntity);
22    }
23
24    @Override
25    public UserEntity query(Long id) {
26
27        UserEntity userEntityRedis = userRedisRepository.query(id);
28        if (null != userEntityRedis) return userEntityRedis;
29
30        UserEntity userEntityMysql = userMysqlRepository.query(id);
31        if (null != userEntityMysql){
32            //保存到Redis
33            userRedisRepository.save(userEntityMysql);
34            return userEntityMysql;
35        }
36
37        // 查詢?yōu)镹ULL
38        return null;
39    }
40
41}

interfaces/dto/UserInfoDto.java | DTO對象類，隔離數(shù)據(jù)庫類

 1/**
 2 * 蟲洞棧：https://
 3 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 4 * Create by fuzhengwei on @2019
 5 */
 6public class UserInfoDto {
 7
 8    private Long id;        // ID
 9
10    public Long getId() {
11        return id;
12    }
13
14    public void setId(Long id) {
15        this.id = id;
16    }
17
18}

interfaces/facade/DDDController.java | 門面接口

 1/**
 2 * 蟲洞棧：https://
 3 * 公眾號(hào)：bugstack蟲洞棧 | 歡迎關(guān)注并獲取更多專題案例源碼
 4 * Create by fuzhengwei on @2019
 5 */
 6@Controller
 7public class DDDController {
 8
 9    @Resource(name = "userService")
10    private UserService userService;
11
12    @RequestMapping("/index")
13    public String index(Model model) {
14        return "index";
15    }
16
17    @RequestMapping("/api/user/queryUserInfo")
18    @ResponseBody
19    public ResponseEntity queryUserInfo(@RequestBody UserInfoDto request) {
20        return new ResponseEntity<>(userService.queryUserInfoById(request.getId()), HttpStatus.OK);
21    }
22
23}